s3

Documentation

Index

• Constants
• func NewS3BackupProvider(config *backup.StorageConfig) backup.Storage
• type ClientS3Wrapper
  • func NewClientFromSecret(kubecli kubernetes.Interface, namespace, endpoint, awsSecret string, ...) (w *ClientS3Wrapper, err error)
  • func (w *ClientS3Wrapper) Close()
• type StorageS3
  • func (c *StorageS3) List(cluster *v1alpha2.EtcdCluster) (interface{}, error)
  • func (c *StorageS3) Stat(objects interface{}) (int, error)

Constants

const (
	ProviderName = string(v1beta2.BackupStorageTypeS3)
)

Functions

func NewS3BackupProvider

func NewS3BackupProvider(config *backup.StorageConfig) backup.Storage

Types

type ClientS3Wrapper

type ClientS3Wrapper struct {
	S3 *awsS3.S3
	// contains filtered or unexported fields
}

ClientS3Wrapper is a wrapper for S3 client that provides cleanup functionality.

func NewClientFromSecret

func NewClientFromSecret(kubecli kubernetes.Interface, namespace, endpoint, awsSecret string, forcePathStyle bool) (w *ClientS3Wrapper, err error)

NewClientFromSecret returns a S3 client based on given k8s secret containing aws credentials.

func (*ClientS3Wrapper) Close

func (w *ClientS3Wrapper) Close()

Close cleans up all intermediate resources for creating S3 client.

type StorageS3

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

func (*StorageS3) List

func (c *StorageS3) List(cluster *v1alpha2.EtcdCluster) (interface{}, error)

func (*StorageS3) Stat

func (c *StorageS3) Stat(objects interface{}) (int, error)