dropsonde_unmarshaller

Documentation

Overview

Package dropsonde_unmarshaller provides a tool for unmarshalling Envelopes from Protocol Buffer messages.

Use

Instantiate a Marshaller and run it:

unmarshaller := dropsonde_unmarshaller.NewDropsondeUnMarshaller(logger)
inputChan :=  make(chan []byte) // or use a channel provided by some other source
outputChan := make(chan *events.Envelope)
go unmarshaller.Run(inputChan, outputChan)

The unmarshaller self-instruments, counting the number of messages processed and the number of errors. These can be accessed through the Emit function on the unmarshaller.

Index

• type DropsondeUnmarshaller
  • func NewDropsondeUnmarshaller(logger *gosteno.Logger) DropsondeUnmarshaller

Types

type DropsondeUnmarshaller

type DropsondeUnmarshaller interface {
	instrumentation.Instrumentable
	Run(inputChan <-chan []byte, outputChan chan<- *events.Envelope)
	UnmarshallMessage([]byte) (*events.Envelope, error)
}

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

func NewDropsondeUnmarshaller

func NewDropsondeUnmarshaller(logger *gosteno.Logger) DropsondeUnmarshaller

NewDropsondeUnmarshaller instantiates a DropsondeUnmarshaller and logs to the provided logger.