bucket

package
v0.50.6 Latest Latest
Warning

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

 Go to latest Published: Nov 27, 2024 License: Apache-2.0 Imports: 31 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 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 responsible for initializing the resource based on the external value

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