Method innerArchiveWAL

internal/cnpi/plugin/client/wal.go:42–83

(
	ctx context.Context,
	cluster client.Object,
	sourceFileName string,
)

}

func (data *data) innerArchiveWAL(
	ctx context.Context,
	cluster client.Object,
	sourceFileName string,
) error {
	contextLogger := log.FromContext(ctx)

	serializedCluster, err := json.Marshal(cluster)
	if err != nil {
		return 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_ARCHIVE_WAL) {
			continue
		}

		pluginLogger := contextLogger.WithValues("pluginName", plugin.Name())
		request := wal.WALArchiveRequest{
			ClusterDefinition: serializedCluster,
			SourceFileName:    sourceFileName,
		}

		pluginLogger.Trace(
			"Calling ArchiveWAL endpoint",
			"clusterDefinition", request.ClusterDefinition,
			"sourceFile", request.SourceFileName)
		_, err := plugin.WALClient().Archive(ctx, &request)
		if err != nil {
			pluginLogger.Error(err, "Error while calling ArchiveWAL, failing")
			return err
		}
	}

	return nil
}

func (data *data) RestoreWAL(
	ctx context.Context,