backendstore

Documentation

Index

• type BackendStore
  • func NewBackendStore() *BackendStore
  • func (b *BackendStore) AddOrUpdateBackend(backendName string, backendClient S3Client, active bool, ...)
  • func (b *BackendStore) BackendsAreStored() bool
  • func (b *BackendStore) DeleteBackend(backendName string)
  • func (b *BackendStore) GetActiveBackends(beNames []string) s3Backends
  • func (b *BackendStore) GetAllActiveBackendNames() []string
  • func (b *BackendStore) GetAllBackendClients() []S3Client
  • func (b *BackendStore) GetAllBackends() s3Backends
  • func (b *BackendStore) GetBackend(backendName string) *backend
  • func (b *BackendStore) GetBackendClient(backendName string) S3Client
  • func (b *BackendStore) GetBackendClients(beNames []string) map[string]S3Client
  • func (b *BackendStore) GetBackendHealthStatus(backendName string) v1alpha1.HealthStatus
  • func (b *BackendStore) IsBackendActive(backendName string) bool
  • func (b *BackendStore) SetBackendHealthStatus(backendName string, health v1alpha1.HealthStatus)
  • func (b *BackendStore) ToggleBackendActiveStatus(backendName string, active bool)
• type S3Client

Types

type BackendStore

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

BackendStore stores the active s3 backends.

func NewBackendStore

func NewBackendStore() *BackendStore

func (*BackendStore) AddOrUpdateBackend

func (b *BackendStore) AddOrUpdateBackend(backendName string, backendClient S3Client, active bool, health v1alpha1.HealthStatus)

func (*BackendStore) BackendsAreStored

func (b *BackendStore) BackendsAreStored() bool

func (*BackendStore) DeleteBackend

func (b *BackendStore) DeleteBackend(backendName string)

func (*BackendStore) GetActiveBackends

func (b *BackendStore) GetActiveBackends(beNames []string) s3Backends

func (*BackendStore) GetAllActiveBackendNames

func (b *BackendStore) GetAllActiveBackendNames() []string

func (*BackendStore) GetAllBackendClients

func (b *BackendStore) GetAllBackendClients() []S3Client

func (*BackendStore) GetAllBackends

func (b *BackendStore) GetAllBackends() s3Backends

func (*BackendStore) GetBackend

func (b *BackendStore) GetBackend(backendName string) *backend

func (*BackendStore) GetBackendClient

func (b *BackendStore) GetBackendClient(backendName string) S3Client

func (*BackendStore) GetBackendClients

func (b *BackendStore) GetBackendClients(beNames []string) map[string]S3Client

func (*BackendStore) GetBackendHealthStatus

func (b *BackendStore) GetBackendHealthStatus(backendName string) v1alpha1.HealthStatus

func (*BackendStore) IsBackendActive

func (b *BackendStore) IsBackendActive(backendName string) bool

func (*BackendStore) SetBackendHealthStatus

func (b *BackendStore) SetBackendHealthStatus(backendName string, health v1alpha1.HealthStatus)

func (*BackendStore) ToggleBackendActiveStatus

func (b *BackendStore) ToggleBackendActiveStatus(backendName string, active bool)

type S3Client

type S3Client interface {
	HeadBucket(context.Context, *s3.HeadBucketInput, ...func(*s3.Options)) (*s3.HeadBucketOutput, error)
	CreateBucket(context.Context, *s3.CreateBucketInput, ...func(*s3.Options)) (*s3.CreateBucketOutput, error)
	PutBucketAcl(context.Context, *s3.PutBucketAclInput, ...func(*s3.Options)) (*s3.PutBucketAclOutput, error)
	DeleteBucket(context.Context, *s3.DeleteBucketInput, ...func(*s3.Options)) (*s3.DeleteBucketOutput, error)
	GetObject(context.Context, *s3.GetObjectInput, ...func(*s3.Options)) (*s3.GetObjectOutput, error)
	PutObject(context.Context, *s3.PutObjectInput, ...func(*s3.Options)) (*s3.PutObjectOutput, error)
	DeleteObject(context.Context, *s3.DeleteObjectInput, ...func(*s3.Options)) (*s3.DeleteObjectOutput, error)
	ListObjectsV2(context.Context, *s3.ListObjectsV2Input, ...func(*s3.Options)) (*s3.ListObjectsV2Output, error)
	ListObjectVersions(context.Context, *s3.ListObjectVersionsInput, ...func(*s3.Options)) (*s3.ListObjectVersionsOutput, error)
	PutBucketLifecycleConfiguration(context.Context, *s3.PutBucketLifecycleConfigurationInput, ...func(*s3.Options)) (*s3.PutBucketLifecycleConfigurationOutput, error)
	GetBucketLifecycleConfiguration(context.Context, *s3.GetBucketLifecycleConfigurationInput, ...func(*s3.Options)) (*s3.GetBucketLifecycleConfigurationOutput, error)
	DeleteBucketLifecycle(context.Context, *s3.DeleteBucketLifecycleInput, ...func(*s3.Options)) (*s3.DeleteBucketLifecycleOutput, error)
}