Versions in this module Expand all Collapse all v1 v1.3.0 Nov 21, 2022 Changes in this version + const MaxSegmentThresh + var ErrVectorMismatch = errors.New("zng record value doesn't match vector writer") + var Template = []interface + type Array struct + Lengths []Segment + Values Metadata + func (a *Array) Type(zctx *zed.Context) zed.Type + type ArrayReader struct + func NewArrayReader(array *Array, r io.ReaderAt) (*ArrayReader, error) + func (a *ArrayReader) Read(b *zcode.Builder) error + type ArrayWriter struct + func NewArrayWriter(inner zed.Type, spiller *Spiller) *ArrayWriter + func (a *ArrayWriter) Flush(eof bool) error + func (a *ArrayWriter) Metadata() Metadata + func (a *ArrayWriter) Write(body zcode.Bytes) error + type Field struct + Name string + Values Metadata + type FieldReader struct + func NewFieldReader(field Field, r io.ReaderAt) (*FieldReader, error) + func (f *FieldReader) Read(b *zcode.Builder) error + type FieldWriter struct + func (f *FieldWriter) Flush(eof bool) error + func (f *FieldWriter) Metadata() Field + type Int64Reader struct + func NewInt64Reader(segmap []Segment, r io.ReaderAt) *Int64Reader + func (p *Int64Reader) Read() (int64, error) + type Int64Writer struct + func NewInt64Writer(spiller *Spiller) *Int64Writer + func (p *Int64Writer) Write(v int64) error + type Map struct + Keys Metadata + Lengths []Segment + Values Metadata + func (m *Map) Type(zctx *zed.Context) zed.Type + type MapReader struct + func NewMapReader(m *Map, r io.ReaderAt) (*MapReader, error) + func (m *MapReader) Read(b *zcode.Builder) error + type MapWriter struct + func NewMapWriter(typ *zed.TypeMap, spiller *Spiller) *MapWriter + func (m *MapWriter) Flush(eof bool) error + func (m *MapWriter) Metadata() Metadata + func (m *MapWriter) Write(body zcode.Bytes) error + type Metadata interface + Type func(*zed.Context) zed.Type + func Under(meta Metadata) Metadata + type Named struct + Name string + Values Metadata + func (n *Named) Type(zctx *zed.Context) zed.Type + type NamedWriter struct + func (n *NamedWriter) Metadata() Metadata + type Nulls struct + Runs []Segment + Values Metadata + func (n *Nulls) Type(zctx *zed.Context) zed.Type + type NullsReader struct + func NewNullsReader(vals Reader, segmap []Segment, r io.ReaderAt) *NullsReader + func (n *NullsReader) Read(b *zcode.Builder) error + type NullsWriter struct + func NewNullsWriter(values Writer, spiller *Spiller) *NullsWriter + func (n *NullsWriter) Flush(eof bool) error + func (n *NullsWriter) Metadata() Metadata + func (n *NullsWriter) Write(body zcode.Bytes) error + type Primitive struct + Segmap []Segment + Typ zed.Type + func (p *Primitive) Type(zctx *zed.Context) zed.Type + type PrimitiveReader struct + func NewPrimitiveReader(primitive *Primitive, reader io.ReaderAt) *PrimitiveReader + func (p *PrimitiveReader) Read(b *zcode.Builder) error + type PrimitiveWriter struct + func NewPrimitiveWriter(typ zed.Type, spiller *Spiller) *PrimitiveWriter + func (p *PrimitiveWriter) Flush(eof bool) error + func (p *PrimitiveWriter) Metadata() Metadata + func (p *PrimitiveWriter) Segmap() []Segment + func (p *PrimitiveWriter) Write(body zcode.Bytes) error + type Reader interface + Read func(*zcode.Builder) error + func NewReader(meta Metadata, r io.ReaderAt) (Reader, error) + type Record struct + Fields []Field + func (r *Record) Lookup(path field.Path) *Field + func (r *Record) LookupField(name string) *Field + func (r *Record) Type(zctx *zed.Context) zed.Type + type RecordReader []FieldReader + func NewRecordReader(record *Record, reader io.ReaderAt) (RecordReader, error) + func (r RecordReader) Read(b *zcode.Builder) error + type RecordWriter []*FieldWriter + func NewRecordWriter(typ *zed.TypeRecord, spiller *Spiller) RecordWriter + func (r RecordWriter) Flush(eof bool) error + func (r RecordWriter) Metadata() Metadata + func (r RecordWriter) Write(body zcode.Bytes) error + type Segment struct + Length int32 + Offset int64 + func (s Segment) NewSectionReader(r io.ReaderAt) io.Reader + type Set Array + func (s *Set) Type(zctx *zed.Context) zed.Type + type SetWriter struct + func NewSetWriter(inner zed.Type, spiller *Spiller) *SetWriter + func (s *SetWriter) Metadata() Metadata + type Spiller struct + Thresh int + func NewSpiller(w io.Writer, thresh int) *Spiller + func (s *Spiller) Position() int64 + func (s *Spiller) Write(segments []Segment, b zcode.Bytes) ([]Segment, error) + type Union struct + Tags []Segment + Values []Metadata + func (u *Union) Type(zctx *zed.Context) zed.Type + type UnionReader struct + func NewUnionReader(union *Union, r io.ReaderAt) (*UnionReader, error) + func (u *UnionReader) Read(b *zcode.Builder) error + type UnionWriter struct + func NewUnionWriter(typ *zed.TypeUnion, spiller *Spiller) *UnionWriter + func (u *UnionWriter) Flush(eof bool) error + func (u *UnionWriter) Metadata() Metadata + func (u *UnionWriter) Write(body zcode.Bytes) error + type Writer interface + Flush func(bool) error + Metadata func() Metadata + Write func(zcode.Bytes) error + func NewWriter(typ zed.Type, spiller *Spiller) Writer
Go to main page