bucket

Documentation

Index

• Constants
• func Add(mgr manager.Manager, context *clusterd.Context, ...) error
• func GetObjectStoreNameFromBucket(ob *bktv1alpha1.ObjectBucket) (types.NamespacedName, error)
• func MaxObjectQuota(AdditionalConfig map[string]string) string
• func MaxSizeQuota(AdditionalConfig map[string]string) string
• func NewBucketController(cfg *rest.Config, p *Provisioner, data map[string]string) (*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) GenerateUserID(obc *bktv1alpha1.ObjectBucketClaim, ob *bktv1alpha1.ObjectBucket) (string, 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
• type ReconcileBucket
  • func (r *ReconcileBucket) Reconcile(context context.Context, request reconcile.Request) (reconcile.Result, error)

Constants

const (
	CephUser             = "cephUser"
	ObjectStoreName      = "objectStoreName"
	ObjectStoreNamespace = "objectStoreNamespace"
)

Functions

func Add

func Add(mgr manager.Manager, context *clusterd.Context, opManagerContext context.Context, opConfig opcontroller.OperatorConfig) error

Add creates a new Ceph CSI Controller and adds it to the Manager. The Manager will set fields on the Controller and Start it when the Manager is Started.

func GetObjectStoreNameFromBucket

func GetObjectStoreNameFromBucket(ob *bktv1alpha1.ObjectBucket) (types.NamespacedName, error)

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, data map[string]string) (*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) GenerateUserID

func (p Provisioner) GenerateUserID(obc *bktv1alpha1.ObjectBucketClaim, ob *bktv1alpha1.ObjectBucket) (string, error)

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.

type ReconcileBucket

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

ReconcileBucket reconciles a ceph-csi driver

func (*ReconcileBucket) Reconcile

func (r *ReconcileBucket) Reconcile(context context.Context, request reconcile.Request) (reconcile.Result, error)

Reconcile reads that state of the operator config map and makes changes based on the state read The Controller will requeue the Request to be processed again if the returned error is non-nil or Result.Requeue is true, otherwise upon completion it will remove the work from the queue.