awss3source

Documentation

Index

• func EnsureNoQueue(ctx context.Context, src *v1alpha1.AWSS3Source, cli sqsiface.SQSAPI) error
• func EnsureNotificationsDisabled(ctx context.Context, src *v1alpha1.AWSS3Source, cli s3iface.S3API) error
• func EnsureNotificationsEnabled(ctx context.Context, src *v1alpha1.AWSS3Source, cli s3iface.S3API, ...) error
• func EnsureQueue(ctx context.Context, src *v1alpha1.AWSS3Source, cli sqsiface.SQSAPI) (string, error)
• type AWSS3Handler
  • func New(s3Cg s3client.ClientGetter, log *zap.SugaredLogger) *AWSS3Handler
  • func (h *AWSS3Handler) Finalize(ctx context.Context, obj metav1.Object) *hookv1.HookResponse
  • func (h *AWSS3Handler) GroupVersionResource() *schema.GroupVersionResource
  • func (h *AWSS3Handler) Kind() string
  • func (h *AWSS3Handler) Reconcile(ctx context.Context, obj metav1.Object) *hookv1.HookResponse

Functions

func EnsureNoQueue

func EnsureNoQueue(ctx context.Context, src *v1alpha1.AWSS3Source, cli sqsiface.SQSAPI) error

EnsureNoQueue ensures that the SQS queue created for sending S3 event notifications is deleted.

func EnsureNotificationsDisabled

func EnsureNotificationsDisabled(ctx context.Context, src *v1alpha1.AWSS3Source, cli s3iface.S3API) error

EnsureNotificationsDisabled ensures that event notifications are disabled in the S3 bucket.

func EnsureNotificationsEnabled

func EnsureNotificationsEnabled(ctx context.Context, src *v1alpha1.AWSS3Source, cli s3iface.S3API, queueARN string) error

EnsureNotificationsEnabled ensures that event notifications are enabled in the S3 bucket.

func EnsureQueue

func EnsureQueue(ctx context.Context, src *v1alpha1.AWSS3Source, cli sqsiface.SQSAPI) (string, error)

EnsureQueue ensures the existence of a SQS queue for sending S3 event notifications.

Types

type AWSS3Handler

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

func New

func New(s3Cg s3client.ClientGetter, log *zap.SugaredLogger) *AWSS3Handler

func (*AWSS3Handler) Finalize

func (h *AWSS3Handler) Finalize(ctx context.Context, obj metav1.Object) *hookv1.HookResponse

func (*AWSS3Handler) GroupVersionResource

func (h *AWSS3Handler) GroupVersionResource() *schema.GroupVersionResource

func (*AWSS3Handler) Kind

func (h *AWSS3Handler) Kind() string

Kind for the managed object

func (*AWSS3Handler) Reconcile

func (h *AWSS3Handler) Reconcile(ctx context.Context, obj metav1.Object) *hookv1.HookResponse