backendstore

package

v0.0.21 Latest Latest Go to latest Published: Oct 9, 2023 License: Apache-2.0 Imports: 4 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/linode/provider-ceph

Links

Open Source Insights

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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 ¶ added in v0.0.7

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

func (*BackendStore) GetAllActiveBackendNames ¶ added in v0.0.7

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

func (*BackendStore) GetAllBackendClients ¶ added in v0.0.5

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 ¶ added in v0.0.5

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

func (*BackendStore) GetBackendClients ¶ added in v0.0.7

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

func (*BackendStore) GetBackendHealthStatus ¶ added in v0.0.9

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

func (*BackendStore) IsBackendActive ¶ added in v0.0.5

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

func (*BackendStore) SetBackendHealthStatus ¶ added in v0.0.9

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

func (*BackendStore) ToggleBackendActiveStatus ¶ added in v0.0.5

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

type S3Client ¶ added in v0.0.12

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)
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
backendstorefakes Code generated by counterfeiter.	Code generated by counterfeiter.

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