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 ¶ added in v0.12.0
func NewPubSubBaseWithAdapter ¶ added in v0.12.0
func (*PubSubBase) DeletePubSub ¶ added in v0.12.0
func (psb *PubSubBase) DeletePubSub(ctx context.Context, pubsubable duck.PubSubable) error
func (*PubSubBase) ReconcilePubSub ¶ added in v0.12.0
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 |
---|---|
Package pullsubscription implements the Pub/Sub PullSubscription controllers.
|
Package pullsubscription implements the Pub/Sub PullSubscription controllers. |
keda
Package keda implements the Pub/Sub PullSubscription controller for Keda-based PullSubscriptions.
|
Package keda implements the Pub/Sub PullSubscription controller for Keda-based PullSubscriptions. |
static
Package static implements the Pub/Sub PullSubscription controller for non-scalable PullSubscriptions.
|
Package static implements the Pub/Sub PullSubscription controller for non-scalable PullSubscriptions. |
Package topic implements the Pub/Sub Topic controller.
|
Package topic implements the Pub/Sub Topic controller. |
Click to show internal directories.
Click to hide internal directories.