pubsub

package
v0.0.0-...-c52b3dd Latest Latest
Warning

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

Go to latest
Published: Mar 3, 2020 License: Apache-2.0 Imports: 16 Imported by: 0

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
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.

Jump to

Keyboard shortcuts

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