bucket

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Feb 27, 2024 License: Apache-2.0 Imports: 40 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 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 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

NewLifecycleConfigurationClient creates the client for Accelerate Configuration

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 ResourceStatus added in v0.0.22 

type ResourceStatus int

ResourceStatus represents the current status of the resource. 

const (
	// Updated is returned if the resource is updated.
	Updated ResourceStatus = iota
	// 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, l logging.Logger) []SubresourceClient

NewSubresourceClients creates the array of all sub resource clients.

type UpdateRequired added in v0.0.14 

type UpdateRequired int
const (
	NeedsStatusUpdate UpdateRequired = iota
	NeedsObjectUpdate
)

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.