plugin

Documentation

Index

• Constants
• func NewKdbDatasource(settings backend.DataSourceInstanceSettings) (instancemgmt.Instance, error)
• func ParseGroupedKdbTable(res *kdb.K, includeKeys bool) ([]*data.Frame, error)
• func ParseSimpleKdbTable(res *kdb.K) (*data.Frame, error)
• type KdbDatasource
  • func (d *KdbDatasource) CheckHealth(_ context.Context, req *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)
  • func (d *KdbDatasource) Dispose()
  • func (d *KdbDatasource) QueryData(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error)
• type QueryModel

Constants

const ADAPTOR_VERSION = float64(1.0)

Functions

func NewKdbDatasource

func NewKdbDatasource(settings backend.DataSourceInstanceSettings) (instancemgmt.Instance, error)

NewKdbDatasource creates a new datasource instance.

func ParseGroupedKdbTable

func ParseGroupedKdbTable(res *kdb.K, includeKeys bool) ([]*data.Frame, error)

func ParseSimpleKdbTable

func ParseSimpleKdbTable(res *kdb.K) (*data.Frame, error)

Types

type KdbDatasource

type KdbDatasource struct {
	Host           string `json:"host"`
	Port           int    `json:"port"`
	Timeout        string `json:"timeout"`
	WithTls        bool   `json:"withTLS"`
	SkipVertifyTLS bool   `json:"skipVerifyTLS"`
	WithCACert     bool   `json:"withCACert"`

	TlsCertificate  string
	TlsKey          string
	CaCert          string
	TlsServerConfig *tls.Config
	DialTimeout     time.Duration
	KdbHandle       *kdb.KDBConn

	IsOpen            bool
	KdbHandleListener func()
	RunKdbQuerySync   func(*kdb.K, time.Duration) (*kdb.K, error)
	OpenConnection    func() error
	CloseConnection   func() error
	WriteConnection   func(kdb.ReqType, *kdb.K) error
	ReadConnection    func() (*kdb.K, kdb.ReqType, error)
	// contains filtered or unexported fields
}

func (*KdbDatasource) CheckHealth

func (d *KdbDatasource) CheckHealth(_ context.Context, req *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)

func (*KdbDatasource) Dispose

func (d *KdbDatasource) Dispose()

func (*KdbDatasource) QueryData

func (d *KdbDatasource) QueryData(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error)

type QueryModel

type QueryModel struct {
	QueryText         string `json:"queryText"`
	Timeout           int    `json:"timeOut"`
	UseTimeColumn     bool   `json:"useTimeColumn"`
	TimeColumn        string `json:"timeColumn"`
	IncludeKeyColumns bool   `json:"includeKeyColumns"`
}