dropsonde_marshaller

Documentation

Overview

Package dropsonde_marshaller provides a tool for marshalling Envelopes to Protocol Buffer messages.

Use

Instantiate a Marshaller and run it:

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

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

Index

• type DropsondeMarshaller
  • func NewDropsondeMarshaller(logger *gosteno.Logger) DropsondeMarshaller

Types

type DropsondeMarshaller

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

A DropsondeMarshaller is an self-instrumenting tool for converting dropsonde Envelopes to binary (Protocol Buffer) messages.

func NewDropsondeMarshaller

func NewDropsondeMarshaller(logger *gosteno.Logger) DropsondeMarshaller

NewDropsondeMarshaller instantiates a DropsondeMarshaller and logs to the provided logger.