bucketaccess

Documentation

Index

• type BucketAccessListener
  • func NewBucketAccessListener(driverName string, client cosi.ProvisionerClient) (*BucketAccessListener, error)
  • func (bal *BucketAccessListener) Add(ctx context.Context, inputBucketAccess *v1alpha1.BucketAccess) error
  • func (bal *BucketAccessListener) Delete(ctx context.Context, bucketAccess *v1alpha1.BucketAccess) error
  • func (bal *BucketAccessListener) InitializeBucketClient(bc buckets.Interface)
  • func (bal *BucketAccessListener) InitializeKubeClient(k kube.Interface)
  • func (bal *BucketAccessListener) Update(ctx context.Context, old, new *v1alpha1.BucketAccess) error

Types

type BucketAccessListener

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

BucketAccessListener manages Bucket objects

func NewBucketAccessListener

func NewBucketAccessListener(driverName string, client cosi.ProvisionerClient) (*BucketAccessListener, error)

NewBucketAccessListener returns a resource handler for BucketAccess objects

func (*BucketAccessListener) Add

func (bal *BucketAccessListener) Add(ctx context.Context, inputBucketAccess *v1alpha1.BucketAccess) error

Add attempts to provision credentials to access a given bucket. This function must be idempotent Return values

nil - BucketAccess successfully granted
non-nil err - Internal error                                [requeue'd with exponential backoff]

func (*BucketAccessListener) Delete

func (bal *BucketAccessListener) Delete(ctx context.Context, bucketAccess *v1alpha1.BucketAccess) error

Delete attemps to delete a bucketAccess. This function must be idempotent Return values

nil - BucketAccess successfully deleted
non-nil err - Internal error                                [requeue'd with exponential backoff]

func (*BucketAccessListener) InitializeBucketClient

func (bal *BucketAccessListener) InitializeBucketClient(bc buckets.Interface)

InitializeBucketClient initializes the object storage bucket client

func (*BucketAccessListener) InitializeKubeClient

func (bal *BucketAccessListener) InitializeKubeClient(k kube.Interface)

InitializeKubeClient initializes the kubernetes client

func (*BucketAccessListener) Update

func (bal *BucketAccessListener) Update(ctx context.Context, old, new *v1alpha1.BucketAccess) error

Update attempts to reconcile changes to a given bucketAccess. This function must be idempotent Return values

nil - BucketAccess successfully reconciled
non-nil err - Internal error                                [requeue'd with exponential backoff]