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

bucket

package
v1.3.3 Latest Latest
Warning

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

 Go to latest Published: May 27, 2026 License: Apache-2.0 Imports: 43 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 SetupGated added in v1.2.0 

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

SetupGated registers controller setup with the gate, waiting for the required CRD.

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 WithKubeReader added in v1.2.0 

func WithKubeReader(k client.Reader) func(*Connector)

func WithLog added in v0.0.27 

func WithLog(l logr.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.LegacyProviderConfigUsageTracker) 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 logr.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 logr.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 logr.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 logr.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 ServerSideEncryptionConfigurationClient added in v1.3.3 

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

ServerSideEncryptionConfigurationClient is the client for API methods and reconciling the ServerSideEncryptionConfiguration

func NewServerSideEncryptionConfigurationClient added in v1.3.3 

func NewServerSideEncryptionConfigurationClient(b *backendstore.BackendStore, h *s3clienthandler.Handler, l logr.Logger) *ServerSideEncryptionConfigurationClient

func (*ServerSideEncryptionConfigurationClient) Handle added in v1.3.3 

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

func (*ServerSideEncryptionConfigurationClient) Observe added in v1.3.3 

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

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 logr.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
	ServerSideEncryptionConfigurationClientDisabled 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 logr.Logger) *VersioningConfigurationClient

func (*VersioningConfigurationClient) Handle added in v0.0.47 

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

func (*VersioningConfigurationClient) Observe added in v0.0.47 

func (v *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.