Configure GitHub Actions

.github/workflows/ci.yaml

@@ -0,0 +1,35 @@
+# https://docs.docker.com/build/ci/github-actions/multi-platform/
+name: ci
+on: push
+jobs:
+  build:
+    runs-on: ubuntu-latest
+    steps:
+    - name: Checkout
+      uses: actions/checkout@v4
+    - name: Set up QEMU
+      uses: docker/setup-qemu-action@v3
+    - name: Set up Docker Buildx
+      uses: docker/setup-buildx-action@v3
+    - name: Login to Docker Hub
+      uses: docker/login-action@v3
+      with:
+        username: ${{ secrets.DOCKERHUB_USERNAME }}
+        password: ${{ secrets.DOCKERHUB_TOKEN }}
+    - name: Generate tag
+      run: |
+        set -euo pipefail
+
+        # https://github.com/github/docs/issues/15319#issuecomment-1662257301
+        echo TAG="${{ github.event.pull_request && github.head_ref || github.ref_name }}"
+        if [ "$TAG" = "main" ]; then
+          TAG=latest
+        fi
+        echo "TAG=$TAG" >> "$GITHUB_ENV"
+    - name: Build and push
+      uses: docker/build-push-action@v5
+      with:
+        context: .
+        platforms: linux/amd64
+        push: true
+        tags: ${{ secrets.DOCKERHUB_USERNAME }}/cost-manager:${{ env.TAG }}

pkg/controller/spot_migrator.go

@@ -111,6 +111,7 @@ func (sm *SpotMigrator) Start(ctx context.Context) error {
 	}
 }
 
+// run runs spot migration
 func (sm *SpotMigrator) run(ctx context.Context) error {
 	logger := log.FromContext(ctx)
 	for {
@@ -162,7 +163,7 @@ func (sm *SpotMigrator) run(ctx context.Context) error {
 		// If any on-demand Nodes were created while draining then we assume that there are no more
 		// spot VMs available and that spot migration is complete
 		if nodeCreated(beforeDrainOnDemandNodes, afterDrainOnDemandNodes) {
-			logger.Info("Node was created while draining")
+			logger.Info("Spot migration complete")
 			return nil
 		}
 	}
@@ -187,7 +188,7 @@ func (sm *SpotMigrator) listOnDemandNodes(ctx context.Context) ([]*corev1.Node,
 	return onDemandNodes, nil
 }
 
-// drainNode drains the specified Node and deletes the underlying instance
+// drainAndDeleteNode drains the specified Node and deletes the underlying instance
 func (sm *SpotMigrator) drainAndDeleteNode(ctx context.Context, node *corev1.Node) error {
 	logger := log.FromContext(ctx, "node", node.Name)
 
@@ -215,7 +216,7 @@ func (sm *SpotMigrator) drainAndDeleteNode(ctx context.Context, node *corev1.Nod
 	// Since the underlying instance has been deleted we expect the Node object to be deleted from
 	// the Kubernetes API server by the node controller:
 	// https://kubernetes.io/docs/concepts/architecture/cloud-controller/#node-controller
-	logger.Info("Waiting for Node to be deleted")
+	logger.Info("Waiting for Node object to be deleted")
 	err = kubernetes.WaitForNodeToBeDeleted(ctx, sm.Clientset, node.Name)
 	if err != nil {
 		return err