zbuf

Jan 6, 2021

Changes in this version

+ type Warner interface

+ Warn func(msg string) error

Dec 14, 2020

Changes in this version

type Array

+ func ReadAll(r Reader) (arr Array, err error)

+ func (a *Array) Write(r *zng.Record) error

+ type Filter interface

+ AsBufferFilter func() (*filter.BufferFilter, error)

+ AsFilter func() (filter.Filter, error)

Dec 1, 2020

Changes in this version

+ var ScannerBatchSize = 100

+ func CloseReaders(readers []Reader) error

+ func NewCompareFn(mergeField field.Static, reversed bool) expr.CompareFn

+ type Merger struct

+ func MergeByTs(ctx context.Context, pullers []Puller, order Order) *Merger

+ func MergeReadersByTs(ctx context.Context, readers []Reader, order Order) (*Merger, error)

+ func NewMerger(ctx context.Context, pullers []Puller, cmp expr.CompareFn) *Merger

+ func (m *Merger) Cancel()

+ func (m *Merger) Pull() (Batch, error)

+ func (m *Merger) Read() (*zng.Record, error)

+ type MultiStats []Scanner

+ func (m MultiStats) Stats() *ScannerStats

type Puller

+ func ReadersToPullers(ctx context.Context, readers []Reader) ([]Puller, error)

type Reader

+ func MergeReadersByTsAsReader(ctx context.Context, readers []Reader, order Order) (Reader, error)

+ type Scanner interface

+ func NewScanner(ctx context.Context, r Reader, filterExpr ast.BooleanExpr, s nano.Span) (Scanner, error)

+ func ReadersToScanners(ctx context.Context, readers []Reader) ([]Scanner, error)

+ type ScannerAble interface

+ NewScanner func(ctx context.Context, filterExpr ast.BooleanExpr, s nano.Span) (Scanner, error)

+ type ScannerStats struct

+ BytesMatched int64

+ BytesRead int64

+ RecordsMatched int64

+ RecordsRead int64

+ func (s *ScannerStats) Accumulate(ss *ScannerStats)

+ type Statser interface

+ Stats func() *ScannerStats

Nov 9, 2020

Changes in this version

+ const OrderAsc

+ const OrderDesc

type Array

+ func (a *Array) Read() (*zng.Record, error)

+ func (a Array) NewReader() Reader

+ type Order bool

+ func (o Order) Int() int

+ func (o Order) String() string

Sep 25, 2020

Changes in this version

type Reader

+ func PullerReader(p Puller) Reader

Aug 28, 2020

Changes in this version

+ func CopyPuller(w Writer, p Puller) error

+ type Puller interface

+ Pull func() (Batch, error)

May 29, 2020

Changes in this version

+ const DirTimeForward

+ const DirTimeReverse

+ func CmpTimeForward(a, b *zng.Record) bool

+ func CmpTimeReverse(a, b *zng.Record) bool

+ type Direction bool

+ type RecordCmpFn func(a, b *zng.Record) bool

+ func RecordCompare(d Direction) RecordCmpFn

type Writer

+ func MultiWriter(writers ...Writer) Writer

May 5, 2020

Changes in this version

+ type Combiner struct

+ func NewCombiner(readers []Reader) *Combiner

+ func (c *Combiner) Close() error

+ func (c *Combiner) Read() (*zng.Record, error)

+ type Mapper struct

+ func NewMapper(reader Reader, zctx *resolver.Context) *Mapper

+ func (m *Mapper) Read() (*zng.Record, error)

Apr 25, 2020

Changes in this version

+ type File struct

+ func NewFile(r Reader, f *os.File) *File

+ func (r *File) Close() error

+ func (r *File) String() string

+ type WarningReader struct

+ func NewWarningReader(zr Reader, ch chan string) *WarningReader

+ func (w *WarningReader) Read() (*zng.Record, error)

Apr 17, 2020

Changes in this version

+ type Counter struct

+ func NewCounter(reader Reader, p *int64) *Counter

+ func (c *Counter) Read() (*zng.Record, error)

+ type ReadCloser interface

+ func NewReadCloser(r Reader, c io.Closer) ReadCloser

+ func NopReadCloser(r Reader) ReadCloser

Apr 13, 2020

Changes in this version

type Batch

+ func ReadBatch(zr Reader, n int) (Batch, error)

+ type Peeker struct

+ func NewPeeker(reader Reader) *Peeker

+ func (p *Peeker) Peek() (*zng.Record, error)

+ func (p *Peeker) Read() (*zng.Record, error)

Feb 11, 2020

Changes in this version

+ func Copy(dst WriteFlusher, src Reader) error

+ func CopyWithContext(ctx context.Context, dst WriteFlusher, src Reader) error

+ func NewRawAndTsFromZeekValues(typ *zng.TypeRecord, tsCol int, vals [][]byte) (zcode.Bytes, nano.Ts, error)

+ func NewRawFromZeekTSV(builder *zcode.Builder, typ *zng.TypeRecord, path []byte, data []byte) (zcode.Bytes, error)

+ func NewRecordZeekStrings(typ *zng.TypeRecord, ss ...string) (t *zng.Record, err error)

+ func ZeekStrings(r *zng.Record, precision int, fmt zng.OutFmt) ([]string, bool, error)

+ type Array struct

+ func NewArray(r []*zng.Record, s nano.Span) *Array

+ func (a *Array) Append(r *zng.Record)

+ func (a *Array) Index(k int) *zng.Record

+ func (a *Array) Length() int

+ func (a *Array) Records() []*zng.Record

+ func (a *Array) Ref()

+ func (a *Array) Span() nano.Span

+ func (a *Array) Unref()

+ type Batch interface

+ Index func(int) *zng.Record

+ Length func() int

+ Records func() []*zng.Record

+ Ref func()

+ Span func() nano.Span

+ Unref func()

+ type Reader interface

+ Read func() (*zng.Record, error)

+ type WriteCloser interface

+ type WriteFlusher interface

+ Flush func() error

+ func NopFlusher(w Writer) WriteFlusher

+ type Writer interface

+ Write func(*zng.Record) error