sender

Documentation

Index

• type Option
  • func WithLogger(logger *zap.Logger) Option
  • func WithMaxMPS(mps int) Option
  • func WithMetrics(r metrics.Registerer) Option
  • func WithNumWorkers(n int) Option
• type Sender
  • func NewSender(p puller.Puller, pushClient pushclient.Client, ...) Sender

Types

type Option

type Option func(*options)

func WithLogger

func WithLogger(logger *zap.Logger) Option

func WithMaxMPS

func WithMaxMPS(mps int) Option

func WithMetrics

func WithMetrics(r metrics.Registerer) Option

func WithNumWorkers

func WithNumWorkers(n int) Option

type Sender

type Sender interface {
	Check(context.Context) health.Status
	Run() error
	Stop()
}

func NewSender

func NewSender(
	p puller.Puller,
	pushClient pushclient.Client,
	featureClient featureclient.Client,
	batchClient btclient.Client,
	opts ...Option) Sender