Versions in this module Expand all Collapse all v1 v1.4.5 Jun 23, 2022 v1.4.4 Jun 23, 2022 v1.4.3 Jun 22, 2022 Changes in this version + func EncodeHeaders(w io.Writer, headers Headers) error + type BoolValue bool + func (v BoolValue) Get() interface{} + func (v BoolValue) String() string + type BytesValue []byte + func (v BytesValue) Get() interface{} + func (v BytesValue) String() string + type ChecksumError struct + func (e ChecksumError) Error() string + type Decoder struct + func NewDecoder(optFns ...func(*DecoderOptions)) *Decoder + func (d *Decoder) Decode(reader io.Reader, payloadBuf []byte) (m Message, err error) + type DecoderOptions struct + LogMessages bool + Logger logging.Logger + type Encoder struct + func NewEncoder(optFns ...func(*EncoderOptions)) *Encoder + func (e *Encoder) Encode(w io.Writer, msg Message) (err error) + type EncoderOptions struct + LogMessages bool + Logger logging.Logger + type Header struct + Name string + Value Value + type Headers []Header + func (hs *Headers) Del(name string) + func (hs *Headers) Set(name string, value Value) + func (hs Headers) Clone() Headers + func (hs Headers) Get(name string) Value + type Int16Value int16 + func (v Int16Value) Get() interface{} + func (v Int16Value) String() string + type Int32Value int32 + func (v Int32Value) Get() interface{} + func (v Int32Value) String() string + type Int64Value int64 + func (v Int64Value) Get() interface{} + func (v Int64Value) String() string + type Int8Value int8 + func (v Int8Value) Get() interface{} + func (v Int8Value) String() string + type LengthError struct + Have int + Part string + Value interface{} + Want int + func (e LengthError) Error() string + type Message struct + Headers Headers + Payload []byte + func (m Message) Clone() Message + type StringValue string + func (v StringValue) Get() interface{} + func (v StringValue) String() string + type TimestampValue time.Time + func (v TimestampValue) Get() interface{} + func (v TimestampValue) MarshalJSON() ([]byte, error) + func (v TimestampValue) String() string + type UUIDValue [16]byte + func (v UUIDValue) Get() interface{} + func (v UUIDValue) String() string + type Value interface + Get func() interface{} + String func() string