bucket

package
v0.54.2 Latest Latest
Warning

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

 Go to latest Published: Jul 18, 2025 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GenerateAWSLogging 

func GenerateAWSLogging(local *v1beta1.LoggingConfiguration) *types.LoggingEnabled

GenerateAWSLogging creates an S3 logging enabled struct from the local logging configuration

func GenerateAWSObjectLockConfiguration added in v0.53.0 

func GenerateAWSObjectLockConfiguration(in *v1beta1.BucketParameters) *types.ObjectLockConfiguration

GenerateAWSObjectLockConfiguration generates the AWS S3 Object Lock Configuration

func GenerateAccelerateConfigurationInput 

func GenerateAccelerateConfigurationInput(name string, config *v1beta1.AccelerateConfiguration) *awss3.PutBucketAccelerateConfigurationInput

GenerateAccelerateConfigurationInput creates the input for the AccelerateConfiguration request for the S3 Client

func GenerateCORSRule 

func GenerateCORSRule(config []types.CORSRule) []v1beta1.CORSRule

GenerateCORSRule creates the cors rule from a GetBucketCORS request from the S3 Client

func GenerateConfiguration 

func GenerateConfiguration(config *v1beta1.NotificationConfiguration) *types.NotificationConfiguration

GenerateConfiguration creates the external aws NotificationConfiguration from the local representation

func GenerateLambdaConfiguration 

func GenerateLambdaConfiguration(config *v1beta1.NotificationConfiguration) []types.LambdaFunctionConfiguration

GenerateLambdaConfiguration creates []awss3.LambdaFunctionConfiguration from the local NotificationConfiguration

func GenerateLifecycleConfiguration 

func GenerateLifecycleConfiguration(name string, config *v1beta1.BucketLifecycleConfiguration) *awss3.PutBucketLifecycleConfigurationInput

GenerateLifecycleConfiguration creates the PutBucketLifecycleConfigurationInput for the AWS SDK

func GenerateLifecycleRules 

func GenerateLifecycleRules(in []v1beta1.LifecycleRule) []types.LifecycleRule

GenerateLifecycleRules creates the list of LifecycleRules for the AWS SDK

func GenerateLocalBucketEncryption 

func GenerateLocalBucketEncryption(config *types.ServerSideEncryptionConfiguration) []v1beta1.ServerSideEncryptionRule

GenerateLocalBucketEncryption creates the local ServerSideEncryptionConfiguration from the S3 Client request

func GenerateLocalTagging 

func GenerateLocalTagging(config []types.Tag) *v1beta1.Tagging

GenerateLocalTagging creates the v1beta1.Tagging from the AWS SDK tagging

func GenerateNotificationConfigurationInput 

func GenerateNotificationConfigurationInput(name string, config *v1beta1.NotificationConfiguration) *awss3.PutBucketNotificationConfigurationInput

GenerateNotificationConfigurationInput creates the input for the LifecycleConfiguration request for the S3 Client

func GeneratePutBucketCorsInput 

func GeneratePutBucketCorsInput(name string, config *v1beta1.CORSConfiguration) *awss3.PutBucketCorsInput

GeneratePutBucketCorsInput creates the input for the PutBucketCors request for the S3 Client

func GeneratePutBucketEncryptionInput 

func GeneratePutBucketEncryptionInput(name string, config *v1beta1.ServerSideEncryptionConfiguration) *awss3.PutBucketEncryptionInput

GeneratePutBucketEncryptionInput creates the input for the PutBucketEncryption request for the S3 Client

func GeneratePutBucketLoggingInput 

func GeneratePutBucketLoggingInput(name string, config *v1beta1.LoggingConfiguration) *awss3.PutBucketLoggingInput

GeneratePutBucketLoggingInput creates the input for the PutBucketLogging request for the S3 Client

func GeneratePutBucketPaymentInput 

func GeneratePutBucketPaymentInput(name string, config *v1beta1.PaymentConfiguration) *awss3.PutBucketRequestPaymentInput

GeneratePutBucketPaymentInput creates the input for the BucketRequestPayment request for the S3 Client

func GeneratePutBucketReplicationInput 

func GeneratePutBucketReplicationInput(name string, config *v1beta1.ReplicationConfiguration) *awss3.PutBucketReplicationInput

GeneratePutBucketReplicationInput creates the input for the PutBucketReplication request for the S3 Client

func GeneratePutBucketTagging 

func GeneratePutBucketTagging(name string, config *v1beta1.Tagging) *awss3.PutBucketTaggingInput

GeneratePutBucketTagging creates the PutBucketTaggingInput for the aws SDK

func GeneratePutBucketVersioningInput 

func GeneratePutBucketVersioningInput(name string, config *v1beta1.VersioningConfiguration) *awss3.PutBucketVersioningInput

GeneratePutBucketVersioningInput creates the input for the PutBucketVersioning request for the S3 Client

func GeneratePutBucketWebsiteInput 

func GeneratePutBucketWebsiteInput(name string, config *v1beta1.WebsiteConfiguration) *awss3.PutBucketWebsiteInput

GeneratePutBucketWebsiteInput creates the input for the PutBucketWebsite request for the S3 Client

func GenerateQueueConfigurations 

func GenerateQueueConfigurations(config *v1beta1.NotificationConfiguration) []types.QueueConfiguration

GenerateQueueConfigurations creates []awss3.QueueConfiguration from the local NotificationConfiguration

func GenerateReplicationConfiguration 

func GenerateReplicationConfiguration(config *v1beta1.ReplicationConfiguration) *types.ReplicationConfiguration

GenerateReplicationConfiguration is responsible for creating the Replication Configuration for requests.

func GenerateTagging 

func GenerateTagging(config *v1beta1.Tagging) *types.Tagging

GenerateTagging creates the awss3.Tagging for the AWS SDK

func GenerateTopicConfigurations 

func GenerateTopicConfigurations(config *v1beta1.NotificationConfiguration) []types.TopicConfiguration

GenerateTopicConfigurations creates []awss3.TopicConfiguration from the local NotificationConfiguration

func GenerateWebsiteConfiguration 

func GenerateWebsiteConfiguration(config *v1beta1.WebsiteConfiguration) *types.WebsiteConfiguration

GenerateWebsiteConfiguration is responsible for creating the Website Configuration for requests.

func LateInitializeEvents 

func LateInitializeEvents(local []string, external []types.Event) []string

LateInitializeEvents initializes the external []awss3.Event to a local []string

func LateInitializeFilter 

func LateInitializeFilter(local *v1beta1.NotificationConfigurationFilter, external *types.NotificationConfigurationFilter) *v1beta1.NotificationConfigurationFilter

LateInitializeFilter initializes the external awss3.NotificationConfigurationFilter to a local v1beta.NotificationConfigurationFilter

func LateInitializeLambda 

func LateInitializeLambda(external []types.LambdaFunctionConfiguration, local []v1beta1.LambdaFunctionConfiguration) []v1beta1.LambdaFunctionConfiguration

LateInitializeLambda initializes the external awss3.LambdaFunctionConfiguration to a local v1beta.LambdaFunctionConfiguration

func LateInitializeQueue 

func LateInitializeQueue(external []types.QueueConfiguration, local []v1beta1.QueueConfiguration) []v1beta1.QueueConfiguration

LateInitializeQueue initializes the external awss3.QueueConfiguration to a local v1beta.QueueConfiguration

func LateInitializeTopic 

func LateInitializeTopic(external []types.TopicConfiguration, local []v1beta1.TopicConfiguration) []v1beta1.TopicConfiguration

LateInitializeTopic initializes the external awss3.TopicConfiguration to a local v1beta.TopicConfiguration

func SetupBucket added in v0.43.0 

func SetupBucket(mgr ctrl.Manager, o controller.Options) error

SetupBucket adds a controller that reconciles Buckets.

Types

type AccelerateConfigurationClient 

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

AccelerateConfigurationClient is the client for API methods and reconciling the AccelerateConfiguration

func NewAccelerateConfigurationClient 

func NewAccelerateConfigurationClient(client s3.BucketClient) *AccelerateConfigurationClient

NewAccelerateConfigurationClient creates the client for Accelerate Configuration

func (*AccelerateConfigurationClient) CreateOrUpdate 

func (in *AccelerateConfigurationClient) CreateOrUpdate(ctx context.Context, bucket *v1beta1.Bucket) error

CreateOrUpdate sends a request to have resource created on AWS

func (*AccelerateConfigurationClient) Delete 

func (*AccelerateConfigurationClient) Delete(_ context.Context, _ *v1beta1.Bucket) error

Delete does not do anything since AccelerateConfiguration doesn't have Delete call.

func (*AccelerateConfigurationClient) LateInitialize 

func (in *AccelerateConfigurationClient) LateInitialize(ctx context.Context, bucket *v1beta1.Bucket) error

LateInitialize is responsible for initializing the resource based on the external value

func (*AccelerateConfigurationClient) Observe 

func (in *AccelerateConfigurationClient) Observe(ctx context.Context, bucket *v1beta1.Bucket) (ResourceStatus, error)

Observe checks if the resource exists and if it matches the local configuration

func (*AccelerateConfigurationClient) SubresourceExists 

func (in *AccelerateConfigurationClient) SubresourceExists(bucket *v1beta1.Bucket) bool

SubresourceExists checks if the subresource this controller manages currently exists

type CORSConfigurationClient 

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

CORSConfigurationClient is the client for API methods and reconciling the CORSConfiguration

func NewCORSConfigurationClient 

func NewCORSConfigurationClient(client s3.BucketClient) *CORSConfigurationClient

NewCORSConfigurationClient creates the client for CORS Configuration

func (*CORSConfigurationClient) CreateOrUpdate 

func (in *CORSConfigurationClient) CreateOrUpdate(ctx context.Context, bucket *v1beta1.Bucket) error

CreateOrUpdate sends a request to have resource created on AWS

func (*CORSConfigurationClient) Delete 

func (in *CORSConfigurationClient) Delete(ctx context.Context, bucket *v1beta1.Bucket) error

Delete creates the request to delete the resource on AWS or set it to the default value.

func (*CORSConfigurationClient) LateInitialize 

func (in *CORSConfigurationClient) LateInitialize(ctx context.Context, bucket *v1beta1.Bucket) error

LateInitialize does nothing because CORSConfiguration might have been deleted by the user.

func (*CORSConfigurationClient) Observe 

func (in *CORSConfigurationClient) Observe(ctx context.Context, bucket *v1beta1.Bucket) (ResourceStatus, error)

Observe checks if the resource exists and if it matches the local configuration

func (*CORSConfigurationClient) SubresourceExists 

func (in *CORSConfigurationClient) SubresourceExists(bucket *v1beta1.Bucket) bool

SubresourceExists checks if the subresource this controller manages currently exists

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(client s3.BucketClient) *LifecycleConfigurationClient

NewLifecycleConfigurationClient creates the client for Accelerate Configuration

func (*LifecycleConfigurationClient) CreateOrUpdate 

func (in *LifecycleConfigurationClient) CreateOrUpdate(ctx context.Context, bucket *v1beta1.Bucket) error

CreateOrUpdate sends a request to have resource created on AWS

func (*LifecycleConfigurationClient) Delete 

func (in *LifecycleConfigurationClient) Delete(ctx context.Context, bucket *v1beta1.Bucket) error

Delete creates the request to delete the resource on AWS or set it to the default value.

func (*LifecycleConfigurationClient) LateInitialize 

func (in *LifecycleConfigurationClient) LateInitialize(ctx context.Context, bucket *v1beta1.Bucket) error

LateInitialize does nothing because LifecycleConfiguration might have been be deleted by the user.

func (*LifecycleConfigurationClient) Observe 

func (in *LifecycleConfigurationClient) Observe(ctx context.Context, bucket *v1beta1.Bucket) (ResourceStatus, error)

Observe checks if the resource exists and if it matches the local configuration

func (*LifecycleConfigurationClient) SubresourceExists 

func (in *LifecycleConfigurationClient) SubresourceExists(bucket *v1beta1.Bucket) bool

SubresourceExists checks if the subresource this controller manages currently exists

type LoggingConfigurationClient 

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

LoggingConfigurationClient is the client for API methods and reconciling the LoggingConfiguration

func NewLoggingConfigurationClient 

func NewLoggingConfigurationClient(client s3.BucketClient) *LoggingConfigurationClient

NewLoggingConfigurationClient creates the client for Logging Configuration

func (*LoggingConfigurationClient) CreateOrUpdate 

func (in *LoggingConfigurationClient) CreateOrUpdate(ctx context.Context, bucket *v1beta1.Bucket) error

CreateOrUpdate sends a request to have resource created on AWS

func (*LoggingConfigurationClient) Delete 

func (*LoggingConfigurationClient) Delete(_ context.Context, _ *v1beta1.Bucket) error

Delete does nothing because there is no deletion call for logging config.

func (*LoggingConfigurationClient) LateInitialize 

func (in *LoggingConfigurationClient) LateInitialize(ctx context.Context, bucket *v1beta1.Bucket) error

LateInitialize is not needed because loggingConfiguration is not something which is created be default it means if it is not set in the desired state, but it exists on aws side it should be deleted(by CreateOrUpdate), not late initialized

func (*LoggingConfigurationClient) Observe 

func (in *LoggingConfigurationClient) Observe(ctx context.Context, bucket *v1beta1.Bucket) (ResourceStatus, error)

Observe checks if the resource exists and if it matches the local configuration

func (*LoggingConfigurationClient) SubresourceExists 

func (in *LoggingConfigurationClient) SubresourceExists(bucket *v1beta1.Bucket) bool

SubresourceExists checks if the subresource this controller manages currently exists

type NotificationConfigurationClient 

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

NotificationConfigurationClient is the client for API methods and reconciling the LifecycleConfiguration

func NewNotificationConfigurationClient 

func NewNotificationConfigurationClient(client s3.BucketClient) *NotificationConfigurationClient

NewNotificationConfigurationClient creates the client for Accelerate Configuration

func (*NotificationConfigurationClient) CreateOrUpdate 

func (in *NotificationConfigurationClient) CreateOrUpdate(ctx context.Context, bucket *v1beta1.Bucket) error

CreateOrUpdate sends a request to have resource created on AWS

func (*NotificationConfigurationClient) Delete 

func (in *NotificationConfigurationClient) Delete(ctx context.Context, bucket *v1beta1.Bucket) error

Delete resets the buckets notification configuration to empty.

func (*NotificationConfigurationClient) LateInitialize 

func (in *NotificationConfigurationClient) LateInitialize(ctx context.Context, bucket *v1beta1.Bucket) error

LateInitialize is responsible for initializing the resource based on the external value

func (*NotificationConfigurationClient) Observe 

func (in *NotificationConfigurationClient) Observe(ctx context.Context, bucket *v1beta1.Bucket) (ResourceStatus, error)

Observe checks if the resource exists and if it matches the local configuration

func (*NotificationConfigurationClient) SubresourceExists 

func (in *NotificationConfigurationClient) SubresourceExists(bucket *v1beta1.Bucket) bool

SubresourceExists checks if the subresource this controller manages currently exists

type ObjectLockConfigurationClient added in v0.53.0 

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

ObjectLockConfigurationClient is the client for API methods and reconciling the ObjectLockConfiguration

func NewObjectLockConfigurationClient added in v0.53.0 

func NewObjectLockConfigurationClient(client s3.BucketClient) *ObjectLockConfigurationClient

NewObjectLockConfigurationClient creates the client for Object Lock Configuration

func (*ObjectLockConfigurationClient) CreateOrUpdate added in v0.53.0 

func (in *ObjectLockConfigurationClient) CreateOrUpdate(ctx context.Context, cr *v1beta1.Bucket) error

CreateOrUpdate updates or creates the Object Lock configuration on AWS side

func (*ObjectLockConfigurationClient) Delete added in v0.53.0 

func (in *ObjectLockConfigurationClient) Delete(_ context.Context, _ *v1beta1.Bucket) error

Delete does nothing because after you enable Object Lock for a bucket, you can't disable it anymore

func (*ObjectLockConfigurationClient) LateInitialize added in v0.53.0 

func (in *ObjectLockConfigurationClient) LateInitialize(_ context.Context, _ *v1beta1.Bucket) error

LateInitialize is not needed, because if something is not specified in the current state, it should be deleted on aws side

func (*ObjectLockConfigurationClient) Observe added in v0.53.0 

func (in *ObjectLockConfigurationClient) Observe(ctx context.Context, cr *v1beta1.Bucket) (ResourceStatus, error)

Observe checks if the resource exists and if it matches the local configuration

func (*ObjectLockConfigurationClient) SubresourceExists added in v0.53.0 

func (in *ObjectLockConfigurationClient) SubresourceExists(bucket *v1beta1.Bucket) bool

SubresourceExists checks if the subresource exists

type PolicyClient added in v0.38.0 

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

PolicyClient is the client for API methods and reconciling the PublicAccessBlock

func NewPolicyClient added in v0.38.0 

func NewPolicyClient(client s3.BucketPolicyClient) *PolicyClient

NewPolicyClient creates the client for Accelerate Configuration

func (*PolicyClient) CreateOrUpdate added in v0.38.0 

func (e *PolicyClient) CreateOrUpdate(ctx context.Context, cr *v1beta1.Bucket) error

CreateOrUpdate sends a request to have resource created on AWS

func (*PolicyClient) Delete added in v0.38.0 

func (e *PolicyClient) Delete(ctx context.Context, cr *v1beta1.Bucket) error

Delete removes the public access block configuration.

func (*PolicyClient) LateInitialize added in v0.38.0 

func (e *PolicyClient) LateInitialize(ctx context.Context, cr *v1beta1.Bucket) error

LateInitialize is responsible for initializing the resource based on the external value

func (*PolicyClient) Observe added in v0.38.0 

func (e *PolicyClient) Observe(ctx context.Context, cr *v1beta1.Bucket) (ResourceStatus, error)

Observe checks if the resource exists and if it matches the local configuration

func (*PolicyClient) SubresourceExists added in v0.38.0 

func (e *PolicyClient) SubresourceExists(cr *v1beta1.Bucket) bool

SubresourceExists checks if the subresource this controller manages currently exists

type PublicAccessBlockClient 

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

PublicAccessBlockClient is the client for API methods and reconciling the PublicAccessBlock

func NewPublicAccessBlockClient 

func NewPublicAccessBlockClient(client s3.BucketClient) *PublicAccessBlockClient

NewPublicAccessBlockClient creates the client for Accelerate Configuration

func (*PublicAccessBlockClient) CreateOrUpdate 

func (in *PublicAccessBlockClient) CreateOrUpdate(ctx context.Context, cr *v1beta1.Bucket) error

CreateOrUpdate sends a request to have resource created on AWS

func (*PublicAccessBlockClient) Delete 

func (in *PublicAccessBlockClient) Delete(ctx context.Context, cr *v1beta1.Bucket) error

Delete removes the public access block configuration.

func (*PublicAccessBlockClient) LateInitialize 

func (in *PublicAccessBlockClient) LateInitialize(ctx context.Context, cr *v1beta1.Bucket) error

LateInitialize is responsible for initializing the resource based on the external value

func (*PublicAccessBlockClient) Observe 

func (in *PublicAccessBlockClient) Observe(ctx context.Context, cr *v1beta1.Bucket) (ResourceStatus, error)

Observe checks if the resource exists and if it matches the local configuration

func (*PublicAccessBlockClient) SubresourceExists 

func (in *PublicAccessBlockClient) SubresourceExists(cr *v1beta1.Bucket) bool

SubresourceExists checks if the subresource this controller manages currently exists

type ReplicationConfigurationClient 

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

ReplicationConfigurationClient is the client for API methods and reconciling the ReplicationConfiguration

func NewReplicationConfigurationClient 

func NewReplicationConfigurationClient(client s3.BucketClient) *ReplicationConfigurationClient

NewReplicationConfigurationClient creates the client for Replication Configuration

func (*ReplicationConfigurationClient) CreateOrUpdate 

func (in *ReplicationConfigurationClient) CreateOrUpdate(ctx context.Context, bucket *v1beta1.Bucket) error

CreateOrUpdate sends a request to have resource created on awsclient.

func (*ReplicationConfigurationClient) Delete 

func (in *ReplicationConfigurationClient) Delete(ctx context.Context, bucket *v1beta1.Bucket) error

Delete creates the request to delete the resource on AWS or set it to the default value.

func (*ReplicationConfigurationClient) LateInitialize 

func (in *ReplicationConfigurationClient) LateInitialize(ctx context.Context, bucket *v1beta1.Bucket) error

LateInitialize does nothing because the resource might have been deleted by the user.

func (*ReplicationConfigurationClient) Observe 

func (in *ReplicationConfigurationClient) Observe(ctx context.Context, bucket *v1beta1.Bucket) (ResourceStatus, error)

Observe checks if the resource exists and if it matches the local configuration

func (*ReplicationConfigurationClient) SubresourceExists 

func (in *ReplicationConfigurationClient) SubresourceExists(bucket *v1beta1.Bucket) bool

SubresourceExists checks if the subresource this controller manages currently exists

type RequestPaymentConfigurationClient 

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

RequestPaymentConfigurationClient is the client for API methods and reconciling the PaymentConfiguration

func NewRequestPaymentConfigurationClient 

func NewRequestPaymentConfigurationClient(client s3.BucketClient) *RequestPaymentConfigurationClient

NewRequestPaymentConfigurationClient creates the client for Payment Configuration

func (*RequestPaymentConfigurationClient) CreateOrUpdate 

func (in *RequestPaymentConfigurationClient) CreateOrUpdate(ctx context.Context, bucket *v1beta1.Bucket) error

CreateOrUpdate sends a request to have resource created on awsclient.

func (*RequestPaymentConfigurationClient) Delete 

func (*RequestPaymentConfigurationClient) Delete(_ context.Context, _ *v1beta1.Bucket) error

Delete does nothing since there is no corresponding deletion call in awsclient.

func (*RequestPaymentConfigurationClient) LateInitialize 

func (in *RequestPaymentConfigurationClient) LateInitialize(ctx context.Context, bucket *v1beta1.Bucket) error

LateInitialize is responsible for initializing the resource based on the external value

func (*RequestPaymentConfigurationClient) Observe 

func (in *RequestPaymentConfigurationClient) Observe(ctx context.Context, bucket *v1beta1.Bucket) (ResourceStatus, error)

Observe checks if the resource exists and if it matches the local configuration

func (*RequestPaymentConfigurationClient) SubresourceExists 

func (in *RequestPaymentConfigurationClient) SubresourceExists(bucket *v1beta1.Bucket) bool

SubresourceExists checks if the subresource this controller manages currently exists

type ResourceStatus 

type ResourceStatus int

ResourceStatus represents the current status if the resource resource is updated. 

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
)

func CompareCORS 

func CompareCORS(local []v1beta1.CORSRule, external []types.CORSRule) ResourceStatus

CompareCORS compares the external and internal representations for the list of CORSRules

func IsNotificationConfigurationUpToDate 

func IsNotificationConfigurationUpToDate(cr *v1beta1.NotificationConfiguration, external *awss3.GetBucketNotificationConfigurationOutput) (ResourceStatus, error)

IsNotificationConfigurationUpToDate determines whether a notification configuration needs to be updated

func IsUpToDate 

func IsUpToDate(external *types.ReplicationConfiguration, source *types.ReplicationConfiguration) (ResourceStatus, error)

IsUpToDate determines whether a replication configuration needs to be updated

type SSEConfigurationClient 

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

SSEConfigurationClient is the client for API methods and reconciling the ServerSideEncryptionConfiguration

func NewSSEConfigurationClient 

func NewSSEConfigurationClient(client s3.BucketClient) *SSEConfigurationClient

NewSSEConfigurationClient creates the client for Server Side Encryption Configuration

func (*SSEConfigurationClient) CreateOrUpdate 

func (in *SSEConfigurationClient) CreateOrUpdate(ctx context.Context, bucket *v1beta1.Bucket) error

CreateOrUpdate sends a request to have resource created on awsclient.

func (*SSEConfigurationClient) Delete 

func (in *SSEConfigurationClient) Delete(ctx context.Context, bucket *v1beta1.Bucket) error

Delete creates the request to delete the resource on AWS or set it to the default value.

func (*SSEConfigurationClient) LateInitialize 

func (in *SSEConfigurationClient) LateInitialize(ctx context.Context, bucket *v1beta1.Bucket) error

LateInitialize does nothing because the resource might have been deleted by the user.

func (*SSEConfigurationClient) Observe 

func (in *SSEConfigurationClient) Observe(ctx context.Context, bucket *v1beta1.Bucket) (ResourceStatus, error)

Observe checks if the resource exists and if it matches the local configuration

func (*SSEConfigurationClient) SubresourceExists 

func (in *SSEConfigurationClient) SubresourceExists(bucket *v1beta1.Bucket) bool

SubresourceExists checks if the subresource this controller manages currently exists

type SubresourceClient 

type SubresourceClient interface {
	Observe(ctx context.Context, bucket *v1beta1.Bucket) (ResourceStatus, error)
	CreateOrUpdate(ctx context.Context, bucket *v1beta1.Bucket) error
	Delete(ctx context.Context, bucket *v1beta1.Bucket) error
	LateInitialize(ctx context.Context, bucket *v1beta1.Bucket) error
	SubresourceExists(bucket *v1beta1.Bucket) bool
}

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

func NewSubresourceClients 

func NewSubresourceClients(client s3.BucketClient) []SubresourceClient

NewSubresourceClients creates the array of all clients for a given BucketProvider

type TaggingConfigurationClient 

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

TaggingConfigurationClient is the client for API methods and reconciling the CORSConfiguration

func NewTaggingConfigurationClient 

func NewTaggingConfigurationClient(client s3.BucketClient) *TaggingConfigurationClient

NewTaggingConfigurationClient creates the client for CORS Configuration

func (*TaggingConfigurationClient) CacheBucketTaggingOutput added in v0.47.1 

func (in *TaggingConfigurationClient) CacheBucketTaggingOutput(ctx context.Context, bucketName *string) (*awss3.GetBucketTaggingOutput, error)

CacheBucketTaggingOutput returns cached *awss3.GetBucketTaggingOutput` if it exists, otherwise adds `TaggingConfigurationClient.GetBucketTagging` output to taggingConfigurationCache and then returns it

func (*TaggingConfigurationClient) CreateOrUpdate 

func (in *TaggingConfigurationClient) CreateOrUpdate(ctx context.Context, bucket *v1beta1.Bucket) error

CreateOrUpdate sends a request to have resource created on AWS

func (*TaggingConfigurationClient) Delete 

func (in *TaggingConfigurationClient) Delete(ctx context.Context, bucket *v1beta1.Bucket) error

Delete creates the request to delete the resource on AWS or set it to the default value.

func (*TaggingConfigurationClient) LateInitialize 

func (in *TaggingConfigurationClient) LateInitialize(ctx context.Context, bucket *v1beta1.Bucket) error

LateInitialize does nothing because the resource might have been deleted by the user.

func (*TaggingConfigurationClient) Observe 

func (in *TaggingConfigurationClient) Observe(ctx context.Context, bucket *v1beta1.Bucket) (ResourceStatus, error)

Observe checks if the resource exists and if it matches the local configuration

func (*TaggingConfigurationClient) SubresourceExists 

func (in *TaggingConfigurationClient) SubresourceExists(bucket *v1beta1.Bucket) bool

SubresourceExists checks if the subresource this controller manages currently exists

type VersioningConfigurationClient 

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

VersioningConfigurationClient is the client for API methods and reconciling the VersioningConfiguration

func NewVersioningConfigurationClient 

func NewVersioningConfigurationClient(client s3.BucketClient) *VersioningConfigurationClient

NewVersioningConfigurationClient creates the client for Versioning Configuration

func (*VersioningConfigurationClient) CreateOrUpdate 

func (in *VersioningConfigurationClient) CreateOrUpdate(ctx context.Context, bucket *v1beta1.Bucket) error

CreateOrUpdate sends a request to have resource created on awsclient.

func (*VersioningConfigurationClient) Delete 

func (*VersioningConfigurationClient) Delete(_ context.Context, _ *v1beta1.Bucket) error

Delete does nothing because there is no corresponding deletion call in awsclient.

func (*VersioningConfigurationClient) LateInitialize 

func (in *VersioningConfigurationClient) LateInitialize(ctx context.Context, bucket *v1beta1.Bucket) error

LateInitialize is responsible for initializing the resource based on the external value

func (*VersioningConfigurationClient) Observe 

func (in *VersioningConfigurationClient) Observe(ctx context.Context, bucket *v1beta1.Bucket) (ResourceStatus, error)

Observe checks if the resource exists and if it matches the local configuration

func (*VersioningConfigurationClient) SubresourceExists 

func (in *VersioningConfigurationClient) SubresourceExists(bucket *v1beta1.Bucket) bool

SubresourceExists checks if the subresource this controller manages currently exists

type WebsiteConfigurationClient 

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

WebsiteConfigurationClient is the client for API methods and reconciling the WebsiteConfiguration

func NewWebsiteConfigurationClient 

func NewWebsiteConfigurationClient(client s3.BucketClient) *WebsiteConfigurationClient

NewWebsiteConfigurationClient creates the client for Website Configuration

func (*WebsiteConfigurationClient) CreateOrUpdate 

func (in *WebsiteConfigurationClient) CreateOrUpdate(ctx context.Context, bucket *v1beta1.Bucket) error

CreateOrUpdate sends a request to have resource created on awsclient.

func (*WebsiteConfigurationClient) Delete 

func (in *WebsiteConfigurationClient) Delete(ctx context.Context, bucket *v1beta1.Bucket) error

Delete creates the request to delete the resource on AWS or set it to the default value.

func (*WebsiteConfigurationClient) LateInitialize 

func (in *WebsiteConfigurationClient) LateInitialize(ctx context.Context, bucket *v1beta1.Bucket) error

LateInitialize does nothing because the resource might have been deleted by the user.

func (*WebsiteConfigurationClient) Observe 

func (in *WebsiteConfigurationClient) Observe(ctx context.Context, bucket *v1beta1.Bucket) (ResourceStatus, error)

Observe checks if the resource exists and if it matches the local configuration

func (*WebsiteConfigurationClient) SubresourceExists 

func (in *WebsiteConfigurationClient) SubresourceExists(bucket *v1beta1.Bucket) bool

SubresourceExists checks if the subresource this controller manages currently exists

Source Files

View all Source files

Directories

Path Synopsis

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.