Versions in this module Expand all Collapse all v1 v1.0.0 Mar 25, 2026 Changes in this version + type FrameConfig struct + BigEndian bool + Delimiter []byte + FixedSize int + LengthBytes int + LengthOffset int + Type FrameType + type FrameType int + const Delimited + const FixedLength + const LengthPrefixed + type Message struct + Err error + Fields map[string]any + Raw []byte + type StateMachine struct + Current string + Transitions map[string]map[string]string + func NewStateMachine(initial string) *StateMachine + func (sm *StateMachine) AddTransition(from, trigger, to string) + func (sm *StateMachine) Trigger(event string) (string, error) + type StreamDecoder struct + func NewStreamDecoder(r io.Reader, lib *protocol.Library, proto string, frame FrameConfig) *StreamDecoder + func (sd *StreamDecoder) Next() (*Message, error)
Go to main page