Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

protocol

package

Go to main page

Versions in this module

v0

v0.9.4

Feb 28, 2025

v0.9.3

Mar 2, 2021

v0.9.2

Oct 13, 2019

Changes in this version

+ type Digest struct

+ Checksum string

+ MeterID uint32

+ MeterType uint8

+ MsgType string

+ func NewDigest(msg Message) Digest

type LogMessage

+ Type string

v0.9.1

Sep 21, 2018

v0.9.0

Sep 1, 2018

Changes in this version

+ const TimeFormat

+ func NextPowerOf2(v int) int

+ func RegisterParser(name string, parserFn NewParserFunc)

+ type Data struct

+ Bits string

+ Bytes []byte

+ Idx int

+ func NewData(data []byte) (d Data)

+ type Decoder struct

+ Cfg PacketConfig

+ Quantized []byte

+ Signal []float64

+ func NewDecoder() Decoder

+ func (d *Decoder) Allocate()

+ func (d *Decoder) RegisterProtocol(p Parser)

+ func (d *Decoder) Search(preamble []byte) []int

+ func (d Decoder) Decode(input []byte) chan Message

+ func (d Decoder) Filter(input []float64, output []byte)

+ func (d Decoder) Log()

+ func (d Decoder) Slice(indices []int) (pkts []Data)

+ type Demodulator interface

+ Execute func([]byte, []float64)

+ type FilterChain []MessageFilter

+ func (fc *FilterChain) Add(filter MessageFilter)

+ func (fc FilterChain) Match(msg Message) bool

+ type LogMessage struct

+ Length int

+ Offset int64

+ Time time.Time

+ func (msg LogMessage) Record() (r []string)

+ func (msg LogMessage) String() string

+ func (msg LogMessage) StringNoOffset() string

+ type MagLUT []float64

+ func NewMagLUT() (lut MagLUT)

+ func (lut MagLUT) Execute(input []byte, output []float64)

+ type Message interface

+ Checksum func() []byte

+ MeterID func() uint32

+ MeterType func() uint8

+ MsgType func() string

+ type MessageFilter interface

+ Filter func(Message) bool

+ type NewParserFunc func(symbolLength int) Parser

+ type PacketConfig struct

+ BlockSize int

+ BlockSize2 int

+ BufferLength int

+ CenterFreq uint32

+ ChipLength int

+ DataRate int

+ PacketLength int

+ PacketSymbols int

+ Preamble string

+ PreambleLength int

+ PreambleSymbols int

+ Protocol string

+ SampleRate int

+ SymbolLength int

+ type Parser interface

+ Cfg func() PacketConfig

+ Parse func([]Data, chan Message, *sync.WaitGroup)

+ SetDecoder func(*Decoder)

+ func NewParser(name string, symbolLength int) (Parser, error)