Documentation ¶
Index ¶
- type IntermediateMetricContext
- func (ctx *IntermediateMetricContext) Complete(err error)
- func (ctx *IntermediateMetricContext) Context() context.Context
- func (ctx *IntermediateMetricContext) GetRequests() map[string]*protoCommonV1.TaskRequest
- func (ctx *IntermediateMetricContext) MakePlan() error
- func (ctx *IntermediateMetricContext) SendRequest(targetNodeID string, req *protoCommonV1.TaskRequest) error
- func (ctx *IntermediateMetricContext) SetTracker(stageTracker *tracker.StageTracker)
- func (ctx *IntermediateMetricContext) WaitResponse() (any, error)
- type LeafExecuteContext
- type LeafGroupingContext
- type LeafMetadataContext
- type LeafReduceContext
- type MetadataContext
- func (ctx *MetadataContext) Complete(err error)
- func (ctx *MetadataContext) Context() context.Context
- func (ctx *MetadataContext) GetRequests() map[string]*protoCommonV1.TaskRequest
- func (ctx *MetadataContext) HandleResponse(resp *protoCommonV1.TaskResponse, fromNode string)
- func (ctx *MetadataContext) MakePlan() error
- func (ctx *MetadataContext) SendRequest(targetNodeID string, req *protoCommonV1.TaskRequest) error
- func (ctx *MetadataContext) SetTracker(stageTracker *tracker.StageTracker)
- func (ctx *MetadataContext) WaitResponse() (any, error)
- type MetadataDeps
- type MetricContext
- func (ctx *MetricContext) Complete(err error)
- func (ctx *MetricContext) Context() context.Context
- func (ctx *MetricContext) GetRequests() map[string]*protoCommonV1.TaskRequest
- func (ctx *MetricContext) HandleResponse(resp *protoCommonV1.TaskResponse, fromNode string)
- func (ctx *MetricContext) SendRequest(targetNodeID string, req *protoCommonV1.TaskRequest) error
- func (ctx *MetricContext) SetTracker(stageTracker *tracker.StageTracker)
- type RootMetricContext
- func (ctx *RootMetricContext) Complete(err error)
- func (ctx *RootMetricContext) Context() context.Context
- func (ctx *RootMetricContext) GetRequests() map[string]*protoCommonV1.TaskRequest
- func (ctx *RootMetricContext) MakePlan() error
- func (ctx *RootMetricContext) SendRequest(targetNodeID string, req *protoCommonV1.TaskRequest) error
- func (ctx *RootMetricContext) SetTracker(stageTracker *tracker.StageTracker)
- func (ctx *RootMetricContext) WaitResponse() (any, error)
- type RootMetricContextDeps
- type TaskContext
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type IntermediateMetricContext ¶ added in v0.2.4
type IntermediateMetricContext struct { MetricContext // contains filtered or unexported fields }
IntermediateMetricContext represents intermediate metric data search context.
func NewIntermediateMetricContext ¶ added in v0.2.4
func NewIntermediateMetricContext(ctx context.Context, transportMgr rpc.TransportManager, stateMgr broker.StateManager, req *protoCommonV1.TaskRequest, curNode models.StatelessNode, physicalPlan *models.PhysicalPlan, statement *stmt.Query, receivers []string, ) *IntermediateMetricContext
NewIntermediateMetricContext creates intermediate metric data search context.
func (*IntermediateMetricContext) Complete ¶ added in v0.2.4
func (ctx *IntermediateMetricContext) Complete(err error)
Complete completes the task with error(if execute failure).
func (*IntermediateMetricContext) GetRequests ¶ added in v0.2.4
func (ctx *IntermediateMetricContext) GetRequests() map[string]*protoCommonV1.TaskRequest
GetRequests returns the request list which send to target node.
func (*IntermediateMetricContext) MakePlan ¶ added in v0.2.4
func (ctx *IntermediateMetricContext) MakePlan() error
MakePlan makes the metric data physical plan.
func (*IntermediateMetricContext) SendRequest ¶ added in v0.2.4
func (ctx *IntermediateMetricContext) SendRequest(targetNodeID string, req *protoCommonV1.TaskRequest) error
SendRequest sends the task request to target node.
func (*IntermediateMetricContext) SetTracker ¶ added in v0.2.4
func (ctx *IntermediateMetricContext) SetTracker(stageTracker *tracker.StageTracker)
SetTracker sets stage tracker.
func (*IntermediateMetricContext) WaitResponse ¶ added in v0.2.4
func (ctx *IntermediateMetricContext) WaitResponse() (any, error)
WaitResponse waits the task completed, then returns the result set.
type LeafExecuteContext ¶
type LeafExecuteContext struct { TaskCtx *flow.TaskContext Tracker *trackerpkg.StageTracker LeafNode *models.Target Receivers []string StorageExecuteCtx *flow.StorageExecuteContext Database tsdb.Database ServerFactory rpc.TaskServerFactory Req *protoCommonV1.TaskRequest GroupingCtx *LeafGroupingContext ReduceCtx *LeafReduceContext // contains filtered or unexported fields }
LeafExecuteContext represents leaf node execution context.
func NewLeafExecuteContext ¶
func NewLeafExecuteContext(taskCtx *flow.TaskContext, tracker *trackerpkg.StageTracker, queryStmt *stmt.Query, req *protoCommonV1.TaskRequest, serverFactory rpc.TaskServerFactory, leafNode *models.Target, receivers []string, database tsdb.Database, ) *LeafExecuteContext
NewLeafExecuteContext creates a LeafExecuteContext instance.
func (*LeafExecuteContext) SendResponse ¶
func (ctx *LeafExecuteContext) SendResponse(err error)
SendResponse sends lead node execute response, if with err sends error msg, else sends result set.
type LeafGroupingContext ¶
type LeafGroupingContext struct {
// contains filtered or unexported fields
}
LeafGroupingContext represents collect grouping tags context under lead node.
func NewLeafGroupingContext ¶
func NewLeafGroupingContext(leafExecuteCtx *LeafExecuteContext) *LeafGroupingContext
NewLeafGroupingContext creates a LeafGroupingContext instance.
func (*LeafGroupingContext) CompleteGroupingTask ¶
func (ctx *LeafGroupingContext) CompleteGroupingTask()
CompleteGroupingTask completes a grouping task, if all grouping tasks are completed, do collect grouping tag values.
func (*LeafGroupingContext) ForkGroupingTask ¶
func (ctx *LeafGroupingContext) ForkGroupingTask()
ForkGroupingTask forks a grouping task.
type LeafMetadataContext ¶
type LeafMetadataContext struct { Request *stmt.MetricMetadata Database tsdb.Database ShardIDs []models.ShardID StorageExecuteCtx *flow.StorageExecuteContext ResultSet []string TagKeyID tag.KeyID // for tag values suggest Limit int }
LeafMetadataContext represents leaf node execution metadata query context.
func NewLeafMetadataContext ¶
func NewLeafMetadataContext(request *stmt.MetricMetadata, database tsdb.Database, shardIDs []models.ShardID) *LeafMetadataContext
NewLeafMetadataContext creates a LeafMetadataContext instance.
func (*LeafMetadataContext) AddValue ¶
func (ctx *LeafMetadataContext) AddValue(val string)
AddValue adds value into result set.
type LeafReduceContext ¶
type LeafReduceContext struct {
// contains filtered or unexported fields
}
LeafReduceContext represents reduce the result after down sampling aggregate.
func NewLeafReduceContext ¶
func NewLeafReduceContext(storageExecuteCtx *flow.StorageExecuteContext, leafGroupingCtx *LeafGroupingContext) *LeafReduceContext
NewLeafReduceContext creates a LeafReduceContext instance.
func (*LeafReduceContext) BuildResultSet ¶
func (ctx *LeafReduceContext) BuildResultSet(leafNode *models.Target, receivers []string) [][]byte
BuildResultSet returns the result set from reduce aggregator based on receivers.
func (*LeafReduceContext) Reduce ¶
func (ctx *LeafReduceContext) Reduce(it series.GroupedIterator)
Reduce reduces the down sampling aggregator's result.
type MetadataContext ¶ added in v0.2.4
type MetadataContext struct { Deps *MetadataDeps // contains filtered or unexported fields }
MetadataContext represents metric metadata search context.
func NewMetadataContext ¶ added in v0.2.4
func NewMetadataContext(deps *MetadataDeps) *MetadataContext
NewMetadataContext creates metric metadata search context.
func (*MetadataContext) Complete ¶ added in v0.2.4
func (ctx *MetadataContext) Complete(err error)
Complete completes the task with error(if execute failure).
func (*MetadataContext) GetRequests ¶ added in v0.2.4
func (ctx *MetadataContext) GetRequests() map[string]*protoCommonV1.TaskRequest
GetRequests returns the request list which send to target node.
func (*MetadataContext) HandleResponse ¶ added in v0.2.4
func (ctx *MetadataContext) HandleResponse(resp *protoCommonV1.TaskResponse, fromNode string)
HandleResponse handles metric metadata task response.
func (*MetadataContext) MakePlan ¶ added in v0.2.4
func (ctx *MetadataContext) MakePlan() error
MakePlan makes the metric metadata physical plan.
func (*MetadataContext) SendRequest ¶ added in v0.2.4
func (ctx *MetadataContext) SendRequest(targetNodeID string, req *protoCommonV1.TaskRequest) error
SendRequest sends the task request to target node.
func (*MetadataContext) SetTracker ¶ added in v0.2.4
func (ctx *MetadataContext) SetTracker(stageTracker *tracker.StageTracker)
SetTracker sets stage tracker.
func (*MetadataContext) WaitResponse ¶ added in v0.2.4
func (ctx *MetadataContext) WaitResponse() (any, error)
WaitResponse waits metric metadata search task completed and returns metric data.
type MetadataDeps ¶ added in v0.2.4
type MetadataDeps struct { Ctx context.Context Request *models.Request Database string Statement *stmt.MetricMetadata CurrentNode models.StatelessNode Choose flow.NodeChoose TransportMgr rpc.TransportManager }
MetadataDeps represents metric metadata search dependency.
type MetricContext ¶ added in v0.2.4
type MetricContext struct {
// contains filtered or unexported fields
}
MetricContext represents metric data search context.
func (*MetricContext) Complete ¶ added in v0.2.4
func (ctx *MetricContext) Complete(err error)
Complete completes the task with error(if execute failure).
func (*MetricContext) GetRequests ¶ added in v0.2.4
func (ctx *MetricContext) GetRequests() map[string]*protoCommonV1.TaskRequest
GetRequests returns the request list which send to target node.
func (*MetricContext) HandleResponse ¶ added in v0.2.4
func (ctx *MetricContext) HandleResponse(resp *protoCommonV1.TaskResponse, fromNode string)
HandleResponse handles metric data search task response.
func (*MetricContext) SendRequest ¶ added in v0.2.4
func (ctx *MetricContext) SendRequest(targetNodeID string, req *protoCommonV1.TaskRequest) error
SendRequest sends the task request to target node.
func (*MetricContext) SetTracker ¶ added in v0.2.4
func (ctx *MetricContext) SetTracker(stageTracker *tracker.StageTracker)
SetTracker sets stage tracker.
type RootMetricContext ¶ added in v0.2.4
type RootMetricContext struct { MetricContext Deps *RootMetricContextDeps }
RootMetricContext represents root metric data search context.
func NewRootMetricContext ¶ added in v0.2.4
func NewRootMetricContext(deps *RootMetricContextDeps) *RootMetricContext
NewRootMetricContext creates the root metric data search context.
func (*RootMetricContext) Complete ¶ added in v0.2.4
func (ctx *RootMetricContext) Complete(err error)
Complete completes the task with error(if execute failure).
func (*RootMetricContext) GetRequests ¶ added in v0.2.4
func (ctx *RootMetricContext) GetRequests() map[string]*protoCommonV1.TaskRequest
GetRequests returns the request list which send to target node.
func (*RootMetricContext) MakePlan ¶ added in v0.2.4
func (ctx *RootMetricContext) MakePlan() error
MakePlan makes the metric data physical plan.
func (*RootMetricContext) SendRequest ¶ added in v0.2.4
func (ctx *RootMetricContext) SendRequest(targetNodeID string, req *protoCommonV1.TaskRequest) error
SendRequest sends the task request to target node.
func (*RootMetricContext) SetTracker ¶ added in v0.2.4
func (ctx *RootMetricContext) SetTracker(stageTracker *tracker.StageTracker)
SetTracker sets stage tracker.
func (*RootMetricContext) WaitResponse ¶ added in v0.2.4
func (ctx *RootMetricContext) WaitResponse() (any, error)
WaitResponse waits metric data search task completed, then returns the result set,
type RootMetricContextDeps ¶ added in v0.2.4
type RootMetricContextDeps struct { Ctx context.Context Request *models.Request Database string CurrentNode models.StatelessNode Statement *stmt.Query Choose flow.NodeChoose TransportMgr rpc.TransportManager }
RootMetricContextDeps represents root metric data search dependency.
type TaskContext ¶ added in v0.2.4
type TaskContext interface { // Context returns the context. Context() context.Context // MakePlan executes search logic in compute level. // 1) get metadata based on params // 2) build execute plan MakePlan() error // HandleResponse handles task response. HandleResponse(resp *protoCommonV1.TaskResponse, fromNode string) // SendRequest sends the task request to target node. SendRequest(targetNodeID string, req *protoCommonV1.TaskRequest) error // GetRequests returns the request list which send to target node. GetRequests() map[string]*protoCommonV1.TaskRequest // Complete completes the task with error(if execute failure). Complete(err error) // WaitResponse waits task complete and returns the response. WaitResponse() (any, error) // SetTracker sets stage tracker. SetTracker(stageTracker *tracker.StageTracker) }
TaskContext represents the task context for distribution query and computing.