reconciler

Jan 21, 2020

Changes in this version

type Base

+ LegacyClientSet legacyclientset.Interface

Jun 25, 2019

Changes in this version

+ const InMemoryChannelReadyCountN

+ const InMemoryChannelReadyLatencyN

+ func WithStatsReporter(ctx context.Context, sr StatsReporter) context.Context

type Base

+ ApiExtensionsClientSet apiextensionsclientset.Interface

type StatsReporter

+ func GetStatsReporter(ctx context.Context) StatsReporter

May 14, 2019

Changes in this version

+ const ApiServerSourceReadyCountN

+ const ApiServerSourceReadyLatencyN

+ const BrokerReadyCountN

+ const BrokerReadyLatencyN

+ const ChannelReadyCountN

+ const ChannelReadyLatencyN

+ const ContainerSourceReadyCountN

+ const ContainerSourceReadyLatencyN

+ const CronJobSourceReadyCountN

+ const CronJobSourceReadyLatencyN

+ const SubscriptionReadyCountN

+ const SubscriptionReadyLatencyN

+ const TriggerReadyCountN

+ const TriggerReadyLatencyN

+ var KindToMeasurements map[string]Measurements

+ var KindToStatKeys = map[string]StatKey

+ func Handler(h func(interface{})) cache.ResourceEventHandler

+ func MustNewStatsReporter(reconciler string, logger *zap.SugaredLogger) controller.StatsReporter

+ type Base struct

+ ConfigMapWatcher configmap.Watcher

+ DynamicClientSet dynamic.Interface

+ EventingClientSet clientset.Interface

+ KubeClientSet kubernetes.Interface

+ Logger *zap.SugaredLogger

+ Recorder record.EventRecorder

+ StatsReporter StatsReporter

+ func NewBase(opt Options, controllerAgentName string) *Base

+ type Measurement int

+ type Measurements struct

+ ReadyCountStat *stats.Int64Measure

+ ReadyLatencyStat *stats.Int64Measure

+ type Options struct

+ ConfigMapWatcher configmap.Watcher

+ DynamicClientSet dynamic.Interface

+ EventingClientSet clientset.Interface

+ KubeClientSet kubernetes.Interface

+ Logger *zap.SugaredLogger

+ Recorder record.EventRecorder

+ ResyncPeriod time.Duration

+ StatsReporter StatsReporter

+ StopChannel <-chan struct{}

+ func NewOptionsOrDie(cfg *rest.Config, logger *zap.SugaredLogger, stopCh <-chan struct{}) Options

+ func (o Options) GetTrackerLease() time.Duration

+ type StatKey struct

+ ReadyCountKey string

+ ReadyLatencyKey string

+ type StatsReporter interface

+ ReportReady func(kind, namespace, service string, d time.Duration) error

+ func NewStatsReporter(reconciler string) (StatsReporter, error)