runtime

Documentation

Index

• func AsProgressReadCloser(q Query) zbuf.ProgressReadCloser
• func AsReader(q Query) zio.Reader
• type Compiler
• type Context
  • func DefaultContext() *Context
  • func NewContext(ctx context.Context, zctx *zed.Context) *Context
  • func (c *Context) Cancel()
  • func (c *Context) KeepAlive(arena *zed.Arena)
• type DeleteQuery
• type Query
  • func CompileLakeQuery(ctx context.Context, zctx *zed.Context, c Compiler, program ast.Seq, ...) (Query, error)
  • func CompileQuery(ctx context.Context, zctx *zed.Context, c Compiler, program ast.Seq, ...) (Query, error)

Functions

func AsProgressReadCloser

func AsProgressReadCloser(q Query) zbuf.ProgressReadCloser

func AsReader

func AsReader(q Query) zio.Reader

Types

type Compiler

type Compiler interface {
	NewQuery(*Context, ast.Seq, []zio.Reader) (Query, error)
	NewLakeQuery(*Context, ast.Seq, int, *lakeparse.Commitish) (Query, error)
	NewLakeDeleteQuery(*Context, ast.Seq, *lakeparse.Commitish) (DeleteQuery, error)
	Parse(string, ...string) (ast.Seq, *parser.SourceSet, error)
}

type Context

type Context struct {
	context.Context
	// WaitGroup is used to ensure that goroutines complete cleanup work
	// (e.g., removing temporary files) before Cancel returns.
	WaitGroup sync.WaitGroup
	Zctx      *zed.Context
	// contains filtered or unexported fields
}

Context provides states used by all procs to provide the outside context in which they are running.

func DefaultContext

func DefaultContext() *Context

func NewContext

func NewContext(ctx context.Context, zctx *zed.Context) *Context

func (*Context) Cancel

func (c *Context) Cancel()

Cancel cancels the context. Cancel must be called to ensure that operators complete cleanup work (e.g., removing temporary files).

func (*Context) KeepAlive

func (c *Context) KeepAlive(arena *zed.Arena)

KeepAlive ensures that arena is not freed before the context.

type DeleteQuery

type DeleteQuery interface {
	Query
	DeletionSet() []ksuid.KSUID
}

type Query

type Query interface {
	zbuf.Puller
	io.Closer
	Progress() zbuf.Progress
	Meter() zbuf.Meter
}

func CompileLakeQuery

func CompileLakeQuery(ctx context.Context, zctx *zed.Context, c Compiler, program ast.Seq, sset *parser.SourceSet, head *lakeparse.Commitish) (Query, error)

func CompileQuery

func CompileQuery(ctx context.Context, zctx *zed.Context, c Compiler, program ast.Seq, sset *parser.SourceSet, readers []zio.Reader) (Query, error)