notification

Documentation

Index

• Variables
• func NewDomainEventInformer(environmentClient environmentclient.Client, sender sender.Sender, maxMPS int, ...) jobs.Job
• func NewExperimentRunningWatcher(environmentClient environmentclient.Client, ...) jobs.Job
• func NewFeatureStaleWatcher(environmentClient environmentclient.Client, featureClient featureclient.Client, ...) jobs.Job
• func NewMAUCountWatcher(environmentClient environmentclient.Client, eventCounterClient ecclient.Client, ...) jobs.Job
• type Option
  • func WithLogger(logger *zap.Logger) Option
  • func WithMetrics(r metrics.Registerer) Option

Variables

var (
	ErrUnknownSourceType = errors.New("batch-server: domain-event-informer unknown source type")
)

Functions

func NewDomainEventInformer

func NewDomainEventInformer(
	environmentClient environmentclient.Client,
	sender sender.Sender,
	maxMPS int,
	runningDurationPerBatch time.Duration,
	project string,
	domainSubscription string,
	domainTopic string,
	pullerNumGoroutines int,
	pullerMaxOutstandingMessages int,
	pullerMaxOutstandingBytes int,
	opts ...Option) jobs.Job

func NewExperimentRunningWatcher

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

func NewFeatureStaleWatcher

func NewFeatureStaleWatcher(
	environmentClient environmentclient.Client,
	featureClient featureclient.Client,
	sender sender.Sender,
	opts ...jobs.Option) jobs.Job

func NewMAUCountWatcher

func NewMAUCountWatcher(
	environmentClient environmentclient.Client,
	eventCounterClient ecclient.Client,
	sender sender.Sender,
	location *time.Location,
	opts ...jobs.Option) jobs.Job

Types

type Option

type Option func(*options)

func WithLogger

func WithLogger(logger *zap.Logger) Option

func WithMetrics

func WithMetrics(r metrics.Registerer) Option