bucketcontroller

Documentation

Index

• func SetupController(mgr ctrl.Manager) error
• func SetupWebhook(mgr ctrl.Manager) error
• type BucketValidator
  • func (v *BucketValidator) ValidateCreate(_ context.Context, obj runtime.Object) (admission.Warnings, error)
  • func (v *BucketValidator) ValidateDelete(_ context.Context, obj runtime.Object) (admission.Warnings, error)
  • func (v *BucketValidator) ValidateUpdate(_ context.Context, oldObj, newObj runtime.Object) (admission.Warnings, error)
• type NoopClient
  • func (n *NoopClient) Create(ctx context.Context, mg resource.Managed) (managed.ExternalCreation, error)
  • func (n *NoopClient) Delete(ctx context.Context, mg resource.Managed) error
  • func (n *NoopClient) Observe(ctx context.Context, mg resource.Managed) (managed.ExternalObservation, error)
  • func (n *NoopClient) Update(ctx context.Context, mg resource.Managed) (managed.ExternalUpdate, error)
• type ProvisioningPipeline
  • func NewProvisioningPipeline(kube client.Client, recorder event.Recorder, minio *minio.Client) *ProvisioningPipeline
  • func (p *ProvisioningPipeline) Create(ctx context.Context, mg resource.Managed) (managed.ExternalCreation, error)
  • func (p *ProvisioningPipeline) Delete(ctx context.Context, mg resource.Managed) error
  • func (p *ProvisioningPipeline) Observe(ctx context.Context, mg resource.Managed) (managed.ExternalObservation, error)
  • func (p *ProvisioningPipeline) Update(ctx context.Context, mg resource.Managed) (managed.ExternalUpdate, error)

Functions

func SetupController

func SetupController(mgr ctrl.Manager) error

SetupController adds a controller that reconciles cloudscalev1.Bucket managed resources.

func SetupWebhook

func SetupWebhook(mgr ctrl.Manager) error

SetupWebhook adds a webhook for Bucket managed resources.

Types

type BucketValidator

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

BucketValidator validates admission requests.

func (*BucketValidator) ValidateCreate

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

ValidateCreate implements admission.CustomValidator.

func (*BucketValidator) ValidateDelete

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

ValidateDelete implements admission.CustomValidator.

func (*BucketValidator) ValidateUpdate

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

ValidateUpdate implements admission.CustomValidator.

type NoopClient

type NoopClient struct{}

NoopClient is a client that does nothing.

func (*NoopClient) Create

func (n *NoopClient) Create(ctx context.Context, mg resource.Managed) (managed.ExternalCreation, error)

Create implement managed.ExternalClient. It returns nil.

func (*NoopClient) Delete

func (n *NoopClient) Delete(ctx context.Context, mg resource.Managed) error

Delete implement managed.ExternalClient. It returns nil.

func (*NoopClient) Observe

func (n *NoopClient) Observe(ctx context.Context, mg resource.Managed) (managed.ExternalObservation, error)

Observe implements managed.ExternalClient. It always returns an observation where the resource doesn't exist and is outdated, together with a nil error.

func (*NoopClient) Update

func (n *NoopClient) Update(ctx context.Context, mg resource.Managed) (managed.ExternalUpdate, error)

Update implement managed.ExternalClient. It returns nil.

type ProvisioningPipeline

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

ProvisioningPipeline provisions Buckets using S3 client.

func NewProvisioningPipeline

func NewProvisioningPipeline(kube client.Client, recorder event.Recorder, minio *minio.Client) *ProvisioningPipeline

NewProvisioningPipeline returns a new instance of ProvisioningPipeline.

func (*ProvisioningPipeline) Create

func (p *ProvisioningPipeline) Create(ctx context.Context, mg resource.Managed) (managed.ExternalCreation, error)

Create implements managed.ExternalClient.

func (*ProvisioningPipeline) Delete

func (p *ProvisioningPipeline) Delete(ctx context.Context, mg resource.Managed) error

Delete implements managed.ExternalClient.

func (*ProvisioningPipeline) Observe

func (p *ProvisioningPipeline) Observe(ctx context.Context, mg resource.Managed) (managed.ExternalObservation, error)

Observe implements managed.ExternalClient.

func (*ProvisioningPipeline) Update

func (p *ProvisioningPipeline) Update(ctx context.Context, mg resource.Managed) (managed.ExternalUpdate, error)

Update implements managed.ExternalClient.