Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type PubSubBase

type PubSubBase struct {
	*reconciler.Base
	// contains filtered or unexported fields
}

func NewPubSubBase

func NewPubSubBase(ctx context.Context, controllerAgentName, receiveAdapterName string, cmw configmap.Watcher) *PubSubBase

func NewPubSubBaseWithAdapter

func NewPubSubBaseWithAdapter(ctx context.Context, controllerAgentName, receiveAdapterName string, adapterType string, cmw configmap.Watcher) *PubSubBase

func (*PubSubBase) DeletePubSub

func (psb *PubSubBase) DeletePubSub(ctx context.Context, pubsubable duck.PubSubable) error

func (*PubSubBase) ReconcilePubSub

func (psb *PubSubBase) ReconcilePubSub(ctx context.Context, pubsubable duck.PubSubable, topic, resourceGroup string) (*pubsubv1alpha1.Topic, *pubsubv1alpha1.PullSubscription, error)

ReconcilePubSub reconciles Topic / PullSubscription given a PubSubSpec. Sets the following Conditions in the Status field appropriately: "TopicReady", and "PullSubscriptionReady" Also sets the following fields in the pubsubable.Status upon success TopicID, ProjectID, and SinkURI

Directories

Path Synopsis
pullsubscription Package pullsubscription implements the Pub/Sub PullSubscription controllers.
pullsubscription/keda Package keda implements the Pub/Sub PullSubscription controller for Keda-based PullSubscriptions.
pullsubscription/keda/resources
pullsubscription/resources
pullsubscription/static Package static implements the Pub/Sub PullSubscription controller for non-scalable PullSubscriptions.
resources
topic Package topic implements the Pub/Sub Topic controller.
topic/resources