azureblobstoragesource

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 (
	// ReasonEventHubCreated indicates that an Event Hub was created for receiving storage events.
	ReasonEventHubCreated = "EventHubCreated"
	// ReasonEventHubDeleted indicates that an Event Hub used for receiving storage events was deleted.
	ReasonEventHubDeleted = "EventHubDeleted"
	// ReasonFailedEventHub indicates a failure while synchronizing the Event Hub for receiving storage events.
	ReasonFailedEventHub = "FailedEventHub"

	// ReasonSubscribed indicates that an event subscription was enabled for a storage account.
	ReasonSubscribed = "Subscribed"
	// ReasonUnsubscribed indicates that an event subscription was removed for a storage account.
	ReasonUnsubscribed = "Unsubscribed"
	// ReasonFailedSubscribe indicates a failure while synchronizing an event subscription for a storage account.
	ReasonFailedSubscribe = "FailedSubscribe"
	// ReasonFailedUnsubscribe indicates a failure while removing an event subscription for a storage account.
	ReasonFailedUnsubscribe = "FailedUnsubscribe"
)

Variables

This section is empty.

Functions

func EnsureEventHub added in v1.22.0 

func EnsureEventHub(ctx context.Context, cli storage.EventHubsClient) (string, error)

EnsureEventHub ensures the existence of an Event Hub for sending storage events. Required permissions:

  • Microsoft.EventHub/namespaces/eventhubs/read
  • Microsoft.EventHub/namespaces/eventhubs/write

func EnsureEventSubscription added in v1.22.0 

func EnsureEventSubscription(ctx context.Context, cli storage.EventSubscriptionsClient, eventHubResID string) error

EnsureEventSubscription ensures an event subscription exists with the expected configuration. Required permissions:

  • Microsoft.EventGrid/eventSubscriptions/read
  • Microsoft.EventGrid/eventSubscriptions/write
  • Microsoft.EventHub/namespaces/eventhubs/write

func EnsureNoEventHub added in v1.22.0 

func EnsureNoEventHub(ctx context.Context, cli storage.EventHubsClient) error

EnsureNoEventHub ensures that the Event Hub created for sending storage events is deleted. Required permissions:

  • Microsoft.EventHub/namespaces/eventhubs/delete

func EnsureNoEventSubscription added in v1.22.0 

func EnsureNoEventSubscription(ctx context.Context, cli storage.EventSubscriptionsClient) reconciler.Event

EnsureNoEventSubscription ensures the event subscription is removed. Required permissions:

  • Microsoft.EventGrid/eventSubscriptions/delete

func MakeAppEnv added in v1.21.0 

func MakeAppEnv(o *v1alpha1.AzureBlobStorageSource) []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, o *v1alpha1.AzureBlobStorageSource) reconciler.Event

FinalizeKind is called when the resource is deleted.

func (*Reconciler) ReconcileKind 

func (r *Reconciler) ReconcileKind(ctx context.Context, o *v1alpha1.AzureBlobStorageSource) reconciler.Event

ReconcileKind implements Interface.ReconcileKind.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.