Versions in this module Expand all Collapse all v0 v0.1.1 Sep 20, 2025 v0.1.0 Sep 4, 2025 Changes in this version + var ObjectKey = toolscache.MetaObjectToName + type ErrAggregation = error + func NewAggregationError(err error) ErrAggregation + type ErrInvalidObject = error + func NewInvalidObjectError(message string) ErrInvalidObject + type ErrJoin = error + func NewJoinError(err error) ErrJoin + type ErrPipeline = error + func NewPipelineError(err error) ErrPipeline + type Evaluator interface + Evaluate func(object.Delta) ([]object.Delta, error) + func New(operator string, target string, sources []schema.GroupVersionKind, ...) (Evaluator, error) + type GatherOp struct + func (eval *GatherOp) String() string + func (eval *GatherOp) Transform(doc dbsp.Document, v any) (dbsp.Document, error) + type JoinOp struct + func (eval *JoinOp) Evaluate(doc dbsp.Document) ([]dbsp.Document, error) + func (eval *JoinOp) String() string + type Pipeline struct + func (p *Pipeline) ConvertDeltaToZSet(delta object.Delta) (*dbsp.DocumentZSet, error) + func (p *Pipeline) ConvertZSetToDelta(zset *dbsp.DocumentZSet, view string) ([]object.Delta, error) + func (p *Pipeline) Evaluate(delta object.Delta) ([]object.Delta, error) + func (p *Pipeline) NewGatherOp(e *expression.Expression) (dbsp.Operator, error) + func (p *Pipeline) NewJoinOp(e *expression.Expression, sources []schema.GroupVersionKind) dbsp.Operator + func (p *Pipeline) NewProjectionOp(e *expression.Expression) dbsp.Operator + func (p *Pipeline) NewSelectionOp(e *expression.Expression) dbsp.Operator + func (p *Pipeline) NewUnwindOp(e *expression.Expression) (dbsp.Operator, error) + func (p *Pipeline) Reconcile(ds []object.Delta) ([]object.Delta, error) + func (p *Pipeline) String() string + type ProjectionOp struct + func (eval *ProjectionOp) Evaluate(doc dbsp.Document) ([]dbsp.Document, error) + func (eval *ProjectionOp) String() string + type SelectionOp struct + func (eval *SelectionOp) Evaluate(doc dbsp.Document) ([]dbsp.Document, error) + func (eval *SelectionOp) String() string + type UnwindOp struct + func (eval *UnwindOp) Extract(doc dbsp.Document) (any, error) + func (eval *UnwindOp) String() string + func (eval *UnwindOp) Transform(doc dbsp.Document, v any) (dbsp.Document, error)
Go to main page