feat: add support for redirecting cluster deploys in hookd for migrat…

…ion purposes

* add feature config flag ClusterMigrationRedirect
* add parsing of redirect key=value string and redirect deploys to
  desired cluster

oo-authored-by: Vegar Sechmann Molvig <[email protected]>
Co-authored-by: Roger Bjørnstad <[email protected]>

charts/hookd/Feature.yaml

@@ -30,6 +30,11 @@ values:
     displayName: Google service account
     computed:
       template: '"{{.Management.hookd_google_service_account_email}}"'
+  clusterMigrationRedirect:
+    description: Cluster reference for migration purposes (comma separated key=val)
+    displayName: Cluster migration redirect
+    config:
+      type: string
   image.imagePullPolicy:
     config:
       type: string

charts/hookd/templates/secret.yaml

@@ -27,3 +27,4 @@ stringData:
   HOOKD_NAIS_API_ADDRESS: "{{ .Values.naisAPI.address }}"
   HOOKD_NAIS_API_INSECURE_CONNECTION: "{{ .Values.naisAPI.insecureConnection }}"
   OTEL_EXPORTER_OTLP_ENDPOINT: "{{ .Values.otelExporterOtlpEndpoint }}"
+  HOOKD_CLUSTER_MIGRATION_REDIRECT: "{{ .Values.clusterMigrationRedirect }}"

charts/hookd/values.yaml

@@ -45,3 +45,5 @@ imagePullSecrets: []
 naisAPI:
   address: "nais-api:3001"
   insecureConnection: "false"
+
+clusterMigrationRedirect:

cmd/hookd/main.go

@@ -172,8 +172,12 @@ func run() error {
 }
 
 func startGrpcServer(cfg config.Config, db database.DeploymentStore, apikeys database.ApiKeyStore) (*grpc.Server, dispatchserver.DispatchServer, error) {
+	clusterRedirects, err := parseKeyVal(cfg.ClusterMigrationRedirect)
+	if err != nil {
+		return nil, nil, fmt.Errorf("unable to parse cluster migration redirects: %v", err)
+	}
 	dispatchServer := dispatchserver.New(db)
-	deployServer := deployserver.New(dispatchServer, db)
+	deployServer := deployserver.New(dispatchServer, db, clusterRedirects)
 	unaryInterceptors := make([]grpc.UnaryServerInterceptor, 0)
 	streamInterceptors := make([]grpc.StreamServerInterceptor, 0)
 

pkg/grpc/deployserver/deployserver.go

@@ -20,12 +20,14 @@ type deployServer struct {
 	pb.UnimplementedDeployServer
 	dispatchServer  dispatchserver.DispatchServer
 	deploymentStore database.DeploymentStore
+	redirect        map[string]string
 }
 
-func New(dispatchServer dispatchserver.DispatchServer, deploymentStore database.DeploymentStore) pb.DeployServer {
+func New(dispatchServer dispatchserver.DispatchServer, deploymentStore database.DeploymentStore, redirect map[string]string) pb.DeployServer {
 	return &deployServer{
 		deploymentStore: deploymentStore,
 		dispatchServer:  dispatchServer,
+		redirect:        redirect,
 	}
 }
 
@@ -105,6 +107,15 @@ func (ds *deployServer) Deploy(ctx context.Context, request *pb.DeploymentReques
 	logger := log.WithFields(request.LogFields())
 	logger.Infof("Received deployment request")
 
+	for requestCluster, targetCluster := range ds.redirect {
+		logger.Infof("Checking for cluster migration redirect: %s -> %s", requestCluster, targetCluster)
+		if request.GetCluster() == requestCluster {
+			request.Cluster = targetCluster
+			logger.Infof("Redirecting deployment from %s to %s", requestCluster, targetCluster)
+			break
+		}
+	}
+
 	logger.Debugf("Writing deployment to database")
 	err = ds.addToDatabase(ctx, request)
 	if err != nil {

pkg/hookd/config/config.go

@@ -34,6 +34,7 @@ type Config struct {
 	ProvisionKey              string        `json:"provision-key"`
 	NaisAPIAddress            string        `json:"nais-api-address"`
 	NaisAPIInsecureConnection bool          `json:"nais-api-insecure-connection"`
+	ClusterMigrationRedirect  []string      `json:"cluster-migration-redirect"`
 }
 
 const (