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 (*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
Source Files
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.