sender

Sep 28, 2022

Changes in this version

+ type Option func(*options)

+ func WithLogger(logger *zap.Logger) Option

+ func WithMaxMPS(mps int) Option

+ func WithMetrics(r metrics.Registerer) Option

+ func WithNumWorkers(n int) Option

+ type Sender interface

+ Check func(context.Context) health.Status

+ Run func() error

+ Stop func()

+ func NewSender(p puller.Puller, pushClient pushclient.Client, ...) Sender