Documentation
¶
Index ¶
- Variables
- func CompileAssignment(zctx *zed.Context, scope *Scope, node *dag.Assignment) (expr.Assignment, error)
- func CompileAssignments(dsts field.List, srcs field.List) (field.List, []expr.Evaluator)
- func CompileBufferFilter(e dag.Expr) (*expr.BufferFilter, error)
- func CompileExprs(zctx *zed.Context, scope *Scope, nodes []dag.Expr) ([]expr.Evaluator, error)
- func CompileFilter(zctx *zed.Context, scope *Scope, node dag.Expr) (expr.Filter, error)
- type Binder
- type Builder
- type Filter
- type Reader
- type Scope
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrJoinParents = errors.New("join requires two upstream parallel query paths")
Functions ¶
func CompileAssignment ¶
func CompileAssignment(zctx *zed.Context, scope *Scope, node *dag.Assignment) (expr.Assignment, error)
func CompileAssignments ¶
func CompileBufferFilter ¶
func CompileBufferFilter(e dag.Expr) (*expr.BufferFilter, error)
CompileBufferFilter tries to return a BufferFilter for e such that the BufferFilter's Eval method returns true for any byte slice containing the ZNG encoding of a record matching e. (It may also return true for some byte slices that do not match.) compileBufferFilter returns a nil pointer and nil error if it cannot construct a useful filter.
func CompileExprs ¶
Types ¶
type Binder ¶
XXX for now, Binder is just a map of identifiers to a specific zed.Value reference that the name refers to. This will be generalized later to handle all possible types of identifier bindings.
type Builder ¶
type Builder struct {
// contains filtered or unexported fields
}
func NewBuilder ¶
func NewBuilder(pctx *proc.Context, adaptor proc.DataAdaptor) *Builder
func (*Builder) Schedulers ¶
type Filter ¶
type Filter struct {
// contains filtered or unexported fields
}
func (*Filter) AsBufferFilter ¶
func (f *Filter) AsBufferFilter() (*expr.BufferFilter, error)
Click to show internal directories.
Click to hide internal directories.