Help us shape the future of Go! Take the 2026 Go Developer Survey

bucket

package
v0.0.29 Latest Latest
Warning

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

Go to latest
Published: Dec 13, 2023 License: Apache-2.0 Imports: 39 Imported by: 0

Documentation

Index

Constants

This section is empty.

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

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(backendStore *backendstore.BackendStore, log 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(backendStore *backendstore.BackendStore, log 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
)

Jump to

Keyboard shortcuts

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