egress

Documentation

Index

• func ContextDone(ctx context.Context) bool
• type DiodeWriter
  • func NewDiodeWriter(ctx context.Context, wc WriteCloser, alerter gendiodes.Alerter, wg WaitGroup) *DiodeWriter
  • func (d *DiodeWriter) Write(env *loggregator_v2.Envelope) error
• type WaitGroup
• type WriteCloser
• type Writer

Functions

func ContextDone

func ContextDone(ctx context.Context) bool

Types

type DiodeWriter

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

func NewDiodeWriter

func NewDiodeWriter(
	ctx context.Context,
	wc WriteCloser,
	alerter gendiodes.Alerter,
	wg WaitGroup,
) *DiodeWriter

func (*DiodeWriter) Write

func (d *DiodeWriter) Write(env *loggregator_v2.Envelope) error

Write writes an envelope into the diode. This can not fail.

type WaitGroup

type WaitGroup interface {
	Add(delta int)
	Done()
}

type WriteCloser

type WriteCloser interface {
	Write(*loggregator_v2.Envelope) error
	io.Closer
}

type Writer

type Writer interface {
	Write(*loggregator_v2.Envelope) error
}