Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
Controller provides a central location to manage all incoming queries. The controller is responsible for queueing, planning, and executing queries.
func New ¶
func New(c Config) *Controller
func (*Controller) Queries ¶
func (c *Controller) Queries() []*Query
Queries reports the active queries.
func (*Controller) Query ¶
Query submits a query for execution returning immediately. The spec must not be modified while the query is still active. Done must be called on any returned Query objects.
func (*Controller) QueryWithCompile ¶ added in v0.0.4
QueryWithCompile submits a query for execution returning immediately. The query will first be compiled before submitting for execution. Done must be called on any returned Query objects.
type PriorityQueue ¶
type PriorityQueue struct {
// contains filtered or unexported fields
}
func (*PriorityQueue) Peek ¶
func (p *PriorityQueue) Peek() *Query
func (*PriorityQueue) Pop ¶
func (p *PriorityQueue) Pop() *Query
func (*PriorityQueue) Push ¶
func (p *PriorityQueue) Push(q *Query)
type Query ¶
type Query struct {
Spec query.Spec
// Ready is a channel that will deliver the query results.
// The channel may be closed before any results arrive, in which case the query should be
// inspected for an error using Err().
Ready <-chan map[string]execute.Result
// contains filtered or unexported fields
}
Query represents a single request.
func (*Query) Cancel ¶
func (q *Query) Cancel()
Cancel will stop the query execution. Done must still be called to free resources.
Source Files
Click to show internal directories.
Click to hide internal directories.