v1

package
v0.0.0-...-ba3aa93 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 15, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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, helpText 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()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL