Documentation
¶
Overview ¶
Package notification to manage a rook bucket notifications.
Index ¶
- func Add(mgr manager.Manager, context *clusterd.Context, ...) error
- func DeleteBucketNotification(c *s3.S3, input *DeleteBucketNotificationRequestInput) error
- func DeleteBucketNotificationRequest(c *s3.S3, input *DeleteBucketNotificationRequestInput) (req *request.Request)
- type DeleteBucketNotificationRequestInput
- type Provisioner
- type ReconcileNotifications
- type ReconcileOBCLabels
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(c *s3.S3, input *DeleteBucketNotificationRequestInput) error
func DeleteBucketNotificationRequest ¶
func DeleteBucketNotificationRequest(c *s3.S3, input *DeleteBucketNotificationRequestInput) (req *request.Request)
Types ¶
type DeleteBucketNotificationRequestInput ¶
type DeleteBucketNotificationRequestInput struct {
// The name of the bucket for which to get the notification configuration.
//
// Bucket is a required field
Bucket *string `location:"uri" locationName:"Bucket" type:"string" required:"true"`
// The account id of the expected bucket owner. If the bucket is owned by a
// different account, the request will fail with an HTTP 403 (Access Denied)
// error.
ExpectedBucketOwner *string `location:"header" locationName:"x-amz-expected-bucket-owner" type:"string"`
// contains filtered or unexported fields
}
func (DeleteBucketNotificationRequestInput) GoString ¶
func (s DeleteBucketNotificationRequestInput) GoString() string
GoString returns the string representation
func (DeleteBucketNotificationRequestInput) String ¶
func (s DeleteBucketNotificationRequestInput) String() string
String returns the string representation
func (*DeleteBucketNotificationRequestInput) Validate ¶
func (s *DeleteBucketNotificationRequestInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type Provisioner ¶
type Provisioner struct {
Client client.Client
Context *clusterd.Context
ClusterInfo *cephclient.ClusterInfo
ClusterSpec *cephv1.ClusterSpec
// contains filtered or unexported fields
}
func (*Provisioner) Create ¶
func (p *Provisioner) Create(bucket *bktv1alpha1.ObjectBucket, topicARN string, notification *cephv1.CephBucketNotification, sess *awssession.Session) error
func (*Provisioner) DeleteAll ¶
func (p *Provisioner) DeleteAll(bucket *bktv1alpha1.ObjectBucket, sess *awssession.Session) error
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 that 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 a ObjectBucketClaim labels
func (*ReconcileOBCLabels) Reconcile ¶
func (r *ReconcileOBCLabels) Reconcile(context context.Context, request reconcile.Request) (reconcile.Result, error)
Reconcile reads that state of the cluster for a 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