plugin

Documentation

Index

• func AppendRow(frame *data.Frame, columns []chainbase.DataWarehouseDataMeta, ...) error
• func ExpandMacros(query backend.DataQuery, statement string) string
• func NewDatasource(_ context.Context, settings backend.DataSourceInstanceSettings) (instancemgmt.Instance, error)
• type Datasource
  • func (d *Datasource) CheckHealth(ctx context.Context, _ *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)
  • func (d *Datasource) Dispose()
  • func (d *Datasource) QueryData(ctx context.Context, request *backend.QueryDataRequest) (*backend.QueryDataResponse, error)
• type InvalidValueError
  • func NewInvalidValueError(columnName string, columnValue any) InvalidValueError
  • func (i InvalidValueError) Error() string
• type Options
• type Query
• type UnsupportedTypeError
  • func NewUnsupportedTypeError(columnName, columnType string) UnsupportedTypeError
  • func (u UnsupportedTypeError) Error() string

Functions

func AppendRow

func AppendRow(frame *data.Frame, columns []chainbase.DataWarehouseDataMeta, rows []map[string]any) error

func ExpandMacros

func ExpandMacros(query backend.DataQuery, statement string) string

func NewDatasource

func NewDatasource(_ context.Context, settings backend.DataSourceInstanceSettings) (instancemgmt.Instance, error)

Types

type Datasource

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

func (*Datasource) CheckHealth

func (d *Datasource) CheckHealth(ctx context.Context, _ *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)

func (*Datasource) Dispose

func (d *Datasource) Dispose()

func (*Datasource) QueryData

func (d *Datasource) QueryData(ctx context.Context, request *backend.QueryDataRequest) (*backend.QueryDataResponse, error)

type InvalidValueError

type InvalidValueError struct {
	Field string
	Value any
}

func NewInvalidValueError

func NewInvalidValueError(columnName string, columnValue any) InvalidValueError

func (InvalidValueError) Error

func (i InvalidValueError) Error() string

type Options

type Options struct {
	QueriesPerSecond int    `json:"queriesPerSecond"`
	APIKey           string `json:"apiKey"`
}

type Query

type Query struct {
	Statement string `json:"statement"`
}

type UnsupportedTypeError

type UnsupportedTypeError struct {
	Field string
	Type  string
}

func NewUnsupportedTypeError

func NewUnsupportedTypeError(columnName, columnType string) UnsupportedTypeError

func (UnsupportedTypeError) Error

func (u UnsupportedTypeError) Error() string