reconciler

package
v0.0.0-...-cb3e436 Latest Latest
Warning

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

Go to latest
Published: Sep 18, 2019 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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