 Documentation
      ¶
      Documentation
      ¶
    
    
  
    
  
    Index ¶
- Variables
- func NewApiClient(httpClient *http.Client, datasource *models.DataSource) *apiClient
- func NewMQEExecutor(dsInfo *models.DataSource) (tsdb.Executor, error)
- type Function
- type MQEExecutor
- type MQEResponse
- type MQEResponseSerie
- type MQESerie
- type Metric
- type Query
- type QueryParser
- type QueryToSend
- type ResponseParser
- type ResponseTimeRange
- type TokenBody
- type TokenClient
- type TokenResponse
Constants ¶
This section is empty.
Variables ¶
      View Source
      
  
var (
	MaxWorker int = 4
)
    Functions ¶
func NewApiClient ¶
func NewApiClient(httpClient *http.Client, datasource *models.DataSource) *apiClient
func NewMQEExecutor ¶
func NewMQEExecutor(dsInfo *models.DataSource) (tsdb.Executor, error)
Types ¶
type MQEExecutor ¶
type MQEExecutor struct {
	*models.DataSource
	// contains filtered or unexported fields
}
    func (*MQEExecutor) Execute ¶
func (e *MQEExecutor) Execute(ctx context.Context, queries tsdb.QuerySlice, queryContext *tsdb.QueryContext) *tsdb.BatchResult
type MQEResponse ¶
type MQEResponse struct {
	Success bool               `json:"success"`
	Name    string             `json:"name"`
	Body    []MQEResponseSerie `json:"body"`
}
    type MQEResponseSerie ¶
type MQEResponseSerie struct {
	Query     string            `json:"query"`
	Name      string            `json:"name"`
	Type      string            `json:"type"`
	Series    []MQESerie        `json:"series"`
	TimeRange ResponseTimeRange `json:"timerange"`
}
    type Query ¶
type QueryParser ¶
type QueryParser struct{}
    func NewQueryParser ¶
func NewQueryParser() *QueryParser
func (*QueryParser) Parse ¶
func (qp *QueryParser) Parse(model *simplejson.Json, dsInfo *models.DataSource, queryContext *tsdb.QueryContext) (*Query, error)
type QueryToSend ¶
type ResponseParser ¶
type ResponseParser struct {
	// contains filtered or unexported fields
}
    func NewResponseParser ¶
func NewResponseParser() *ResponseParser
func (*ResponseParser) Parse ¶
func (parser *ResponseParser) Parse(res *http.Response, queryRef QueryToSend) ([]*tsdb.TimeSeries, error)
type ResponseTimeRange ¶
type TokenClient ¶
type TokenClient struct {
	Datasource *models.DataSource
	HttpClient *http.Client
	// contains filtered or unexported fields
}
    func NewTokenClient ¶
func NewTokenClient(datasource *models.DataSource) *TokenClient
func (*TokenClient) GetTokenData ¶
func (client *TokenClient) GetTokenData(ctx context.Context) (*TokenBody, error)
func (*TokenClient) RequestTokenData ¶
func (client *TokenClient) RequestTokenData(ctx context.Context) (*TokenBody, error)
type TokenResponse ¶
 Click to show internal directories. 
   Click to hide internal directories.