databend

Documentation

Index

• Constants
• func TransferGroupTimeField(timeField string, timeFieldTyp int) string
• type Databend
  • func NewDatabend(db *sql.DB, ins *db2.BaseInstance) (*Databend, error)
  • func (c *Databend) CalculateInterval(interval int64, timeField string) (string, int64)
  • func (c *Databend) Chart(param view2.ReqQuery) (res []*view2.HighChart, q string, err error)
  • func (c *Databend) ClusterInfo() (clusters map[string]dto.ClusterInfo, err error)
  • func (c *Databend) Conn() *sql.DB
  • func (c *Databend) Count(param view2.ReqQuery) (uint64, error)
  • func (c *Databend) CreateAlertView(viewTableName, viewSQL, cluster string) (err error)
  • func (c *Databend) CreateBufferNullDataPipe(req db2.ReqCreateBufferNullDataPipe) (names []string, sqls []string, err error)
  • func (c *Databend) CreateDatabase(name, cluster string) error
  • func (c *Databend) CreateKafkaTable(tableInfo *db2.BaseTable, params view2.ReqStorageUpdate) (streamSQL string, err error)
  • func (c *Databend) CreateMetricsSamples(cluster string) error
  • func (c *Databend) CreateStorage(did int, database db2.BaseDatabase, ct view2.ReqStorageCreate) (dStreamSQL, dDataSQL, dViewSQL, dDistributedSQL string, err error)
  • func (c *Databend) CreateStorageJSONAsString(database db2.BaseDatabase, create view2.ReqStorageCreate) (string, string, string, string, error)
  • func (c *Databend) CreateTable(did int, database db2.BaseDatabase, ct view2.ReqTableCreate) (dStreamSQL, dDataSQL, dViewSQL, dDistributedSQL string, err error)
  • func (c *Databend) CreateTraceJaegerDependencies(database, cluster, table string, ttl int) (err error)
  • func (c *Databend) DeleteAlertView(viewTableName, cluster string) (err error)
  • func (c *Databend) DeleteDatabase(name string, cluster string) (err error)
  • func (c *Databend) DeleteTable(database, table, cluster string, tid int) (err error)
  • func (c *Databend) DeleteTableListByNames(i []string, s string) error
  • func (c *Databend) DeleteTraceJaegerDependencies(database, cluster, table string) (err error)
  • func (c *Databend) DoSQL(sql string) (res view2.RespComplete, err error)
  • func (c *Databend) GetAlertViewSQL(alarm *db2.Alarm, tableInfo db2.BaseTable, filterId int, ...) (string, string, error)
  • func (c *Databend) GetCreateSQL(database, table string) (resp string, err error)
  • func (c *Databend) GetLogs(param view2.ReqQuery, tid int) (res view2.RespQuery, err error)
  • func (c *Databend) GetMetricsSamples() error
  • func (c *Databend) GetTraceGraph(ctx context.Context) (resp []view2.RespJaegerDependencyDataModel, err error)
  • func (c *Databend) GroupBy(param view2.ReqQuery) (res map[string]uint64)
  • func (c *Databend) ListColumn(database, table string, isTimeField bool) (res []*view2.RespColumn, err error)
  • func (c *Databend) ListDatabase() ([]*view2.RespDatabaseSelfBuilt, error)
  • func (c *Databend) ListSystemCluster() (l []*view2.SystemClusters, m map[string]*view2.SystemClusters, err error)
  • func (c *Databend) ListSystemTable() (res []*view2.SystemTables)
  • func (c *Databend) Prepare(res view2.ReqQuery, table *db2.BaseTable, isFilter bool) (view2.ReqQuery, error)
  • func (c *Databend) SyncView(table db2.BaseTable, current *db2.BaseView, list []*db2.BaseView, ...) (dViewSQL, cViewSQL string, err error)
  • func (c *Databend) UpdateLogAnalysisFields(database db2.BaseDatabase, table db2.BaseTable, adds map[string]*db2.BaseIndex, ...) (err error)
  • func (c *Databend) UpdateMergeTreeTable(tableInfo *db2.BaseTable, params view2.ReqStorageUpdate) (err error)
• type JaegerJson
• type JaegerJsonOriginal

Constants

const (
	ModeStandalone int = 0
	ModeCluster    int = 1
)

Functions

func TransferGroupTimeField

func TransferGroupTimeField(timeField string, timeFieldTyp int) string

Types

type Databend

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

func NewDatabend

func NewDatabend(db *sql.DB, ins *db2.BaseInstance) (*Databend, error)

func (*Databend) CalculateInterval

func (c *Databend) CalculateInterval(interval int64, timeField string) (string, int64)

func (*Databend) Chart

func (c *Databend) Chart(param view2.ReqQuery) (res []*view2.HighChart, q string, err error)

func (*Databend) ClusterInfo

func (c *Databend) ClusterInfo() (clusters map[string]dto.ClusterInfo, err error)

func (*Databend) Conn

func (c *Databend) Conn() *sql.DB

func (*Databend) Count

func (c *Databend) Count(param view2.ReqQuery) (uint64, error)

func (*Databend) CreateAlertView

func (c *Databend) CreateAlertView(viewTableName, viewSQL, cluster string) (err error)

func (*Databend) CreateBufferNullDataPipe

func (c *Databend) CreateBufferNullDataPipe(req db2.ReqCreateBufferNullDataPipe) (names []string, sqls []string, err error)

func (*Databend) CreateDatabase

func (c *Databend) CreateDatabase(name, cluster string) error

func (*Databend) CreateKafkaTable

func (c *Databend) CreateKafkaTable(tableInfo *db2.BaseTable, params view2.ReqStorageUpdate) (streamSQL string, err error)

CreateKafkaTable Drop and Create

func (*Databend) CreateMetricsSamples

func (c *Databend) CreateMetricsSamples(cluster string) error

func (*Databend) CreateStorage

func (c *Databend) CreateStorage(did int, database db2.BaseDatabase, ct view2.ReqStorageCreate) (dStreamSQL, dDataSQL, dViewSQL, dDistributedSQL string, err error)

CreateStorage create default stream data table and view

func (*Databend) CreateStorageJSONAsString

func (c *Databend) CreateStorageJSONAsString(database db2.BaseDatabase, create view2.ReqStorageCreate) (string, string, string, string, error)

func (*Databend) CreateTable

func (c *Databend) CreateTable(did int, database db2.BaseDatabase, ct view2.ReqTableCreate) (dStreamSQL, dDataSQL, dViewSQL, dDistributedSQL string, err error)

CreateTable create default stream data table and view

func (*Databend) CreateTraceJaegerDependencies

func (c *Databend) CreateTraceJaegerDependencies(database, cluster, table string, ttl int) (err error)

func (*Databend) DeleteAlertView

func (c *Databend) DeleteAlertView(viewTableName, cluster string) (err error)

func (*Databend) DeleteDatabase

func (c *Databend) DeleteDatabase(name string, cluster string) (err error)

func (*Databend) DeleteTable

func (c *Databend) DeleteTable(database, table, cluster string, tid int) (err error)

DeleteTable data view stream

func (*Databend) DeleteTableListByNames

func (c *Databend) DeleteTableListByNames(i []string, s string) error

func (*Databend) DeleteTraceJaegerDependencies

func (c *Databend) DeleteTraceJaegerDependencies(database, cluster, table string) (err error)

func (*Databend) DoSQL

func (c *Databend) DoSQL(sql string) (res view2.RespComplete, err error)

func (*Databend) GetAlertViewSQL

func (c *Databend) GetAlertViewSQL(alarm *db2.Alarm, tableInfo db2.BaseTable, filterId int, filter *view2.AlarmFilterItem) (string, string, error)

func (*Databend) GetCreateSQL

func (c *Databend) GetCreateSQL(database, table string) (resp string, err error)

func (*Databend) GetLogs

func (c *Databend) GetLogs(param view2.ReqQuery, tid int) (res view2.RespQuery, err error)

func (*Databend) GetMetricsSamples

func (c *Databend) GetMetricsSamples() error

func (*Databend) GetTraceGraph

func (c *Databend) GetTraceGraph(ctx context.Context) (resp []view2.RespJaegerDependencyDataModel, err error)

func (*Databend) GroupBy

func (c *Databend) GroupBy(param view2.ReqQuery) (res map[string]uint64)

func (*Databend) ListColumn

func (c *Databend) ListColumn(database, table string, isTimeField bool) (res []*view2.RespColumn, err error)

func (*Databend) ListDatabase

func (c *Databend) ListDatabase() ([]*view2.RespDatabaseSelfBuilt, error)

func (*Databend) ListSystemCluster

func (c *Databend) ListSystemCluster() (l []*view2.SystemClusters, m map[string]*view2.SystemClusters, err error)

func (*Databend) ListSystemTable

func (c *Databend) ListSystemTable() (res []*view2.SystemTables)

func (*Databend) Prepare

func (c *Databend) Prepare(res view2.ReqQuery, table *db2.BaseTable, isFilter bool) (view2.ReqQuery, error)

func (*Databend) SyncView

func (c *Databend) SyncView(table db2.BaseTable, current *db2.BaseView, list []*db2.BaseView, isAddOrUpdate bool) (dViewSQL, cViewSQL string, err error)

SyncView delete: list need remove current update: list need update current create: list need add current

func (*Databend) UpdateLogAnalysisFields

func (c *Databend) UpdateLogAnalysisFields(database db2.BaseDatabase, table db2.BaseTable, adds map[string]*db2.BaseIndex, dels map[string]*db2.BaseIndex, newList map[string]*db2.BaseIndex) (err error)

UpdateLogAnalysisFields Data table index operation

func (*Databend) UpdateMergeTreeTable

func (c *Databend) UpdateMergeTreeTable(tableInfo *db2.BaseTable, params view2.ReqStorageUpdate) (err error)

UpdateMergeTreeTable ... ALTER TABLE dev.test MODIFY TTL toDateTime(time_second) + toIntervalDay(7)

type JaegerJson

type JaegerJson struct {
	TraceId       string    `json:"traceId"`
	SpanId        string    `json:"spanId"`
	OperationName string    `json:"operationName"`
	StartTime     time.Time `json:"startTime"`
	Duration      string    `json:"duration"`
	Tags          []struct {
		Key    string `json:"key"`
		VStr   string `json:"vStr,omitempty"`
		VType  string `json:"vType,omitempty"`
		VInt64 string `json:"vInt64,omitempty"`
	} `json:"tags"`
	Process struct {
		ServiceName string `json:"serviceName"`
		Tags        []struct {
			Key  string `json:"key"`
			VStr string `json:"vStr"`
		} `json:"tags"`
	} `json:"process"`
}

type JaegerJsonOriginal

type JaegerJsonOriginal struct {
	TraceId  string `json:"trace_id"`
	SpanId   string `json:"span_id"`
	Duration string `json:"duration"`
}