control

Apr 22, 2019

Changes in this version

type Config

+ QueueSize int

+ func (c *Config) Validate() error

Apr 17, 2019

Changes in this version

type Config

+ MemoryBytesQuotaPerQuery int64

type Query

+ func (q *Query) Results() <-chan flux.Result

Dec 17, 2018

Changes in this version

type Controller

+ func (c *Controller) CancelAll()

Nov 28, 2018

Changes in this version

type Controller

+ func (c *Controller) Shutdown(ctx context.Context) error

Nov 6, 2018

Changes in this version

+ func StartSpanFromContext(ctx context.Context, operationName string, hist prometheus.Observer, ...) (*span, context.Context)

+ type Config struct

+ ConcurrencyQuota int

+ ExecutorDependencies execute.Dependencies

+ LPlannerOptions []plan.LogicalOption

+ Logger *zap.Logger

+ MemoryBytesQuota int64

+ MetricLabelKeys []string

+ PPlannerOptions []plan.PhysicalOption

+ Verbose bool

+ type Controller struct

+ func New(c Config) *Controller

+ func (c *Controller) PrometheusCollectors() []prometheus.Collector

+ func (c *Controller) Queries() []*Query

+ func (c *Controller) Query(ctx context.Context, compiler flux.Compiler) (flux.Query, error)

+ type PriorityQueue struct

+ func (p *PriorityQueue) Peek() *Query

+ func (p *PriorityQueue) Pop() *Query

+ func (p *PriorityQueue) Push(q *Query)

+ type Query struct

+ func (q *Query) Cancel()

+ func (q *Query) Concurrency() int

+ func (q *Query) Done()

+ func (q *Query) Err() error

+ func (q *Query) ID() QueryID

+ func (q *Query) Ready() <-chan map[string]flux.Result

+ func (q *Query) Spec() *flux.Spec

+ func (q *Query) State() State

+ func (q *Query) Statistics() flux.Statistics

+ type QueryID uint64

+ type State int

+ const Canceled

+ const Compiling

+ const Created

+ const Errored

+ const Executing

+ const Finished

+ const Planning

+ const Queueing

+ const Requeueing

+ func (s State) String() string

+ type Stringer interface

+ String func() string