Back to

Package pubsub

Latest Go to latest

The highest tagged major version is .

Published: Mar 3, 2020 | License: Apache-2.0 | Module:


type PubSubBase

type PubSubBase struct {
	// 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

Package Files

Documentation was rendered with GOOS=linux and GOARCH=amd64.

Jump to identifier

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to identifier