Documentation
¶
Index ¶
- func ExecuteAsyncQuery(root *structs.ASTNode, aggs *structs.QueryAggregators, qid uint64, ...) (chan *query.QueryStateChanData, error)
- func ExecuteMetricsQuery(mQuery *structs.MetricsQuery, timeRange *dtu.MetricsTimeRange, qid uint64) *mresults.MetricsResult
- func ExecuteMultipleMetricsQuery(hashList []uint64, mQueries []*structs.MetricsQuery, ...) *mresults.MetricsResult
- func ExecuteQuery(root *structs.ASTNode, aggs *structs.QueryAggregators, qid uint64, ...) *structs.NodeResult
- func LogASTNode(prefix string, astNode *structs.ASTNode, qid uint64)
- func LogMetricsQuery(prefix string, mQRequest *structs.MetricsQueryRequest, qid uint64)
- func LogMetricsQueryOps(prefix string, queryOps []structs.QueryArithmetic, qid uint64)
- func LogNode(prefix string, node any, qid uint64)
- func LogQueryAggsNode(prefix string, node *structs.QueryAggregators, qid uint64)
- func LogQueryContext(qc *structs.QueryContext, qid uint64)
- func LogSearchNode(prefix string, sNode *structs.SearchNode, qid uint64)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ExecuteAsyncQuery ¶
func ExecuteAsyncQuery(root *structs.ASTNode, aggs *structs.QueryAggregators, qid uint64, qc *structs.QueryContext) (chan *query.QueryStateChanData, error)
The caller of this function is responsible for calling query.DeleteQuery(qid) to remove the qid info from memory. Returns a channel that will have events for query status or any error. An error means the query was not successfully started
func ExecuteMetricsQuery ¶
func ExecuteMetricsQuery(mQuery *structs.MetricsQuery, timeRange *dtu.MetricsTimeRange, qid uint64) *mresults.MetricsResult
func ExecuteMultipleMetricsQuery ¶
func ExecuteMultipleMetricsQuery(hashList []uint64, mQueries []*structs.MetricsQuery, queryOps []structs.QueryArithmetic, timeRange *dtu.MetricsTimeRange, qid uint64) *mresults.MetricsResult
func ExecuteQuery ¶
func ExecuteQuery(root *structs.ASTNode, aggs *structs.QueryAggregators, qid uint64, qc *structs.QueryContext) *structs.NodeResult
func LogMetricsQuery ¶
func LogMetricsQuery(prefix string, mQRequest *structs.MetricsQueryRequest, qid uint64)
func LogMetricsQueryOps ¶
func LogMetricsQueryOps(prefix string, queryOps []structs.QueryArithmetic, qid uint64)
func LogQueryAggsNode ¶
func LogQueryAggsNode(prefix string, node *structs.QueryAggregators, qid uint64)
func LogQueryContext ¶
func LogQueryContext(qc *structs.QueryContext, qid uint64)
func LogSearchNode ¶
func LogSearchNode(prefix string, sNode *structs.SearchNode, qid uint64)
Types ¶
This section is empty.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.