inquiry

package
v0.4.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 30, 2022 License: MIT Imports: 23 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ModeStandalone int = 0
	ModeCluster    int = 1
)
View Source 
const (
	TableTypeString = 1
	TableTypeFloat  = 2
)

Variables

This section is empty.

Functions

func TagsToString 

func TagsToString(alarm *db.Alarm, isMV bool, filterId int) string

func TransferGroupTimeField added in v0.4.4 

func TransferGroupTimeField(timeField string, timeFieldTyp int) string

Types

type ClickHouse 

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

func NewClickHouse 

func NewClickHouse(db *sql.DB, ins *db.BaseInstance) (*ClickHouse, error)

func (*ClickHouse) CalculateInterval added in v0.4.5 

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

func (*ClickHouse) Chart added in v0.4.4 

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

func (*ClickHouse) Conn added in v0.4.3 

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

func (*ClickHouse) Count 

func (c *ClickHouse) Count(param view.ReqQuery) (res uint64, err error)

func (*ClickHouse) CreateAlertView added in v0.4.4 

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

func (*ClickHouse) CreateBufferNullDataPipe added in v0.4.5 

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

func (*ClickHouse) CreateDatabase added in v0.4.4 

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

func (*ClickHouse) CreateKafkaTable added in v0.4.4 

func (c *ClickHouse) CreateKafkaTable(tableInfo *db.BaseTable, params view.ReqStorageUpdate) (streamSQL string, err error)

CreateKafkaTable Drop and Create

func (*ClickHouse) CreateMetricsSamples added in v0.4.4 

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

func (*ClickHouse) CreateStorage added in v0.4.4 

func (c *ClickHouse) CreateStorage(did int, database db.BaseDatabase, ct view.ReqStorageCreate) (dStreamSQL, dDataSQL, dViewSQL, dDistributedSQL string, err error)

CreateStorage create default stream data table and view

func (*ClickHouse) CreateStorageV3 added in v0.4.4 

func (c *ClickHouse) CreateStorageV3(did int, database db.BaseDatabase, ct view.ReqStorageCreateV3) (dStreamSQL, dDataSQL, dViewSQL, dDistributedSQL string, err error)

CreateStorageV3 create default stream data table and view

func (*ClickHouse) CreateTable added in v0.4.4 

func (c *ClickHouse) CreateTable(did int, database db.BaseDatabase, ct view.ReqTableCreate) (dStreamSQL, dDataSQL, dViewSQL, dDistributedSQL string, err error)

CreateTable create default stream data table and view

func (*ClickHouse) CreateTraceJaegerDependencies added in v0.4.3 

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

func (*ClickHouse) DeleteAlertView added in v0.4.4 

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

func (*ClickHouse) DeleteDatabase added in v0.4.4 

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

func (*ClickHouse) DeleteTable added in v0.4.4 

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

DeleteTable data view stream

func (*ClickHouse) DeleteTableListByNames added in v0.4.5 

func (c *ClickHouse) DeleteTableListByNames(names []string, cluster string) (err error)

DeleteTableListByNames data view stream

func (*ClickHouse) DeleteTraceJaegerDependencies added in v0.4.4 

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

func (*ClickHouse) DoSQL added in v0.4.4 

func (c *ClickHouse) DoSQL(sql string) (res view.RespComplete, err error)

func (*ClickHouse) GetAlertViewSQL added in v0.4.4 

func (c *ClickHouse) GetAlertViewSQL(alarm *db.Alarm, tableInfo db.BaseTable, filterId int, filter *view.AlarmFilterItem) (string, string, error)

GetAlertViewSQL TableTypePrometheusMetric: `CREATE MATERIALIZED VIEW %s TO metrics.samples AS SELECT 

    toDate(_timestamp_) as date,
    %s as name,
    array(%s) as tags,
    toFloat64(count(*)) as val,
    _timestamp_ as ts,
    toDateTime(_timestamp_) as updated
FROM %s WHERE %s GROUP by _timestamp_;`,

func (*ClickHouse) GetCreateSQL added in v0.4.3 

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

func (*ClickHouse) GetLogs added in v0.4.4 

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

func (*ClickHouse) GetMetricsSamples added in v0.4.4 

func (c *ClickHouse) GetMetricsSamples() error

func (*ClickHouse) GetTraceGraph added in v0.4.3 

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

func (*ClickHouse) GroupBy 

func (c *ClickHouse) GroupBy(param view.ReqQuery) (res map[string]uint64)

func (*ClickHouse) ListColumn added in v0.4.4 

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

func (*ClickHouse) ListDatabase added in v0.4.4 

func (c *ClickHouse) ListDatabase() ([]*view.RespDatabaseSelfBuilt, error)

func (*ClickHouse) ListSystemCluster added in v0.4.4 

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

func (*ClickHouse) ListSystemTable added in v0.4.4 

func (c *ClickHouse) ListSystemTable() (res []*view.SystemTables)

func (*ClickHouse) Prepare 

func (c *ClickHouse) Prepare(res view.ReqQuery, isRegroup bool) (view.ReqQuery, error)

func (*ClickHouse) SyncView added in v0.4.4 

func (c *ClickHouse) SyncView(table db.BaseTable, current *db.BaseView, list []*db.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 (*ClickHouse) UpdateIndex added in v0.4.4 

func (c *ClickHouse) UpdateIndex(database db.BaseDatabase, table db.BaseTable, adds map[string]*db.BaseIndex, dels map[string]*db.BaseIndex, newList map[string]*db.BaseIndex) (err error)

UpdateIndex Data table index operation

func (*ClickHouse) UpdateMergeTreeTable added in v0.4.4 

func (c *ClickHouse) UpdateMergeTreeTable(tableInfo *db.BaseTable, params view.ReqStorageUpdate) (err error)

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

type Databend added in v0.4.5 

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

func NewDatabend added in v0.4.5 

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

func (*Databend) CalculateInterval added in v0.4.5 

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

func (*Databend) Chart added in v0.4.5 

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

func (*Databend) Conn added in v0.4.5 

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

func (*Databend) Count added in v0.4.5 

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

func (*Databend) CreateAlertView added in v0.4.5 

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

func (*Databend) CreateBufferNullDataPipe added in v0.4.5 

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

func (*Databend) CreateDatabase added in v0.4.5 

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

func (*Databend) CreateKafkaTable added in v0.4.5 

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

CreateKafkaTable Drop and Create

func (*Databend) CreateMetricsSamples added in v0.4.5 

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

func (*Databend) CreateStorage added in v0.4.5 

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

CreateStorage create default stream data table and view

func (*Databend) CreateStorageV3 added in v0.4.5 

func (c *Databend) CreateStorageV3(did int, database db.BaseDatabase, ct view.ReqStorageCreateV3) (dStreamSQL, dDataSQL, dViewSQL, dDistributedSQL string, err error)

CreateStorageV3 create default stream data table and view

func (*Databend) CreateTable added in v0.4.5 

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

CreateTable create default stream data table and view

func (*Databend) CreateTraceJaegerDependencies added in v0.4.5 

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

func (*Databend) DeleteAlertView added in v0.4.5 

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

func (*Databend) DeleteDatabase added in v0.4.5 

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

func (*Databend) DeleteTable added in v0.4.5 

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

DeleteTable data view stream

func (*Databend) DeleteTableListByNames added in v0.4.5 

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

func (*Databend) DeleteTraceJaegerDependencies added in v0.4.5 

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

func (*Databend) DoSQL added in v0.4.5 

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

func (*Databend) GetAlertViewSQL added in v0.4.5 

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

func (*Databend) GetCreateSQL added in v0.4.5 

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

func (*Databend) GetLogs added in v0.4.5 

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

func (*Databend) GetMetricsSamples added in v0.4.5 

func (c *Databend) GetMetricsSamples() error

func (*Databend) GetTraceGraph added in v0.4.5 

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

func (*Databend) GroupBy added in v0.4.5 

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

func (*Databend) ListColumn added in v0.4.5 

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

func (*Databend) ListDatabase added in v0.4.5 

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

func (*Databend) ListSystemCluster added in v0.4.5 

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

func (*Databend) ListSystemTable added in v0.4.5 

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

func (*Databend) Prepare added in v0.4.5 

func (c *Databend) Prepare(res view.ReqQuery, isFilter bool) (view.ReqQuery, error)

func (*Databend) SyncView added in v0.4.5 

func (c *Databend) SyncView(table db.BaseTable, current *db.BaseView, list []*db.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) UpdateIndex added in v0.4.5 

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

UpdateIndex Data table index operation

func (*Databend) UpdateMergeTreeTable added in v0.4.5 

func (c *Databend) UpdateMergeTreeTable(tableInfo *db.BaseTable, params view.ReqStorageUpdate) (err error)

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

type JaegerJson added in v0.4.3 

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 added in v0.4.3 

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

type Operator 

type Operator interface {
	Conn() *sql.DB
	Chart(view.ReqQuery) ([]*view.HighChart, string, error)
	Count(view.ReqQuery) (uint64, error)
	GroupBy(view.ReqQuery) map[string]uint64
	DoSQL(string) (view.RespComplete, error)
	Prepare(view.ReqQuery, bool) (view.ReqQuery, error)
	SyncView(db.BaseTable, *db.BaseView, []*db.BaseView, bool) (string, string, error)

	CreateDatabase(string, string) error
	CreateAlertView(string, string, string) error
	CreateKafkaTable(*db.BaseTable, view.ReqStorageUpdate) (string, error)
	CreateTraceJaegerDependencies(database, cluster, table string, ttl int) (err error)
	CreateTable(int, db.BaseDatabase, view.ReqTableCreate) (string, string, string, string, error)
	CreateStorage(int, db.BaseDatabase, view.ReqStorageCreate) (string, string, string, string, error)
	CreateStorageV3(int, db.BaseDatabase, view.ReqStorageCreateV3) (string, string, string, string, error)
	CreateMetricsSamples(cluster string) error
	CreateBufferNullDataPipe(req db.ReqCreateBufferNullDataPipe) (names []string, sqls []string, err error)

	UpdateIndex(db.BaseDatabase, db.BaseTable, map[string]*db.BaseIndex, map[string]*db.BaseIndex, map[string]*db.BaseIndex) error
	UpdateMergeTreeTable(*db.BaseTable, view.ReqStorageUpdate) error

	GetLogs(view.ReqQuery, int) (view.RespQuery, error)
	GetCreateSQL(database, table string) (string, error)
	GetAlertViewSQL(*db.Alarm, db.BaseTable, int, *view.AlarmFilterItem) (string, string, error)
	GetTraceGraph(ctx context.Context) ([]view.RespJaegerDependencyDataModel, error)
	GetMetricsSamples() error

	ListSystemTable() []*view.SystemTables
	ListSystemCluster() ([]*view.SystemClusters, map[string]*view.SystemClusters, error)
	ListDatabase() ([]*view.RespDatabaseSelfBuilt, error)
	ListColumn(string, string, bool) ([]*view.RespColumn, error)

	DeleteDatabase(string, string) error
	DeleteAlertView(string, string) error
	DeleteTable(string, string, string, int) error
	DeleteTableListByNames([]string, string) error
	DeleteTraceJaegerDependencies(database, cluster, table string) (err error)
	CalculateInterval(interval int64, timeField string) (string, int64)
}

Source Files

View all Source files

Directories

Path Synopsis
bumo
cluster
common
standalone
example

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.