awss3source

package
v1.27.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 17, 2023 License: Apache-2.0 Imports: 41 Imported by: 3

Documentation

Index

Constants

View Source
const (
	// ReasonQueueCreated indicates that a SQS queue was created for receiving S3 event notifications.
	ReasonQueueCreated = "QueueCreated"
	// ReasonQueueDeleted indicates that a SQS queue used for receiving S3 events was deleted.
	ReasonQueueDeleted = "QueueDeleted"
	// ReasonFailedQueue indicates a failure while synchronizing the SQS queue for receiving S3 event notifications.
	ReasonFailedQueue = "FailedQueue"

	// ReasonSubscribed indicates that event notifications were enabled for a S3 bucket.
	ReasonSubscribed = "Subscribed"
	// ReasonUnsubscribed indicates that event notifications were disabled for a S3 bucket.
	ReasonUnsubscribed = "Unsubscribed"
	// ReasonFailedSubscribe indicates a failure while enabling event notifications for a S3 bucket.
	ReasonFailedSubscribe = "FailedSubscribe"
	// ReasonFailedUnsubscribe indicates a failure while disabling event notifications for a S3 bucket.
	ReasonFailedUnsubscribe = "FailedUnsubscribe"
)

Variables

This section is empty.

Functions

func EnsureNoQueue added in v1.22.0

func EnsureNoQueue(ctx context.Context, cli sqsiface.SQSAPI) error

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

func EnsureNotificationsDisabled added in v1.22.0

func EnsureNotificationsDisabled(ctx context.Context, cli s3iface.S3API) error

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

func EnsureNotificationsEnabled added in v1.22.0

func EnsureNotificationsEnabled(ctx context.Context, cli s3iface.S3API, queueARN string) error

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

func EnsureQueue added in v1.22.0

func EnsureQueue(ctx context.Context, cli sqsiface.SQSAPI) (string, error)

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

func MakeAppEnv added in v1.21.0

func MakeAppEnv(o *v1alpha1.AWSS3Source) []corev1.EnvVar

MakeAppEnv extracts environment variables from the object. Exported to be used in external tools for local test environments.

func NewController

func NewController(
	ctx context.Context,
	cmw configmap.Watcher,
) *controller.Impl

NewController creates a Reconciler for the event source and returns the result of NewImpl.

Types

type Reconciler

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

Reconciler implements controller.Reconciler for the event source type.

func (*Reconciler) BuildAdapter

func (r *Reconciler) BuildAdapter(src commonv1alpha1.Reconcilable, sinkURI *apis.URL) (*appsv1.Deployment, error)

BuildAdapter implements common.AdapterBuilder.

func (*Reconciler) FinalizeKind

func (r *Reconciler) FinalizeKind(ctx context.Context, src *v1alpha1.AWSS3Source) reconciler.Event

FinalizeKind is called when the resource is deleted.

func (*Reconciler) ReconcileKind

func (r *Reconciler) ReconcileKind(ctx context.Context, src *v1alpha1.AWSS3Source) reconciler.Event

ReconcileKind implements Interface.ReconcileKind.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL