storage

package
v0.5.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 8, 2025 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewAerospikeClient

func NewAerospikeClient(
	cfg *client.AerospikeConfig,
	cp *models.ClientPolicy,
	racks string,
	warmUp int,
	logger *slog.Logger,
) (*aerospike.Client, error)

NewAerospikeClient initializes and returns a new Aerospike client with the specified configuration and settings. It validates input parameters, applies client policies, and optionally warms up the client for better performance. Returns an Aerospike client instance or an error if initialization fails.

func NewBackupWriter

func NewBackupWriter(
	ctx context.Context,
	params *config.BackupParams,
	sa *backup.SecretAgentConfig,
	logger *slog.Logger,
) (backup.Writer, error)

NewBackupWriter initializes and returns a backup.Writer based on the provided parameters or cleans up artifacts if required.

func NewRestoreReader

func NewRestoreReader(
	ctx context.Context,
	params *config.RestoreParams,
	sa *backup.SecretAgentConfig,
	logger *slog.Logger,
) (reader, xdrReader backup.StreamingReader, err error)

NewRestoreReader creates and returns a reader based on the restore mode specified in RestoreParams.

func NewStateReader

func NewStateReader(
	ctx context.Context,
	params *config.BackupParams,
	sa *backup.SecretAgentConfig,
	logger *slog.Logger,
) (backup.StreamingReader, error)

NewStateReader initialize reader for a state file.

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL