egress

package

v0.0.0-...-d500c8a Latest Latest Go to latest Published: Jan 15, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

func ContextDone(ctx context.Context) bool

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

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

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

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

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

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

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

Path	Synopsis
syslog
v1
v1fakes Code generated by counterfeiter.	Code generated by counterfeiter.
v2
v2fakes Code generated by counterfeiter.	Code generated by counterfeiter.