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 (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
Constants ¶
const ( CephUser = "cephUser" ObjectStoreName = "objectStoreName" ObjectStoreNamespace = "objectStoreNamespace" )
Variables ¶
This section is empty.
Functions ¶
func Add ¶ added in v1.8.0
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 ¶ added in v1.10.6
func GetObjectStoreNameFromBucket(ob *bktv1alpha1.ObjectBucket) (types.NamespacedName, error)
func MaxObjectQuota ¶ added in v1.4.0
func MaxSizeQuota ¶ added in v1.4.0
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 ¶ added in v1.10.6
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 ¶ added in v1.8.0
type ReconcileBucket struct {
// contains filtered or unexported fields
}
ReconcileBucket reconciles a ceph-csi driver
func (*ReconcileBucket) Reconcile ¶ added in v1.8.0
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.
Source Files