zng21io

Mar 26, 2022

Changes in this version

+ const MaxSize

+ const ReadSize

+ const TypeLimit

+ var ErrNotContainer = errors.New("not a container")

+ var ErrNotSingleton = errors.New("not a single container")

+ var ErrTrunc = errors.New("truncated type value convert zng21 to zng")

+ func AppendUvarint(dst []byte, u64 uint64) []byte

+ type AppMessage struct

+ Bytes []byte

+ Code int

+ Encoding int

+ type Bytes []byte

+ func AppendAs(dst Bytes, container bool, val []byte) Bytes

+ func AppendContainer(dst Bytes, val Bytes) Bytes

+ func AppendNull(dst Bytes) Bytes

+ func AppendPrimitive(dst Bytes, val []byte) Bytes

+ func (b Bytes) Body() (Bytes, error)

+ func (b Bytes) ContainerBody() (Bytes, error)

+ func (b Bytes) Iter() Iter

+ type Iter Bytes

+ func (i *Iter) Done() bool

+ func (i *Iter) Next() (Bytes, bool)

+ func (i *Iter) NextTagAndBody() (Bytes, bool)

+ type Reader struct

+ func NewReader(reader io.Reader, sctx *zed.Context) *Reader

+ func NewReaderWithOpts(reader io.Reader, sctx *zed.Context, opts zngio.ReaderOpts) *Reader

+ func (r *Reader) Read() (*zed.Value, error)

+ func (r *Reader) ReadByte() (byte, error)

+ func (r *Reader) ReadPayload() (*zed21.Value, *AppMessage, error)