reconciler

Sep 16, 2019

Changes in this version

+ func Not(f func(interface{}) bool) func(interface{}) bool

Jun 25, 2019

Changes in this version

+ const ForceUpgradePatch

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

type Base

+ func (b *Base) MarkNeedsUpgrade(gvr schema.GroupVersionResource, namespace, name string) error

+ type ConfigStore interface

+ ToContext func(ctx context.Context) context.Context

type StatsReporter

+ func GetStatsReporter(ctx context.Context) StatsReporter

May 14, 2019

Changes in this version

+ func ChainFilterFuncs(funcs ...func(interface{}) bool) func(interface{}) bool

+ func LabelFilterFunc(label string, value string, allowUnset bool) func(interface{}) bool

+ func NameFilterFunc(name string) func(interface{}) bool

+ func NamespaceFilterFunc(namespace string) func(interface{}) bool

Apr 2, 2019

Changes in this version

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

type Options

+ ScaleClientSet scale.ScalesGetter

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

Feb 19, 2019

Changes in this version

+ func GetServingRevisionNameForK8sService(name string) string

+ func LabelExistsFilterFunc(label string) func(obj interface{}) bool

Jan 8, 2019

Changes in this version

+ const ServiceReadyCountN

+ const ServiceReadyLatencyN

+ func AnnotationFilterFunc(key string, value string, allowUnset bool) func(interface{}) bool

type Base

+ StatsReporter StatsReporter

+ type Measurement int

type Options

+ Recorder record.EventRecorder

+ StatsReporter StatsReporter

+ type StatsReporter interface

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

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

Nov 7, 2018

Changes in this version

+ type Callback func(interface{})

+ func EnsureTypeMeta(f Callback, gvk schema.GroupVersionKind) Callback

Oct 30, 2018

Changes in this version

+ func GetK8sServiceFullname(name string, namespace string) string

+ func GetServingK8SServiceNameForObj(name string) string

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

+ type Base struct

+ CachingClientSet cachingclientset.Interface

+ ConfigMapWatcher configmap.Watcher

+ DynamicClientSet dynamic.Interface

+ KubeClientSet kubernetes.Interface

+ Logger *zap.SugaredLogger

+ Recorder record.EventRecorder

+ ServingClientSet clientset.Interface

+ SharedClientSet sharedclientset.Interface

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

+ type Options struct

+ CachingClientSet cachingclientset.Interface

+ ConfigMapWatcher configmap.Watcher

+ DynamicClientSet dynamic.Interface

+ KubeClientSet kubernetes.Interface

+ Logger *zap.SugaredLogger

+ ResyncPeriod time.Duration

+ ServingClientSet clientset.Interface

+ SharedClientSet sharedclientset.Interface

+ StopChannel <-chan struct{}

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