Method innerRestoreWAL

internal/cnpi/plugin/client/wal.go:95–143

(
	ctx context.Context,
	cluster client.Object,
	sourceWALName string,
	destinationFileName string,
)

}

func (data *data) innerRestoreWAL(
	ctx context.Context,
	cluster client.Object,
	sourceWALName string,
	destinationFileName string,
) (bool, error) {
	var errorCollector error

	contextLogger := log.FromContext(ctx)

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

	for idx := range data.plugins {
		plugin := data.plugins[idx]

		if !slices.Contains(plugin.WALCapabilities(), wal.WALCapability_RPC_TYPE_RESTORE_WAL) {
			continue
		}

		pluginLogger := contextLogger.WithValues("pluginName", plugin.Name())
		request := wal.WALRestoreRequest{
			ClusterDefinition:   serializedCluster,
			SourceWalName:       sourceWALName,
			DestinationFileName: destinationFileName,
		}

		pluginLogger.Trace(
			"Calling RestoreWAL endpoint",
			"clusterDefinition", request.ClusterDefinition,
			"sourceWALName", sourceWALName,
			"destinationFileName", destinationFileName,
		)
		if _, err := plugin.WALClient().Restore(ctx, &request); err != nil {
			pluginLogger.Trace("WAL restore via plugin failed, trying next one", "err", err)
			errorCollector = multierr.Append(errorCollector, err)
		} else {
			return true, nil
		}
	}

	return false, errorCollector
}