Documentation
¶
Overview ¶
Package notification to manage rook bucket notifications.
Package notification to manage rook bucket notifications.
Package notification to manage rook bucket notifications.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Add ¶
func Add(mgr manager.Manager, context *clusterd.Context, opManagerContext context.Context, opConfig opcontroller.OperatorConfig) error
Add creates a new CephBucketNotification controller and a new ObjectBucketClaim Controller and adds it to the Manager. The Manager will set fields on the Controller and start it when the Manager is started.
func DeleteBucketNotification ¶
func DeleteBucketNotification(ctx context.Context, client *s3.Client, input *DeleteBucketNotificationRequestInput, notificationId string) error
DeleteBucketNotification sends a Ceph-specific DELETE request to remove a bucket notification configuration. This is not part of the standard AWS S3 API, so we build and sign the HTTP request manually using the v2 client's credentials and endpoint.
Types ¶
type ReconcileNotifications ¶
type ReconcileNotifications struct {
// contains filtered or unexported fields
}
ReconcileNotifications reconciles a CephBucketNotification
func (*ReconcileNotifications) Reconcile ¶
func (r *ReconcileNotifications) Reconcile(context context.Context, request reconcile.Request) (reconcile.Result, error)
Reconcile reads the state of the cluster for a CephBucketNotification object 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.
type ReconcileOBCLabels ¶
type ReconcileOBCLabels struct {
// contains filtered or unexported fields
}
ReconcileOBCLabels reconciles ObjectBucketClaim labels
func (*ReconcileOBCLabels) Reconcile ¶
func (r *ReconcileOBCLabels) Reconcile(context context.Context, request reconcile.Request) (reconcile.Result, error)
Reconcile reads the state of the cluster for an ObjectBucketClaim object and makes changes based on the state read and the ObjectBucketClaim labels 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