intevents

Documentation

Index

• Constants
• type PubSubBase
  • func NewPubSubBase(ctx context.Context, args *PubSubBaseArgs) *PubSubBase
  • func (psb *PubSubBase) DeletePubSub(ctx context.Context, pubsubable duck.PubSubable) error
  • func (psb *PubSubBase) ReconcilePubSub(ctx context.Context, pubsubable duck.PubSubable, topic, resourceGroup string) (*inteventsv1.Topic, *inteventsv1.PullSubscription, error)
  • func (psb *PubSubBase) ReconcilePullSubscription(ctx context.Context, pubsubable duck.PubSubable, topic, resourceGroup string) (*inteventsv1.PullSubscription, pkgreconciler.Event)
• type PubSubBaseArgs

Constants

const (
	PullSubscriptionStatusPropagateFailedReason = "PullSubscriptionStatusPropagateFailed"
)

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

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