Function joinSubCommand

internal/cmd/manager/instance/join/cmd.go:97–133

(ctx context.Context, instance *postgres.Instance, info postgres.InitInfo)

}

func joinSubCommand(ctx context.Context, instance *postgres.Instance, info postgres.InitInfo) error {
	contextLogger := log.FromContext(ctx)

	if err := info.EnsureTargetDirectoriesDoNotExist(ctx); err != nil {
		return err
	}

	client, err := management.NewControllerRuntimeClient()
	if err != nil {
		contextLogger.Error(err, "Error creating Kubernetes client")
		return err
	}

	// Download the cluster definition from the API server
	var cluster apiv1.Cluster
	if err := client.Get(ctx,
		ctrl.ObjectKey{Namespace: instance.GetNamespaceName(), Name: instance.GetClusterName()},
		&cluster,
	); err != nil {
		contextLogger.Error(err, "Error while getting cluster")
		return err
	}
	instance.SetCluster(&cluster)

	if _, err := instancecertificate.NewReconciler(client, instance).RefreshSecrets(ctx, &cluster); err != nil {
		contextLogger.Error(err, "Error while refreshing secrets")
		return err
	}

	// Run "pg_basebackup" to download the data directory from the primary
	if err := info.Join(ctx, &cluster); err != nil {
		contextLogger.Error(err, "Error joining node")
		return err
	}

	return nil
}