bucket

Documentation

Index

• func NewBucketController(cfg *rest.Config, p *Provisioner) (*provisioner.Provisioner, error)
• type Provisioner
  • func NewProvisioner(context *clusterd.Context, namespace, runRgwCmdAsUser string) *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

Functions

func NewBucketController

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

Types

type Provisioner

type Provisioner struct {

	// RunAsUser cephx user to use on radosgw-admin to create s3 users
	RunRgwCmdAsUser string
	// contains filtered or unexported fields
}

func NewProvisioner

func NewProvisioner(context *clusterd.Context, namespace, runRgwCmdAsUser string) *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.