job

Documentation

Index

• 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
  • func (w *ExperimentRunningWatcher) Run(ctx context.Context) (lastErr error)
• type Option
  • func WithLogger(logger *zap.Logger) Option
  • func WithMetrics(r metrics.Registerer) Option
  • func WithTimeout(t time.Duration) Option

Functions

func NewExperimentRunningWatcher

func NewExperimentRunningWatcher(
	environmentClient environmentclient.Client,
	experimentClient experimentclient.Client,
	sender sender.Sender,
	opts ...Option) job.Job

func NewFeatureWatcher

func NewFeatureWatcher(
	environmentClient environmentclient.Client,
	featureClient featureclient.Client,
	sender sender.Sender,
	opts ...Option) job.Job

func NewMAUCountWatcher

func NewMAUCountWatcher(
	environmentClient environmentclient.Client,
	eventCounterClient ecclient.Client,
	sender sender.Sender,
	opts ...Option) job.Job

Types

type ExperimentRunningWatcher

type ExperimentRunningWatcher struct {
	// contains filtered or unexported fields
}

func (*ExperimentRunningWatcher) Run

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

type Option

type Option func(*options)

func WithLogger

func WithLogger(logger *zap.Logger) Option

func WithMetrics

func WithMetrics(r metrics.Registerer) Option

func WithTimeout

func WithTimeout(t time.Duration) Option