Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  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

mavlink2

package module

Go to main page

Versions in this module

v0

v0.13.1

Jun 27, 2024

v0.13.0

Jan 29, 2021

Changes in this version

+ type FrameLogger interface

+ LogRead func(msg []byte) error

+ LogWritten func(msg []byte) error

type FrameStream

+ func NewFrameStreamWithLogger(rwc io.ReadWriteCloser, inputFrames chan Frame, dialects Dialects, ...) *FrameStream

+ func (s *FrameStream) GetCloseErr() error

v0.12.0

Sep 2, 2020

v0.11.0

Aug 31, 2020

v0.10.0

Aug 18, 2020

Changes in this version

+ const CompatibilityFlagSignature

+ const V1StartByte

+ const V2StartByte

+ var ErrDecodeV2MessageV1Frame = fmt.Errorf("Unable to decode a V2 message from a V1 Frame")

+ var ErrEncodeV2MessageV1Frame = fmt.Errorf("Unable to encode a V2 message to a V1 Frame")

+ var ErrFrameTooShort = fmt.Errorf("Not enough bytes in Frame")

+ var ErrInvalidChecksum = fmt.Errorf("Invalid checksum")

+ var ErrMessageTooLong = fmt.Errorf("Message too long")

+ var ErrMessageTooShort = fmt.Errorf("Message too short")

+ var ErrPrivateField = fmt.Errorf(...)

+ var ErrUnknownMessage = fmt.Errorf("Unknown message")

+ var ErrUnknownStartByte = fmt.Errorf("Start byte is not 0x%x (V1) or 0x%x (V2)", V1StartByte, V2StartByte)

+ var ErrUnsupportedVersion = fmt.Errorf("The version requested is not supported by this library")

+ var ErrUserClosed = errors.New("User closed")

+ var ErrValueTooLong = fmt.Errorf("The input string was too long and was truncated")

+ var ErrWriteChannelClosed = errors.New("Write channel closed")

+ type Dialect interface

+ GetMessage func(Frame) (Message, error)

+ GetMeta func(uint32) (MessageMeta, error)

+ type Dialects []Dialect

+ func (d Dialects) GetFrame(version int, senderSystemID, senderComponentID, messageSequence uint8, ...) (frame Frame, err error)

+ func (d Dialects) GetMessage(frame Frame) (message Message, err error)

+ func (d Dialects) Validate(frame Frame) error

+ type Frame interface

+ Bytes func() []byte

+ GetChecksum func() uint16

+ GetChecksumInput func() []byte

+ GetMessageBytes func() []byte

+ GetMessageID func() uint32

+ GetMessageLength func() uint8

+ GetMessageSequence func() uint8

+ GetSenderComponentID func() uint8

+ GetSenderSystemID func() uint8

+ GetVersion func() int

+ func FrameFromBytes(raw []byte, makeCopy bool) (frame Frame, err error)

+ type FrameParser func(Frame) (Message, error)

+ type FrameStream struct

+ func NewFrameStream(rwc io.ReadWriteCloser, inputFrames chan Frame, dialects Dialects) *FrameStream

+ func (s *FrameStream) Close()

+ func (s *FrameStream) Closed() <-chan struct{}

+ func (s *FrameStream) Read() <-chan Frame

+ func (s *FrameStream) ReadContext(ctx context.Context)

+ func (s *FrameStream) Write() chan<- Frame

+ func (s *FrameStream) WriteContext(ctx context.Context)

+ type FrameV1 []byte

+ func (frame FrameV1) Bytes() []byte

+ func (frame FrameV1) GetChecksum() uint16

+ func (frame FrameV1) GetChecksumInput() []byte

+ func (frame FrameV1) GetMessageBytes() []byte

+ func (frame FrameV1) GetMessageID() uint32

+ func (frame FrameV1) GetMessageLength() uint8

+ func (frame FrameV1) GetMessageSequence() uint8

+ func (frame FrameV1) GetSenderComponentID() uint8

+ func (frame FrameV1) GetSenderSystemID() uint8

+ func (frame FrameV1) GetVersion() int

+ func (frame FrameV1) String() string

+ type FrameV2 []byte

+ func (frame FrameV2) Bytes() []byte

+ func (frame FrameV2) GetChecksum() uint16

+ func (frame FrameV2) GetChecksumInput() []byte

+ func (frame FrameV2) GetCompatibilityFlags() uint8

+ func (frame FrameV2) GetIncompatibilityFlags() uint8

+ func (frame FrameV2) GetMessageBytes() []byte

+ func (frame FrameV2) GetMessageID() uint32

+ func (frame FrameV2) GetMessageLength() uint8

+ func (frame FrameV2) GetMessageSequence() uint8

+ func (frame FrameV2) GetSenderComponentID() uint8

+ func (frame FrameV2) GetSenderSystemID() uint8

+ func (frame FrameV2) GetSignature() []byte

+ func (frame FrameV2) GetVersion() int

+ func (frame FrameV2) String() string

+ type Message interface

+ GetDialect func() string

+ GetID func() uint32

+ GetMessageName func() string

+ GetVersion func() int

+ Read func(Frame) error

+ Write func(int) ([]byte, error)

+ type MessageMeta struct

+ CRCExtra byte

+ MaximumLength uint8

+ MinimumLength uint8

+ type UnknownMessage struct

+ ID uint32

+ Raw []byte

+ Version int

+ func (m *UnknownMessage) GetDialect() string

+ func (m *UnknownMessage) GetID() uint32

+ func (m *UnknownMessage) GetMessageName() string

+ func (m *UnknownMessage) GetVersion() int

+ func (m *UnknownMessage) Read(frame Frame) (err error)

+ func (m *UnknownMessage) String() string

+ func (m *UnknownMessage) Write(version int) ([]byte, error)

+ type X25CRC struct

+ func (hash *X25CRC) BlockSize() int

+ func (hash *X25CRC) Reset()

+ func (hash *X25CRC) Size() int

+ func (hash *X25CRC) Sum(b []byte) []byte

+ func (hash *X25CRC) Write(input []byte) (int, error)