lencode

package

v0.2.2 Latest Latest Go to latest Published: May 6, 2026 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Decoder struct {
	// contains filtered or unexported fields
}

func NewDecoder(r io.Reader, opts ...Option) *Decoder

func (d *Decoder) Decode() ([]byte, error)

Decode the next message from the io.Reader.

func (d *Decoder) DecodeInto(b []byte) error

Decode the next message into a provided byte slice. Use NextLen() to ensure the slice is large enough for the message.

func (d *Decoder) NextLen() (int, error)

Return the length of the next message

type Encoder struct {
	// contains filtered or unexported fields
}

func NewEncoder(w io.Writer, opts ...Option) *Encoder

func (e *Encoder) Encode(msg []byte) error

Encode a message to the underlying writer. It is not safe to call this method concurrently.

type Option struct {
	// contains filtered or unexported fields
}

func SeparatorOpt(s []byte) Option

Specify a record separator to use as an integrity check when decoding. This defaults to \x6c\x65\x6e\x63 ("lenc"). Set to nil to disable.