filequeue

Nov 13, 2024

Changes in this version

+ func NewQueue(directory string, out func(ctx context.Context, dh types.DataHandle), ...) (types.FileStorage, error)

+ type Record struct

+ Data []byte

+ Meta map[string]string

+ func (z *Record) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Record) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *Record) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *Record) Msgsize() (s int)

+ func (z *Record) UnmarshalMsg(bts []byte) (o []byte, err error)