v1

Documentation

Index

• type ByteArrayWriter
• type EnvelopeWriter
• type EventUnmarshaller
  • func NewUnMarshaller(outputWriter EnvelopeWriter) *EventUnmarshaller
  • func (u *EventUnmarshaller) UnmarshallMessage(message []byte) (*events.Envelope, error)
  • func (u *EventUnmarshaller) Write(message []byte)
• type MetricClient
• type NetworkReader
  • func NewNetworkReader(address string, writer ByteArrayWriter, m MetricClient) (*NetworkReader, error)
  • func (nr *NetworkReader) StartReading()
  • func (nr *NetworkReader) StartWriting()
  • func (nr *NetworkReader) Stop()

Types

type ByteArrayWriter

type ByteArrayWriter interface {
	Write(message []byte)
}

type EnvelopeWriter

type EnvelopeWriter interface {
	Write(event *events.Envelope)
}

type EventUnmarshaller

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

An EventUnmarshaller is an self-instrumenting tool for converting Protocol Buffer-encoded dropsonde messages to Envelope instances.

func NewUnMarshaller

func NewUnMarshaller(outputWriter EnvelopeWriter) *EventUnmarshaller

func (*EventUnmarshaller) UnmarshallMessage

func (u *EventUnmarshaller) UnmarshallMessage(message []byte) (*events.Envelope, error)

func (*EventUnmarshaller) Write

func (u *EventUnmarshaller) Write(message []byte)

type MetricClient

type MetricClient interface {
	NewCounter(name string, opts ...metrics.MetricOption) metrics.Counter
}

type NetworkReader

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

func NewNetworkReader

func NewNetworkReader(
	address string,
	writer ByteArrayWriter,
	m MetricClient,
) (*NetworkReader, error)

func (*NetworkReader) StartReading

func (nr *NetworkReader) StartReading()

func (*NetworkReader) StartWriting

func (nr *NetworkReader) StartWriting()

func (*NetworkReader) Stop

func (nr *NetworkReader) Stop()