notification

Documentation

Overview

Package notification to manage a rook bucket notifications.

Package notification to manage a rook bucket notifications.

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, notificationId string) error
• func DeleteBucketNotificationRequest(c *s3.S3, input *DeleteBucketNotificationRequestInput, notificationId string) *request.Request
• type DeleteBucketNotificationRequestInput
  • func (s DeleteBucketNotificationRequestInput) GoString() string
  • func (s DeleteBucketNotificationRequestInput) String() string
  • func (s *DeleteBucketNotificationRequestInput) Validate() error
• type ReconcileNotifications
  • func (r *ReconcileNotifications) Reconcile(context context.Context, request reconcile.Request) (reconcile.Result, error)
• type ReconcileOBCLabels
  • func (r *ReconcileOBCLabels) Reconcile(context context.Context, request reconcile.Request) (reconcile.Result, error)

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, notificationId string) error

func DeleteBucketNotificationRequest

func DeleteBucketNotificationRequest(c *s3.S3, input *DeleteBucketNotificationRequestInput, notificationId string) *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 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.