plugin

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
}

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