exec

type BranchStats ¶

type BranchStats struct {
	Size int64 `zed:"size"`
	// XXX (nibs) - This shouldn't be a span because keys don't have to be time.
	Span *nano.Span `zed:"span"`
}

func GetBranchStats(ctx context.Context, b *lake.Branch, snap commits.View) (info BranchStats, err error)

type DeleteQuery ¶ added in v1.13.0

type DeleteQuery struct {
	*Query
	// contains filtered or unexported fields
}

func NewDeleteQuery(rctx *runtime.Context, puller zbuf.Puller, deletes *sync.Map) *DeleteQuery

func (d *DeleteQuery) DeletionSet() []ksuid.KSUID

type PoolStats ¶

type PoolStats struct {
	Size int64 `zed:"size"`
	// XXX (nibs) - This shouldn't be a span because keys don't have to be time.
	Span *nano.Span `zed:"span"`
}

XXX for backward compat keep this for now, and return branchstats for pool/main

func GetPoolStats(ctx context.Context, p *lake.Pool, snap commits.View) (info PoolStats, err error)

type Query ¶ added in v1.13.0

type Query struct {
	zbuf.Puller
	// contains filtered or unexported fields
}

Query runs a flowgraph as a zbuf.Puller and implements a Close() method that gracefully tears down the flowgraph. Its AsReader() and AsProgressReader() methods provide a convenient means to run a flowgraph as zio.Reader.

func NewQuery(rctx *runtime.Context, puller zbuf.Puller, meter zbuf.Meter) *Query

func (q *Query) AsReader() zio.Reader

func (q *Query) Close() error

func (q *Query) Meter() zbuf.Meter

func (q *Query) Progress() zbuf.Progress

func (q *Query) Pull(done bool) (zbuf.Batch, error)