Documentation ¶ Index ¶ type Egress func New(c client, m <-chan *loggregator_v2.Envelope) *Egress func (e *Egress) Start() func() Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type Egress ¶ type Egress struct { // contains filtered or unexported fields } func New ¶ func New(c client, m <-chan *loggregator_v2.Envelope) *Egress New returns a new Egress. func (*Egress) Start ¶ func (e *Egress) Start() func() Start spins up a go routine that sends envelopes to Loggregator. It returns a shutdown function which blocks until all messages are drained. If a message fails to send it will reconnect to Loggregator and retry sending that message. Source Files ¶ View all Source files egress.go Click to show internal directories. Click to hide internal directories.