sender

Documentation

Index

• type Sender
  • func New(config *config.Config, msgChan <-chan string) *Sender
  • func (s *Sender) ErrChan() <-chan error
  • func (s *Sender) Exit() <-chan struct{}
  • func (s *Sender) Run(ctx context.Context)

Types

type Sender

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

func New

func New(config *config.Config, msgChan <-chan string) *Sender

func (*Sender) ErrChan

func (s *Sender) ErrChan() <-chan error

func (*Sender) Exit

func (s *Sender) Exit() <-chan struct{}

func (*Sender) Run

func (s *Sender) Run(ctx context.Context)