Versions in this module Expand all Collapse all v0 v0.1.0 Feb 19, 2025 Changes in this version + var ErrInvalidExtByte = errors.New("invalid extension byte") + var ErrInvalidFormat = errors.New("invalid MessagePack format") + var ErrInvalidHeaderByte = errors.New("invalid header byte") + var ErrInvalidOffset = errors.New("offset must be greater than 0") + var ErrReachedMaxBufferSize = errors.New("reached max buffer size") + var ErrShortBuffer = io.ErrShortBuffer + func AppendAny(dst []byte, v any) []byte + func AppendArrayHeader(dst []byte, n int) []byte + func AppendBinary(dst []byte, data []byte) []byte + func AppendBinaryAppender(dst []byte, s internal.BinaryAppender) []byte + func AppendBinaryUnknownLength(dst []byte, fn func(dst []byte) []byte) []byte + func AppendBool(dst []byte, b bool) []byte + func AppendFloat(dst []byte, f float64) []byte + func AppendInt(buf []byte, value int64) []byte + func AppendMapHeader(dst []byte, n int) []byte + func AppendNil(dst []byte) []byte + func AppendString(dst []byte, s string) []byte + func AppendStringDynamic(dst []byte, fn func(dst []byte) []byte) []byte + func AppendStringMax255(dst []byte, fn func(dst []byte) []byte) []byte + func AppendStringUnknownLength(dst []byte, fn func(dst []byte) []byte) []byte + func AppendTextAppender(dst []byte, s internal.TextAppender) []byte + func AppendTimestamp(dst []byte, t time.Time, format ...TsFormat) []byte + func AppendUint(buf []byte, value uint64) []byte + func ReadArrayHeader(src []byte, offset int) (length int, newOffset int, err error) + func ReadBinary(src []byte, offset int) (data []byte, newOffset int, err error) + func ReadBool(src []byte, offset int) (value bool, newOffset int, err error) + func ReadFloat(src []byte, offset int) (value float64, newOffset int, err error) + func ReadInt(src []byte, offset int) (value int64, newOffset int, err error) + func ReadMapHeader(src []byte, offset int) (length int, newOffset int, err error) + func ReadNil(src []byte, offset int) (newOffset int, err error) + func ReadString(src []byte, offset int) (s string, newOffset int, err error) + func ReadStringCopy(src []byte, offset int) (s string, newOffset int, err error) + func ReadTimestamp(src []byte, offset int) (t time.Time, newOffset int, err error) + func ReadUint(src []byte, offset int) (value uint64, newOffset int, err error) + type Float interface + type IterPool struct + BufMaxSize int + func (p *IterPool) Get(r io.Reader) (iter *Iterator) + func (p *IterPool) Put(iter *Iterator) + type Iterator struct + func NewIterator(r io.Reader, maxBufSize ...int) Iterator + func (iter *Iterator) Any() any + func (iter *Iterator) Bin() []byte + func (iter *Iterator) Bool() bool + func (iter *Iterator) Error() error + func (iter *Iterator) Float() float64 + func (iter *Iterator) Int() int64 + func (iter *Iterator) Items() int + func (iter *Iterator) Len() int + func (iter *Iterator) LockBuffer() bool + func (iter *Iterator) Next() bool + func (iter *Iterator) NextExpectedType(expected ...types.Type) (err error) + func (iter *Iterator) Reader() *bufio.LimitedReader + func (iter *Iterator) Reset(r io.Reader, maxBufSize ...int) + func (iter *Iterator) ResetBytes(b []byte, maxBufSize ...int) + func (iter *Iterator) Skip() + func (iter *Iterator) Str() string + func (iter *Iterator) Time() time.Time + func (iter *Iterator) Type() types.Type + func (iter *Iterator) Uint() uint64 + func (iter *Iterator) UnlockBuffer() bool + func (r *Iterator) TotalRead() int + type Numeric interface + type Signed interface + type TsFormat uint8 + const Ts32 + const Ts64 + const Ts96 + const TsAuto + const TsFluentd + const TsInt + func (f TsFormat) String() string + type Unsigned interface + type Value []byte + func (v Value) AppendBinary(b []byte) ([]byte, error) + func (v Value) AppendJson(b []byte) ([]byte, error) + func (v Value) AppendText(b []byte) ([]byte, error) + func (v Value) Array() iter.Seq[Value] + func (v Value) Bin() (val []byte) + func (v Value) Bool() (val bool) + func (v Value) BytesLen() (l int) + func (v Value) Float() (val float64) + func (v Value) Int() (val int64) + func (v Value) IsZero() bool + func (v Value) Len() (l int) + func (v Value) Map() iter.Seq2[Value, Value] + func (v Value) Str() (val string) + func (v Value) StrCopy() (val string) + func (v Value) String() string + func (v Value) Timestamp() (val time.Time) + func (v Value) Type() (t types.Type) + func (v Value) Uint() (val uint64) + type Writer struct + func NewWriter(w io.Writer, buf *buffer.Buffer) Writer + func (w *Writer) Reset(writer io.Writer) + func (w Writer) Bytes() []byte + func (w Writer) Flush() (err error) + func (w Writer) Write(p []byte) (int, error) + func (w Writer) WriteArrayHeader(n int) + func (w Writer) WriteBinary(data []byte) + func (w Writer) WriteBinaryReader(size int, r io.Reader) (err error) + func (w Writer) WriteBool(b bool) + func (w Writer) WriteCustom(fn func([]byte) []byte) + func (w Writer) WriteFloat(f float64) + func (w Writer) WriteInt(i int64) + func (w Writer) WriteMapHeader(n int) + func (w Writer) WriteNil() + func (w Writer) WriteString(s string) + func (w Writer) WriteStringMax255(fn func(dst []byte) []byte) + func (w Writer) WriteTimestamp(t time.Time, format ...TsFormat) + func (w Writer) WriteTo(wr io.Writer) (int64, error) + func (w Writer) WriteUint(i uint64)
Go to main page