Versions in this module Expand all Collapse all v0 v0.0.1 Apr 23, 2019 Changes in this version + const DefaultReapInterval + var LastProcessedResourceVersionGauge = prometheus.NewGauge(prometheus.GaugeOpts{ ... }) + var LastSeenResourceVersionGauge = prometheus.NewGauge(prometheus.GaugeOpts{ ... }) + var ProcessingErrorsCounter = prometheus.NewCounter(prometheus.CounterOpts{ ... }) + func New(ctx context.Context, kubeClient kubernetes.Interface, ...) *operator + func NewFromEnv(ctx context.Context, kubeClient kubernetes.Interface, ...) (*operator, error) + type OptionFunc func(*operator) + func WithBackupPolicy(b policy.BackupPolicy) OptionFunc + func WithFlusher(flusher flusher.Flusher) OptionFunc + func WithHTTPServerPort(port int) OptionFunc + func WithMetricsHandler(path string) OptionFunc + func WithPurger(purger purger.Purger) OptionFunc + func WithReadinessHandler(path string) OptionFunc + func WithReapInterval(interval time.Duration) OptionFunc + func WithReaper(reaper reaper.Reaper) OptionFunc + func WithStorer(s store.Storer) OptionFunc + func WithThreadiness(threadiness int) OptionFunc