Documentation
¶
Index ¶
- func CreateTableFramesFromQuery(ctx context.Context, tableName string, cursor *mongo.Cursor) (*data.Frame, error)
- func CreateTableFramesFromStream(ctx context.Context, tableName string, stream *mongo.ChangeStream) (*data.Frame, error)
- func CreateTimeSeriesFramesFromQuery(ctx context.Context, cursor *mongo.Cursor) (map[string]*data.Frame, error)
- func CreateTimeSeriesFramesFromStream(ctx context.Context, tableName string, stream *mongo.ChangeStream) (*data.Frame, error)
- func MongoUri(config *models.PluginSettings) (string, error)
- func NewDatasource(ctx context.Context, source backend.DataSourceInstanceSettings) (instancemgmt.Instance, error)
- func PrintDataFrame(dataFrame *data.Frame)
- type Datasource
- func (d *Datasource) CallResource(ctx context.Context, req *backend.CallResourceRequest, ...) error
- func (d *Datasource) CheckHealth(ctx context.Context, req *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)
- func (d *Datasource) Dispose()
- func (d *Datasource) PublishStream(ctx context.Context, req *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error)
- func (d *Datasource) QueryData(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error)
- func (d *Datasource) RunStream(ctx context.Context, req *backend.RunStreamRequest, ...) error
- func (d *Datasource) SubscribeStream(ctx context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error)
- type TimeSeriesRow
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateTableFramesFromStream ¶ added in v0.3.0
func CreateTimeSeriesFramesFromQuery ¶
func CreateTimeSeriesFramesFromQuery(ctx context.Context, cursor *mongo.Cursor) (map[string]*data.Frame, error)
Create time-series data frames of different names on Mongo query result. Each data frame has field "ts", "value" and "name"
func CreateTimeSeriesFramesFromStream ¶ added in v0.3.0
func MongoUri ¶
func MongoUri(config *models.PluginSettings) (string, error)
Validate mongo connection configuration and return connection string
func NewDatasource ¶
func NewDatasource(ctx context.Context, source backend.DataSourceInstanceSettings) (instancemgmt.Instance, error)
NewDatasource creates a new MongoDB datasource instance.
func PrintDataFrame ¶
Types ¶
type Datasource ¶
type Datasource struct {
// contains filtered or unexported fields
}
Datasource is a mongo datasource which can respond to data queries, reports its health and has streaming skills.
func (*Datasource) CallResource ¶ added in v0.4.1
func (d *Datasource) CallResource(ctx context.Context, req *backend.CallResourceRequest, sender backend.CallResourceResponseSender) error
func (*Datasource) CheckHealth ¶
func (d *Datasource) CheckHealth(ctx context.Context, req *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)
CheckHealth handles health checks sent from Grafana to the plugin. The main use case for these health checks is the test button on the datasource configuration page which allows users to verify that a datasource is working as expected.
func (*Datasource) Dispose ¶
func (d *Datasource) Dispose()
Dispose here tells plugin SDK that plugin wants to clean up resources when a new instance created. As soon as datasource settings change detected by SDK old datasource instance will be disposed and a new one will be created using NewSampleDatasource factory function.
func (*Datasource) PublishStream ¶ added in v0.3.0
func (d *Datasource) PublishStream(ctx context.Context, req *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error)
func (*Datasource) QueryData ¶
func (d *Datasource) QueryData(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error)
QueryData handles multiple queries and returns multiple responses. req contains the queries []DataQuery (where each query contains RefID as a unique identifier). The QueryDataResponse contains a map of RefID to the response for each query, and each response contains Frames ([]*Frame).
func (*Datasource) RunStream ¶ added in v0.3.0
func (d *Datasource) RunStream(ctx context.Context, req *backend.RunStreamRequest, sender *backend.StreamSender) error
func (*Datasource) SubscribeStream ¶ added in v0.3.0
func (d *Datasource) SubscribeStream(ctx context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error)
Source Files