bucket

Documentation

Index

• Variables
• func LifecycleConfigurationNotFound(err error) bool
• func Setup(mgr ctrl.Manager, o controller.Options, s *backendstore.BackendStore, ...) error
• type BucketValidator
  • func NewBucketValidator(b *backendstore.BackendStore) *BucketValidator
  • func (b *BucketValidator) ValidateCreate(ctx context.Context, obj runtime.Object) (admission.Warnings, error)
  • func (b *BucketValidator) ValidateDelete(ctx context.Context, obj runtime.Object) (admission.Warnings, error)
  • func (b *BucketValidator) ValidateUpdate(ctx context.Context, oldObj, newObj runtime.Object) (admission.Warnings, error)
• type LifecycleConfigurationClient
  • func NewLifecycleConfigurationClient(backendStore *backendstore.BackendStore, log logging.Logger) *LifecycleConfigurationClient
  • func (l *LifecycleConfigurationClient) Handle(ctx context.Context, b *v1alpha1.Bucket, backendName string, ...) error
  • func (l *LifecycleConfigurationClient) Observe(ctx context.Context, bucket *v1alpha1.Bucket, backendNames []string) (ResourceStatus, error)
• type NoOpService
• type ResourceStatus
• type SubresourceClient
  • func NewSubresourceClients(backendStore *backendstore.BackendStore, log logging.Logger) []SubresourceClient
• type UpdateRequired

Variables

var LifecycleNotFoundErrCode = "NoSuchLifecycleConfiguration"

LifecycleNotFoundErrCode is the error code sent by AWS when the lifecycle config does not exist

Functions

func LifecycleConfigurationNotFound

func LifecycleConfigurationNotFound(err error) bool

LifecycleConfigurationNotFound is parses the aws Error and validates if the lifecycle configuration does not exist

func Setup

func Setup(mgr ctrl.Manager, o controller.Options, s *backendstore.BackendStore, autoPauseBucket bool, pollInterval, operationTimeout, creationGracePeriod time.Duration) error

Setup adds a controller that reconciles Bucket managed resources.

Types

type BucketValidator

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

func NewBucketValidator

func NewBucketValidator(b *backendstore.BackendStore) *BucketValidator

func (*BucketValidator) ValidateCreate

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

func (*BucketValidator) ValidateDelete

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

func (*BucketValidator) ValidateUpdate

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

type LifecycleConfigurationClient

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

LifecycleConfigurationClient is the client for API methods and reconciling the LifecycleConfiguration

func NewLifecycleConfigurationClient

func NewLifecycleConfigurationClient(backendStore *backendstore.BackendStore, log logging.Logger) *LifecycleConfigurationClient

NewLifecycleConfigurationClient creates the client for Accelerate Configuration

func (*LifecycleConfigurationClient) Handle

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

func (*LifecycleConfigurationClient) Observe

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

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

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

func NewSubresourceClients(backendStore *backendstore.BackendStore, log logging.Logger) []SubresourceClient

NewSubresourceClients creates the array of all sub resource clients.

type UpdateRequired

type UpdateRequired int

const (
	NeedsStatusUpdate UpdateRequired = iota
	NeedsObjectUpdate
)