intevents

package
v0.17.0 Latest Latest
Warning

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

Go to latest
Published: Aug 20, 2020 License: Apache-2.0 Imports: 18 Imported by: 9

Documentation

Index

Constants

View Source
const (
	PullSubscriptionStatusPropagateFailedReason = "PullSubscriptionStatusPropagateFailed"
)

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, args *PubSubBaseArgs) *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) (*inteventsv1.Topic, *inteventsv1.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

func (*PubSubBase) ReconcilePullSubscription

func (psb *PubSubBase) ReconcilePullSubscription(ctx context.Context, pubsubable duck.PubSubable, topic, resourceGroup string) (*inteventsv1.PullSubscription, pkgreconciler.Event)

type PubSubBaseArgs added in v0.16.0

type PubSubBaseArgs struct {
	ControllerAgentName string
	ReceiveAdapterName  string
	ReceiveAdapterType  string
	ConfigWatcher       configmap.Watcher
}

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