Documentation
¶
Index ¶
- func NewAerospikeClient(cfg *client.AerospikeConfig, cp *models.ClientPolicy, racksIDs []int, ...) (*aerospike.Client, error)
- func NewBackupWriter(ctx context.Context, params *config.BackupServiceConfig, logger *slog.Logger) (backup.Writer, error)
- func NewReader(ctx context.Context, cfg *config.ServiceConfigCommon, ...) (backup.StreamingReader, error)
- func NewRestoreReader(ctx context.Context, cfg *config.RestoreServiceConfig, logger *slog.Logger) (reader, xdrReader backup.StreamingReader, err error)
- func NewS3Client(ctx context.Context, a *models.AwsS3) (*s3.Client, error)
- func NewStateReader(ctx context.Context, cfg *config.BackupServiceConfig, logger *slog.Logger) (backup.StreamingReader, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewAerospikeClient ¶
func NewAerospikeClient( cfg *client.AerospikeConfig, cp *models.ClientPolicy, racksIDs []int, 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.BackupServiceConfig, 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 NewReader ¶ added in v1.1.0
func NewReader( ctx context.Context, cfg *config.ServiceConfigCommon, directory, inputFile, parentDirectory, directoryList string, stdBufferSize int, isXdr, skipCheck bool, logger *slog.Logger, ) (backup.StreamingReader, error)
NewReader creates and returns a reader based on the provided parameters.
func NewRestoreReader ¶
func NewRestoreReader( ctx context.Context, cfg *config.RestoreServiceConfig, logger *slog.Logger, ) (reader, xdrReader backup.StreamingReader, err error)
NewRestoreReader creates and returns a reader based on the restore mode specified in RestoreServiceConfig.
func NewS3Client ¶ added in v1.1.0
NewS3Client initializes and returns a new S3 client with the specified configuration.
func NewStateReader ¶
func NewStateReader( ctx context.Context, cfg *config.BackupServiceConfig, logger *slog.Logger, ) (backup.StreamingReader, error)
NewStateReader initialize reader for a state file.
Types ¶
This section is empty.
Source Files