plan

Documentation

Index

• type CollectStage
  • func MakeCollectStage() *CollectStage
  • func (c *CollectStage) Add(entries []WrappedEntry)
  • func (c *CollectStage) Chain(s Stage)
  • func (c *CollectStage) Execute()
  • func (c *CollectStage) Finish()
  • func (c *CollectStage) Next() Stage
• type DataPipeline
• type FilterStage
  • func MakeFilterStage(node *ast.DataFunctionNode) *FilterStage
  • func (f *FilterStage) Add(entries []WrappedEntry)
  • func (f *FilterStage) Chain(next Stage)
  • func (f *FilterStage) Execute()
  • func (f *FilterStage) Finish()
  • func (f *FilterStage) Next() Stage
• type Function
  • func MakeFunction(symbols SymbolMap) Function
  • func (f *Function) Visit(node ast.ASTNode) ast.Visitor
• type MapStage
  • func MakeMapStage(node *ast.DataFunctionNode) *MapStage
  • func (m *MapStage) Add(entries []WrappedEntry)
  • func (m *MapStage) Chain(next Stage)
  • func (m *MapStage) Execute()
  • func (m *MapStage) Finish()
  • func (m *MapStage) Next() Stage
• type MetaDataFilterBuilder
  • func (m *MetaDataFilterBuilder) Visit(node ast.ASTNode) ast.Visitor
• type Pipeline
  • func MakePipelineFromNode(node *ast.DataPipelineNode) Pipeline
  • func (p *Pipeline) Add(s Stage)
  • func (p *Pipeline) Execute(entries database.Entries) database.Entries
  • func (p *Pipeline) Finalize()
• type ReduceStage
  • func MakeReduceStage(node *ast.DataFunctionNode) *ReduceStage
  • func (r *ReduceStage) Add(entries []WrappedEntry)
  • func (r *ReduceStage) Chain(next Stage)
  • func (r *ReduceStage) Execute()
  • func (r *ReduceStage) Finish()
  • func (r *ReduceStage) Next() Stage
• type Stage
• type SymbolMap
• type WrappedEntry
  • func Wrap(entry database.Entry) WrappedEntry
  • func (w *WrappedEntry) Copy(v types.Value) WrappedEntry
  • func (w *WrappedEntry) Entry() database.Entry
  • func (w *WrappedEntry) SetTopic(t string)
  • func (w *WrappedEntry) Value() types.Value

Types

type CollectStage

type CollectStage struct {
	Output chan WrappedEntry
	// contains filtered or unexported fields
}

func MakeCollectStage

func MakeCollectStage() *CollectStage

func (*CollectStage) Add

func (c *CollectStage) Add(entries []WrappedEntry)

func (*CollectStage) Chain

func (c *CollectStage) Chain(s Stage)

func (*CollectStage) Execute

func (c *CollectStage) Execute()

func (*CollectStage) Finish

func (c *CollectStage) Finish()

func (*CollectStage) Next

func (c *CollectStage) Next() Stage

type DataPipeline

type DataPipeline interface {
	Execute(entries database.Entries) database.Entries
}

type FilterStage

type FilterStage struct {
	// contains filtered or unexported fields
}

func MakeFilterStage

func MakeFilterStage(node *ast.DataFunctionNode) *FilterStage

func (*FilterStage) Add

func (f *FilterStage) Add(entries []WrappedEntry)

func (*FilterStage) Chain

func (f *FilterStage) Chain(next Stage)

func (*FilterStage) Execute

func (f *FilterStage) Execute()

func (*FilterStage) Finish

func (f *FilterStage) Finish()

func (*FilterStage) Next

func (f *FilterStage) Next() Stage

type Function

type Function struct {
	Result []types.Value
	// contains filtered or unexported fields
}

func MakeFunction

func MakeFunction(symbols SymbolMap) Function

func (*Function) Visit

func (f *Function) Visit(node ast.ASTNode) ast.Visitor

type MapStage

type MapStage struct {
	// contains filtered or unexported fields
}

func MakeMapStage

func MakeMapStage(node *ast.DataFunctionNode) *MapStage

func (*MapStage) Add

func (m *MapStage) Add(entries []WrappedEntry)

func (*MapStage) Chain

func (m *MapStage) Chain(next Stage)

func (*MapStage) Execute

func (m *MapStage) Execute()

func (*MapStage) Finish

func (m *MapStage) Finish()

func (*MapStage) Next

func (m *MapStage) Next() Stage

type MetaDataFilterBuilder

type MetaDataFilterBuilder struct {
	Filters database.Filters
	DB      *database.Database
}

func (*MetaDataFilterBuilder) Visit

func (m *MetaDataFilterBuilder) Visit(node ast.ASTNode) ast.Visitor

type Pipeline

type Pipeline struct {
	// contains filtered or unexported fields
}

func MakePipelineFromNode

func MakePipelineFromNode(node *ast.DataPipelineNode) Pipeline

func (*Pipeline) Add

func (p *Pipeline) Add(s Stage)

func (*Pipeline) Execute

func (p *Pipeline) Execute(entries database.Entries) database.Entries

func (*Pipeline) Finalize

func (p *Pipeline) Finalize()

type ReduceStage

type ReduceStage struct {
	// contains filtered or unexported fields
}

func MakeReduceStage

func MakeReduceStage(node *ast.DataFunctionNode) *ReduceStage

func (*ReduceStage) Add

func (r *ReduceStage) Add(entries []WrappedEntry)

func (*ReduceStage) Chain

func (r *ReduceStage) Chain(next Stage)

func (*ReduceStage) Execute

func (r *ReduceStage) Execute()

func (*ReduceStage) Finish

func (r *ReduceStage) Finish()

func (*ReduceStage) Next

func (r *ReduceStage) Next() Stage

type Stage

type Stage interface {
	Chain(Stage)
	Next() Stage
	Add(entries []WrappedEntry)
	Finish()
	Execute()
}

type SymbolMap

type SymbolMap map[string]types.Value

type WrappedEntry

type WrappedEntry struct {
	// contains filtered or unexported fields
}

func Wrap

func Wrap(entry database.Entry) WrappedEntry

func (*WrappedEntry) Copy

func (w *WrappedEntry) Copy(v types.Value) WrappedEntry

func (*WrappedEntry) Entry

func (w *WrappedEntry) Entry() database.Entry

func (*WrappedEntry) SetTopic

func (w *WrappedEntry) SetTopic(t string)

func (*WrappedEntry) Value

func (w *WrappedEntry) Value() types.Value