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
Constants ¶
This section is empty.
Variables ¶
View Source
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
Types ¶
type Option ¶
type Option func(*options)
func WithLogger ¶
func WithMetrics ¶
func WithMetrics(r metrics.Registerer) Option
Click to show internal directories.
Click to hide internal directories.