refnozzle

package module

v0.0.0-...-63430c4 Latest Latest Go to latest Published: Nov 3, 2017 License: Apache-2.0 Imports: 15 Imported by: 1

Details

This is a reference nozzle written in Go, which demonstrates how to consume from the Loggregator v2 API.

This section is empty.

This section is empty.

func NewClientMutualTLSConfig(
	certFile string,
	keyFile string,
	caCertFile string,
	serverName string,
) (*tls.Config, error)

NewClientMutualTLSConfig validates the provided key pair against a CA and returns a *tls.Config which permits any ExtKeyUsage.

type EnvelopeBufferReader interface {
	Read() *loggregator_v2.Envelope
}

type EnvelopeBufferWriter interface {
	Write(*loggregator_v2.Envelope)
}

type EnvelopeStream func() []*loggregator_v2.Envelope

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

func NewEnvelopeStreamConnector(
	addr string,
	c *tls.Config,
) *EnvelopeStreamConnector

func (c *EnvelopeStreamConnector) Stream(ctx context.Context, req *loggregator_v2.EgressBatchRequest) EnvelopeStream

type Event struct {
	Title string `json:"title"`
	Body  string `json:"body"`
}

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

func NewRepeater(
	buf EnvelopeBufferWriter,
	s EnvelopeStream,
) *Repeater

func (r *Repeater) Start()

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

func NewRingBuffer(size int, alerter diodes.Alerter) *RingBuffer

func (d *RingBuffer) Read() *loggregator_v2.Envelope

func (d *RingBuffer) Write(data *loggregator_v2.Envelope)

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

func NewWriter(buf EnvelopeBufferReader, addr string) *Writer

func (w *Writer) Start()

Path	Synopsis
cmd
nozzle