column

package

Go to main page

Versions in this module

v1

v1.2.0

Jul 14, 2022

v1.1.0

May 14, 2022

v1.0.0

Mar 26, 2022

Changes in this version

+ type ArrayReader struct

+ func NewArrayReader(inner zed.Type, in zed.Value, r io.ReaderAt) (*ArrayReader, error)

+ func (a *ArrayReader) Read(b *zcode.Builder) error

type ArrayWriter

+ func (a *ArrayWriter) EncodeMap(zctx *zed.Context, b *zcode.Builder) (zed.Type, error)

+ type FieldReader struct

+ func NewFieldReader(typ zed.Type, in zed.Value, r io.ReaderAt) (*FieldReader, error)

+ func (f *FieldReader) Read(b *zcode.Builder) error

type FieldWriter

+ func (f *FieldWriter) EncodeMap(zctx *zed.Context, b *zcode.Builder) (zed.Type, error)

+ type IntReader struct

+ func NewIntReader(val zed.Value, r io.ReaderAt) (*IntReader, error)

+ func (p *IntReader) Read() (int64, error)

+ type PresenceReader struct

+ func (p *PresenceReader) IsEmpty() bool

+ func (p *PresenceReader) Read() (bool, error)

type PresenceWriter

+ func (p *PresenceWriter) TouchNull()

+ type PrimitiveReader struct

+ func NewPrimitiveReader(in zed.Value, reader io.ReaderAt) (*PrimitiveReader, error)

+ func (p *PrimitiveReader) Read(b *zcode.Builder) error

type PrimitiveWriter

+ func (p *PrimitiveWriter) EncodeMap(zctx *zed.Context, b *zcode.Builder) (zed.Type, error)

+ type Reader interface

+ Read func(*zcode.Builder) error

+ func NewReader(typ zed.Type, in zed.Value, r io.ReaderAt) (Reader, error)

+ type RecordReader []FieldReader

+ func NewRecordReader(utyp zed.Type, in zed.Value, reader io.ReaderAt) (RecordReader, error)

+ func (r RecordReader) Lookup(typ *zed.TypeRecord, fields []string) (zed.Type, Reader, error)

+ func (r RecordReader) Read(b *zcode.Builder) error

type RecordWriter

+ func (r RecordWriter) EncodeMap(zctx *zed.Context, b *zcode.Builder) (zed.Type, error)

type Segment

+ func NewSegmap(in zed.Value) ([]Segment, error)

+ func NewSegment(zv zcode.Bytes) Segment

+ type UnionReader struct

+ func NewUnionReader(utyp zed.Type, in zed.Value, r io.ReaderAt) (*UnionReader, error)

+ func (u *UnionReader) Read(b *zcode.Builder) error

type UnionWriter

+ func (u *UnionWriter) EncodeMap(zctx *zed.Context, b *zcode.Builder) (zed.Type, error)

type Writer

+ EncodeMap func(*zed.Context, *zcode.Builder) (zed.Type, error)

v0

v0.34.0-test1

Feb 13, 2022

v0.33.0

Nov 17, 2021

v0.32.0

Nov 3, 2021

v0.31.0

Oct 4, 2021

Changes in this version

+ const MaxSegmentThresh

+ const SegmapTypeString

+ var ErrColumnMismatch = errors.New("zng record value doesn't match column writer")

+ var ErrCorruptSegment = errors.New("segmap value corrupt")

+ var ErrNonRecordAccess = errors.New("attempting to access a field in a non-record value")

+ func UnmarshalSegmap(in zed.Value, s *[]Segment) error

+ func UnmarshalSegment(zv zcode.Bytes, s *Segment) error

+ type Array struct

+ func (a *Array) Read(b *zcode.Builder) error

+ func (a *Array) UnmarshalZNG(inner zed.Type, in zed.Value, r io.ReaderAt) error

+ type ArrayWriter struct

+ func NewArrayWriter(inner zed.Type, spiller *Spiller) *ArrayWriter

+ func (a *ArrayWriter) Flush(eof bool) error

+ func (a *ArrayWriter) MarshalZNG(zctx *zed.Context, b *zcode.Builder) (zed.Type, error)

+ func (a *ArrayWriter) Write(body zcode.Bytes) error

+ type Field struct

+ func (f *Field) Read(b *zcode.Builder) error

+ func (f *Field) UnmarshalZNG(typ zed.Type, in zed.Value, r io.ReaderAt) error

+ type FieldWriter struct

+ func (f *FieldWriter) Flush(eof bool) error

+ func (f *FieldWriter) MarshalZNG(zctx *zed.Context, b *zcode.Builder) (zed.Type, error)

+ type Int struct

+ func (p *Int) Read() (int32, error)

+ type IntWriter struct

+ func NewIntWriter(spiller *Spiller) *IntWriter

+ func (p *IntWriter) Write(v int32) error

+ type Interface interface

+ Read func(*zcode.Builder) error

+ func Unmarshal(typ zed.Type, in zed.Value, r io.ReaderAt) (Interface, error)

+ type Presence struct

+ func NewPresence() *Presence

+ func (p *Presence) IsEmpty() bool

+ func (p *Presence) Read() (bool, error)

+ type PresenceWriter struct

+ func NewPresenceWriter(spiller *Spiller) *PresenceWriter

+ func (p *PresenceWriter) Finish()

+ func (p *PresenceWriter) TouchUnset()

+ func (p *PresenceWriter) TouchValue()

+ type Primitive struct

+ func (p *Primitive) Read(b *zcode.Builder) error

+ func (p *Primitive) UnmarshalZNG(in zed.Value, reader io.ReaderAt) error

+ type PrimitiveWriter struct

+ func NewPrimitiveWriter(spiller *Spiller) *PrimitiveWriter

+ func (p *PrimitiveWriter) Flush(eof bool) error

+ func (p *PrimitiveWriter) MarshalZNG(zctx *zed.Context, b *zcode.Builder) (zed.Type, error)

+ func (p *PrimitiveWriter) Write(body zcode.Bytes) error

+ type Record []*Field

+ func (r *Record) UnmarshalZNG(typ *zed.TypeRecord, in zed.Value, reader io.ReaderAt) error

+ func (r Record) Lookup(typ *zed.TypeRecord, fields []string) (zed.Type, Interface, error)

+ func (r Record) 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) MarshalZNG(zctx *zed.Context, b *zcode.Builder) (zed.Type, error)

+ func (r RecordWriter) Write(body zcode.Bytes) error

+ type Segment struct

+ Length int64

+ Offset int64

+ func (s Segment) NewSectionReader(r io.ReaderAt) io.Reader

+ 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

+ func (u *Union) Read(b *zcode.Builder) error

+ func (u *Union) UnmarshalZNG(typ *zed.TypeUnion, in zed.Value, r io.ReaderAt) error

+ type UnionWriter struct

+ func NewUnionWriter(typ *zed.TypeUnion, spiller *Spiller) *UnionWriter

+ func (u *UnionWriter) Flush(eof bool) error

+ func (u *UnionWriter) MarshalZNG(zctx *zed.Context, b *zcode.Builder) (zed.Type, error)

+ func (u *UnionWriter) Write(body zcode.Bytes) error

+ type Writer interface

+ Flush func(bool) error

+ MarshalZNG func(*zed.Context, *zcode.Builder) (zed.Type, error)

+ Write func(zcode.Bytes) error

+ func NewWriter(typ zed.Type, spiller *Spiller) Writer

v0.30.0

Sep 13, 2021

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL