bucket

Documentation

Index

• func MaxObjectQuota(AdditionalConfig map[string]string) string
• func MaxSizeQuota(AdditionalConfig map[string]string) string
• func NewBucketController(cfg *rest.Config, p *Provisioner) (*provisioner.Provisioner, error)
• type Provisioner
  • func NewProvisioner(context *clusterd.Context, clusterInfo *client.ClusterInfo) *Provisioner
  • func (p Provisioner) Delete(ob *bktv1alpha1.ObjectBucket) error
  • func (p Provisioner) Grant(options *apibkt.BucketOptions) (*bktv1alpha1.ObjectBucket, error)
  • func (p Provisioner) Provision(options *apibkt.BucketOptions) (*bktv1alpha1.ObjectBucket, error)
  • func (p Provisioner) Revoke(ob *bktv1alpha1.ObjectBucket) error
  • func (p Provisioner) Update(ob *bktv1alpha1.ObjectBucket) error

Functions

func MaxObjectQuota

func MaxObjectQuota(AdditionalConfig map[string]string) string

func MaxSizeQuota

func MaxSizeQuota(AdditionalConfig map[string]string) string

func NewBucketController

func NewBucketController(cfg *rest.Config, p *Provisioner) (*provisioner.Provisioner, error)

Types

type Provisioner

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

func NewProvisioner

func NewProvisioner(context *clusterd.Context, clusterInfo *client.ClusterInfo) *Provisioner

func (Provisioner) Delete

func (p Provisioner) Delete(ob *bktv1alpha1.ObjectBucket) error

Delete is called when the ObjectBucketClaim (OBC) is deleted and the associated storage class' reclaimPolicy is "Delete". Or, if a Provision() error occurs and the bucket controller needs to clean up before retrying.

func (Provisioner) Grant

func (p Provisioner) Grant(options *apibkt.BucketOptions) (*bktv1alpha1.ObjectBucket, error)

Grant attaches to an existing rgw bucket and returns a connection info representing the bucket's endpoint and user access credentials.

func (Provisioner) Provision

func (p Provisioner) Provision(options *apibkt.BucketOptions) (*bktv1alpha1.ObjectBucket, error)

Provision creates an s3 bucket and returns a connection info representing the bucket's endpoint and user access credentials.

func (Provisioner) Revoke

func (p Provisioner) Revoke(ob *bktv1alpha1.ObjectBucket) error

Revoke removes a user and creds from an existing bucket. Note: cleanup order below matters.

func (Provisioner) Update

func (p Provisioner) Update(ob *bktv1alpha1.ObjectBucket) error

Update is sent when only there is modification to AdditionalConfig field in OBC