reconciler

May 19, 2020

Changes in this version

+ const AzureChannelReadyCountN

+ const AzureChannelReadyLatencyN

+ var KindToMeasurements map[string]Measurements

+ var KindToStatKeys = map[string]StatKey

+ type Base struct

+ AzureClientSet clientset.Interface

+ ConfigMapWatcher configmap.Watcher

+ DynamicClientSet dynamic.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

+ AzureClientSet clientset.Interface

+ ConfigMapWatcher *configmap.InformedWatcher

+ DynamicClientSet dynamic.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)