Versions in this module Expand all Collapse all v0 v0.3.2 Oct 18, 2023 v0.3.1 Oct 18, 2023 v0.3.0 Oct 18, 2023 v0.2.0 Oct 15, 2023 v0.1.0 Oct 15, 2023 Changes in this version + const DefaultBufferSize + var ErrInsufficientData = errors.New("insufficient data") + var ErrMessageSizeExceeded = MessageSizeExceeded + var ErrMissingNulTerminator = errors.New("NUL terminator not found") + func NewInsufficientData(length int) error + func NewMessageSizeExceeded(max, size int) error + func NewMissingNulTerminator() error + type MessageSizeExceeded struct + Max int + Message string + Size int + func UnwrapMessageSizeExceeded(err error) (result MessageSizeExceeded, _ bool) + func (err MessageSizeExceeded) Error() string + func (err MessageSizeExceeded) Is(target error) bool + type Reader struct + Buffer io.Reader + MaxMessageSize int + Msg []byte + func NewReader(logger *slog.Logger, reader io.Reader, bufferSize int) *Reader + func (reader *Reader) ReadTypedMsg() (types.ClientMessage, int, error) + func (reader *Reader) ReadUntypedMsg() (int, error) + func (reader *Reader) Slurp(size int) error
Go to main page