job

Sep 28, 2022

Changes in this version

+ func NewExperimentRunningWatcher(environmentClient environmentclient.Client, ...) job.Job

+ func NewFeatureWatcher(environmentClient environmentclient.Client, featureClient featureclient.Client, ...) job.Job

+ func NewMAUCountWatcher(environmentClient environmentclient.Client, eventCounterClient ecclient.Client, ...) job.Job

+ type ExperimentRunningWatcher struct

+ func (w *ExperimentRunningWatcher) Run(ctx context.Context) (lastErr error)

+ type Option func(*options)

+ func WithLogger(logger *zap.Logger) Option

+ func WithMetrics(r metrics.Registerer) Option

+ func WithTimeout(t time.Duration) Option