reconciler

Documentation

Index

• Variables
• func Annotations(owner kmeta.OwnerRefable) map[string]string
• func Labels(owner kmeta.OwnerRefable, labelKey string) map[string]string
• type Base
  • func NewBase(ctx context.Context, controllerAgentName string, cmw configmap.Watcher) *Base
  • func (r *Base) ReconcileSink(ctx context.Context, source v1alpha1.Source) error

Variables

var (
	ErrSinkMissing = errors.New("Sink missing from spec")
)

Functions

func Annotations

func Annotations(owner kmeta.OwnerRefable) map[string]string

func Labels

func Labels(owner kmeta.OwnerRefable, labelKey string) map[string]string

Types

type Base

type Base struct {
	// Include the knative/eventing reconciler base.
	// +required
	*eventingreconciler.Base

	// ClientSet for Sources; note that EventingClientSet (from eventing Base) is unused
	// +required
	SourcesClientSet clientset.Interface

	// Used by all Sources to resolve their sink.
	// +required
	SinkResolver *resolver.URIResolver
}

Base is a set of tools that source reconcilers need.

func NewBase

func NewBase(ctx context.Context, controllerAgentName string, cmw configmap.Watcher) *Base

func (*Base) ReconcileSink

func (r *Base) ReconcileSink(ctx context.Context, source v1alpha1.Source) error