s3

package
v0.7.1 Latest Latest
Warning

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

Go to latest
Published: Feb 9, 2024 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewS3BackupHandler

func NewS3BackupHandler(conf *S3Config, store es.EventStore, retention int) backup.BackupHandler

Types

type S3BackupHandler

type S3BackupHandler struct {
	// contains filtered or unexported fields
}

func (*S3BackupHandler) RunBackup

func (b *S3BackupHandler) RunBackup(ctx context.Context) (*backup.BackupResult, error)

func (*S3BackupHandler) RunPurge

func (b *S3BackupHandler) RunPurge(ctx context.Context) (*backup.PurgeResult, error)

func (*S3BackupHandler) RunRestore

func (b *S3BackupHandler) RunRestore(ctx context.Context, identifier string) (*backup.RestoreResult, error)

type S3Config

type S3Config struct {
	Endpoint   string `yaml:"endpoint"`
	Bucket     string `yaml:"bucket"`
	Region     string `yaml:"region"`
	DisableSSL bool   `yaml:"disableSSL"`
}

func NewS3ConfigFromFile

func NewS3ConfigFromFile(path string) (*S3Config, error)

NewS3ConfigFromFile creates a new S3 config from a given yaml file

type TestEnv

type TestEnv struct {
	*test.TestEnv

	Endpoint string
	Bucket   string
	// contains filtered or unexported fields
}

func NewTestEnvWithParent

func NewTestEnvWithParent(testEnv *test.TestEnv) (*TestEnv, error)

func (*TestEnv) CreateBucket

func (t *TestEnv) CreateBucket(endpoint, accessKeyID, secretAccessKey string) error

func (*TestEnv) WaitForS3

func (t *TestEnv) WaitForS3(endpoint, accessKeyID, secretAccessKey string) error

Jump to

Keyboard shortcuts

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