s3

Documentation

Index

• func NewS3BackupHandler(conf *S3Config, store es.EventStore, retention int) backup.BackupHandler
• type S3BackupHandler
  • func (b *S3BackupHandler) RunBackup(ctx context.Context) (*backup.BackupResult, error)
  • func (b *S3BackupHandler) RunPurge(ctx context.Context) (*backup.PurgeResult, error)
  • func (b *S3BackupHandler) RunRestore(ctx context.Context, identifier string) (*backup.RestoreResult, error)
• type S3Config
  • func NewS3ConfigFromFile(path string) (*S3Config, error)
• type TestEnv
  • func NewTestEnvWithParent(testEnv *test.TestEnv) (*TestEnv, error)
  • func (t *TestEnv) CreateBucket(endpoint, accessKeyID, secretAccessKey string) error
  • func (t *TestEnv) WaitForS3(endpoint, accessKeyID, secretAccessKey string) error

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