Method innerBackup

internal/cnpi/plugin/client/backup.go:93–169

(
	ctx context.Context,
	cluster client.Object,
	backupObject client.Object,
	pluginName string,
	parameters map[string]string,
)

}

func (data *data) innerBackup(
	ctx context.Context,
	cluster client.Object,
	backupObject client.Object,
	pluginName string,
	parameters map[string]string,
) (*BackupResponse, error) {
	contextLogger := log.FromContext(ctx)

	serializedCluster, err := json.Marshal(cluster)
	if err != nil {
		return nil, fmt.Errorf("while serializing %s %s/%s to JSON: %w",
			cluster.GetObjectKind().GroupVersionKind().Kind,
			cluster.GetNamespace(), cluster.GetName(),
			err,
		)
	}

	serializedBackup, err := json.Marshal(backupObject)
	if err != nil {
		return nil, fmt.Errorf("while serializing %s %s/%s to JSON: %w",
			backupObject.GetObjectKind().GroupVersionKind().Kind,
			backupObject.GetNamespace(), backupObject.GetName(),
			err,
		)
	}

	plugin, err := data.getPlugin(pluginName)
	if err != nil {
		return nil, err
	}

	if !slices.Contains(plugin.PluginCapabilities(), identity.PluginCapability_Service_TYPE_BACKUP_SERVICE) {
		return nil, ErrPluginNotSupportBackup
	}

	if !slices.Contains(plugin.BackupCapabilities(), backup.BackupCapability_RPC_TYPE_BACKUP) {
		return nil, ErrPluginNotSupportBackupEndpoint
	}

	contextLogger = contextLogger.WithValues(
		"pluginName", pluginName,
	)

	request := backup.BackupRequest{
		ClusterDefinition: serializedCluster,
		BackupDefinition:  serializedBackup,
		Parameters:        parameters,
	}

	contextLogger.Trace(
		"Calling Backup endpoint",
		"clusterDefinition", request.ClusterDefinition,
		"parameters", parameters)

	result, err := plugin.BackupClient().Backup(ctx, &request)
	if err != nil {
		contextLogger.Error(err, "Error while calling Backup, failing")