timestream

Documentation

Index

• func ExecuteQuery(ctx context.Context, query models.QueryModel, runner queryRunner, ...) (dr backend.DataResponse)
• func Interpolate(query models.QueryModel, settings models.DatasourceSettings) (string, error)
• func NewServerInstance(s backend.DataSourceInstanceSettings) (instancemgmt.Instance, error)
• func QueryResultToDataFrame(res *timestreamquery.QueryOutput) (dr backend.DataResponse)
• type MockClient

Functions

func ExecuteQuery

func ExecuteQuery(ctx context.Context, query models.QueryModel, runner queryRunner, settings models.DatasourceSettings) (dr backend.DataResponse)

ExecuteQuery -- run a query

func Interpolate

func Interpolate(query models.QueryModel, settings models.DatasourceSettings) (string, error)

Interpolate processes macros

func NewServerInstance

func NewServerInstance(s backend.DataSourceInstanceSettings) (instancemgmt.Instance, error)

func QueryResultToDataFrame

func QueryResultToDataFrame(res *timestreamquery.QueryOutput) (dr backend.DataResponse)

QueryResultToDataFrame creates a DataFrame from query results

Types

type MockClient

type MockClient struct {
	// contains filtered or unexported fields
}

MockClient ...