sender

Documentation

Index

• func BuildEndpoints() (*client.Endpoints, error)
• type Sender
  • func NewSender(inputChan, outputChan chan *message.Message, destinations *client.Destinations) *Sender
  • func (s *Sender) Start()
  • func (s *Sender) Stop()

Functions

func BuildEndpoints

func BuildEndpoints() (*client.Endpoints, error)

BuildEndpoints returns the endpoints to send logs to.

Types

type Sender

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

Sender is responsible for sending logs to different destinations.

func NewSender

func NewSender(inputChan, outputChan chan *message.Message, destinations *client.Destinations) *Sender

NewSender returns an new sender.

func (*Sender) Start

func (s *Sender) Start()

Start starts the Sender

func (*Sender) Stop

func (s *Sender) Stop()

Stop stops the Sender, this call blocks until inputChan is flushed