runtime

package
v1.16.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 21, 2024 License: BSD-3-Clause Imports: 10 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AsProgressReadCloser added in v1.13.0

func AsProgressReadCloser(q Query) zbuf.ProgressReadCloser

func AsReader added in v1.13.0

func AsReader(q Query) zio.Reader

Types

type Compiler added in v1.2.0

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 added in v1.13.0

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 added in v1.13.0

func DefaultContext() *Context

func NewContext added in v1.13.0

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

func (*Context) Cancel added in v1.13.0

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 added in v1.16.0

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

KeepAlive ensures that arena is not freed before the context.

type DeleteQuery added in v1.3.0

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

type Query

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

func CompileLakeQuery added in v1.2.0

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

func CompileQuery added in v1.2.0

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

Directories

Path Synopsis
sam
op
op/combine
A combine proc merges multiple upstream inputs into one output.
A combine proc merges multiple upstream inputs into one output.
vam
op

Jump to

Keyboard shortcuts

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