bucket

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Oct 17, 2024 License: Apache-2.0 Imports: 43 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	True = "true"
)

Variables

View Source 
var (
	NewNoOpService = func(_ []byte) (interface{}, error) { return &NoOpService{}, nil }
)

Functions

func Setup 

func Setup(mgr ctrl.Manager, o controller.Options, c *Connector) error

Setup adds a controller that reconciles Bucket managed resources.

func WithAutoPause added in v0.0.27 

func WithAutoPause(a *bool) func(*Connector)

func WithBackendStore added in v0.0.27 

func WithBackendStore(s *backendstore.BackendStore) func(*Connector)

func WithCreationGracePeriod added in v0.0.27 

func WithCreationGracePeriod(t time.Duration) func(*Connector)

func WithKubeClient added in v0.0.27 

func WithKubeClient(k client.Client) func(*Connector)

func WithLog added in v0.0.27 

func WithLog(l logging.Logger) func(*Connector)

func WithMinimumReplicas added in v0.0.40 

func WithMinimumReplicas(m *uint) func(*Connector)

func WithNewServiceFn added in v0.0.27 

func WithNewServiceFn(s func(creds []byte) (interface{}, error)) func(*Connector)

func WithOperationTimeout added in v0.0.27 

func WithOperationTimeout(t time.Duration) func(*Connector)

func WithPollInterval added in v0.0.27 

func WithPollInterval(t time.Duration) func(*Connector)

func WithRecreateMissingBucket added in v0.0.40 

func WithRecreateMissingBucket(a *bool) func(*Connector)

func WithS3ClientHandler added in v0.0.35 

func WithS3ClientHandler(h *s3clienthandler.Handler) func(*Connector)

func WithSubresourceClients added in v0.0.27 

func WithSubresourceClients(s []SubresourceClient) func(*Connector)

func WithUsage added in v0.0.27 

func WithUsage(u resource.Tracker) func(*Connector)

Types

type ACLClient added in v0.0.44 

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

ACLClient is the client for API methods and reconciling the ACL

func NewACLClient added in v0.0.44 

func NewACLClient(b *backendstore.BackendStore, h *s3clienthandler.Handler, l logging.Logger) *ACLClient

NewACLClient creates the client for ACL

func (*ACLClient) Handle added in v0.0.44 

func (l *ACLClient) Handle(ctx context.Context, b *v1alpha1.Bucket, backendName string, bb *bucketBackends) error

func (*ACLClient) Observe added in v0.0.44 

func (l *ACLClient) Observe(ctx context.Context, bucket *v1alpha1.Bucket, backendNames []string) (ResourceStatus, error)

type BucketValidator added in v0.0.17 

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

func NewBucketValidator added in v0.0.17 

func NewBucketValidator(b *backendstore.BackendStore) *BucketValidator

func (*BucketValidator) ValidateCreate added in v0.0.17 

func (b *BucketValidator) ValidateCreate(ctx context.Context, obj runtime.Object) (admission.Warnings, error)

func (*BucketValidator) ValidateDelete added in v0.0.17 

func (b *BucketValidator) ValidateDelete(ctx context.Context, obj runtime.Object) (admission.Warnings, error)

func (*BucketValidator) ValidateUpdate added in v0.0.17 

func (b *BucketValidator) ValidateUpdate(ctx context.Context, oldObj, newObj runtime.Object) (admission.Warnings, error)

type Connector added in v0.0.27 

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

A Connector is expected to produce an ExternalClient when its Connect method is called.

func NewConnector added in v0.0.27 

func NewConnector(options ...func(*Connector)) *Connector

func (*Connector) Connect added in v0.0.27 

func (c *Connector) Connect(ctx context.Context, mg resource.Managed) (managed.ExternalClient, error)

type LifecycleConfigurationClient added in v0.0.22 

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

LifecycleConfigurationClient is the client for API methods and reconciling the LifecycleConfiguration

func NewLifecycleConfigurationClient added in v0.0.22 

func NewLifecycleConfigurationClient(b *backendstore.BackendStore, h *s3clienthandler.Handler, l logging.Logger) *LifecycleConfigurationClient

func (*LifecycleConfigurationClient) Handle added in v0.0.22 

func (l *LifecycleConfigurationClient) Handle(ctx context.Context, b *v1alpha1.Bucket, backendName string, bb *bucketBackends) error

func (*LifecycleConfigurationClient) Observe added in v0.0.22 

func (l *LifecycleConfigurationClient) Observe(ctx context.Context, bucket *v1alpha1.Bucket, backendNames []string) (ResourceStatus, error)

type NoOpService 

type NoOpService struct{}

A NoOpService does nothing.

type ObjectLockConfigurationClient added in v0.0.48 

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

ObjectLockConfigurationClient is the client for API methods and reconciling the ObjectLockConfiguration

func NewObjectLockConfigurationClient added in v0.0.48 

func NewObjectLockConfigurationClient(b *backendstore.BackendStore, h *s3clienthandler.Handler, l logging.Logger) *ObjectLockConfigurationClient

func (*ObjectLockConfigurationClient) Handle added in v0.0.48 

func (l *ObjectLockConfigurationClient) Handle(ctx context.Context, b *v1alpha1.Bucket, backendName string, bb *bucketBackends) error

func (*ObjectLockConfigurationClient) Observe added in v0.0.48 

func (l *ObjectLockConfigurationClient) Observe(ctx context.Context, bucket *v1alpha1.Bucket, backendNames []string) (ResourceStatus, error)

type PolicyClient added in v0.0.45 

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

PolicyClient is the client for API methods and reconciling a BucketPolicy

func NewPolicyClient added in v0.0.45 

func NewPolicyClient(b *backendstore.BackendStore, h *s3clienthandler.Handler, l logging.Logger) *PolicyClient

func (*PolicyClient) Handle added in v0.0.45 

func (p *PolicyClient) Handle(ctx context.Context, b *v1alpha1.Bucket, backendName string, bb *bucketBackends) error

func (*PolicyClient) Observe added in v0.0.45 

func (p *PolicyClient) Observe(ctx context.Context, bucket *v1alpha1.Bucket, backendNames []string) (ResourceStatus, error)

type ResourceStatus added in v0.0.22 

type ResourceStatus int

ResourceStatus represents the current status of the resource. 

const (
	// NoAction is returned if the resource requires no action.
	NoAction ResourceStatus = iota
	// Updated is returned if the resource is updated.
	Updated
	// NeedsUpdate is returned if the resource required updating.
	NeedsUpdate
	// NeedsDeletion is returned if the resource needs to be deleted.
	NeedsDeletion
)

type SubresourceClient added in v0.0.22 

type SubresourceClient interface {
	Observe(ctx context.Context, bucket *v1alpha1.Bucket, backendNames []string) (ResourceStatus, error)
	Handle(ctx context.Context, bucket *v1alpha1.Bucket, backendName string, bb *bucketBackends) error
}

SubresourceClient is the interface all Bucket sub-resources must conform to.

func NewSubresourceClients added in v0.0.22 

func NewSubresourceClients(b *backendstore.BackendStore, h *s3clienthandler.Handler, config SubresourceClientConfig, l logging.Logger) []SubresourceClient

NewSubresourceClients creates the array of all sub resource clients.

type SubresourceClientConfig added in v1.0.0 

type SubresourceClientConfig struct {
	LifecycleConfigurationClientDisabled  bool
	ACLClientDisabled                     bool
	PolicyClientDisabled                  bool
	VersioningConfigurationClientDisabled bool
	ObjectLockConfigurationClientDisabled bool
}

type UpdateRequired added in v0.0.14 

type UpdateRequired int
const (
	NeedsStatusUpdate UpdateRequired = iota
	NeedsObjectUpdate
)

type VersioningConfigurationClient added in v0.0.47 

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

VersioningConfigurationClient is the client for API methods and reconciling the VersioningConfiguration

func NewVersioningConfigurationClient added in v0.0.47 

func NewVersioningConfigurationClient(b *backendstore.BackendStore, h *s3clienthandler.Handler, l logging.Logger) *VersioningConfigurationClient

func (*VersioningConfigurationClient) Handle added in v0.0.47 

func (l *VersioningConfigurationClient) Handle(ctx context.Context, b *v1alpha1.Bucket, backendName string, bb *bucketBackends) error

func (*VersioningConfigurationClient) Observe added in v0.0.47 

func (l *VersioningConfigurationClient) Observe(ctx context.Context, bucket *v1alpha1.Bucket, backendNames []string) (ResourceStatus, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.