sender

Documentation

Index

• type Sender
  • func New(store store.Store, metricsAccountant metricsaccountant.MetricsAccountant, ...) *Sender
  • func (sender *Sender) Send(timeProvider timeprovider.TimeProvider) error

Types

type Sender

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

func New

func New(store store.Store, metricsAccountant metricsaccountant.MetricsAccountant, conf *config.Config, messageBus yagnats.NATSConn, logger logger.Logger) *Sender

func (*Sender) Send

func (sender *Sender) Send(timeProvider timeprovider.TimeProvider) error