Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

executor

package

Go to main page

Versions in this module

v0

v0.3.0

Jul 16, 2018

Changes in this version

type Engine

+ func (e *Engine) ExecuteExpr(ctx context.Context, parser parser.Parser, opts *EngineOptions, ...)

+ type Query struct

+ Err error

+ Result Result

type Result

+ ResultChan func() chan ResultChan

+ type ResultChan struct

+ Block block.Block

+ Err error

type ResultNode

+ func (r *ResultNode) ResultChan() chan ResultChan

v0.2.0

May 26, 2018

v0.1.0

May 24, 2018

Changes in this version

+ const DefaultQueryTimeout

+ func CreateSource(ID parser.NodeID, params SourceParams, storage storage.Storage, ...) (parser.Source, *transform.Controller)

+ func CreateTransform(ID parser.NodeID, params TransformParams) (transform.OpNode, *transform.Controller)

+ type Engine struct

+ Stats *QueryStatistics

+ func NewEngine(store storage.Storage) *Engine

+ func (e *Engine) Close() error

+ func (e *Engine) Execute(ctx context.Context, query *storage.FetchQuery, opts *EngineOptions, ...)

+ type EngineOptions struct

+ AbortCh <-chan bool

+ type ExecutionState struct

+ func GenerateExecutionState(pplan plan.PhysicalPlan, storage storage.Storage) (*ExecutionState, error)

+ func (s *ExecutionState) Execute(ctx context.Context) error

+ func (s *ExecutionState) String() string

+ type QueryStatistics struct

+ ActiveQueries int64

+ ExecutedQueries int64

+ FinishedQueries int64

+ QueryExecutionDuration int64

+ type QueryTask struct

+ type Result interface

+ type ResultNode struct

+ func (r ResultNode) Process(ID parser.NodeID, block storage.Block) error

+ type SourceParams interface

+ Node func(controller *transform.Controller, storage storage.Storage, ...) parser.Source

+ type TaskStatus int

+ const KilledTask

+ const RunningTask

+ func (t TaskStatus) String() string

+ type Tracker struct

+ LogQueriesAfter time.Duration

+ MaxConcurrentQueries int

+ func NewTracker() *Tracker

+ func (t *Tracker) Close() error

+ func (t *Tracker) DetachQuery(qid uint64) error

+ func (t *Tracker) KillQuery(qid uint64) error

+ func (t *Tracker) Track(query storage.Query, connClosed <-chan bool) (*QueryTask, error)

+ type TransformParams interface

+ Node func(controller *transform.Controller) transform.OpNode