clickhouse

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Mar 5, 2024 License: MIT Imports: 30 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ModeStandalone int = 0
	ModeCluster    int = 1
)

Variables

This section is empty.

Functions

func TransferGroupTimeField 

func TransferGroupTimeField(timeField string, timeFieldTyp int) string

Types

type ClickHouseX 

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

func NewClickHouse 

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

func (*ClickHouseX) CalculateInterval 

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

func (*ClickHouseX) Chart 

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

func (*ClickHouseX) ClusterInfo 

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

func (*ClickHouseX) Conn 

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

func (*ClickHouseX) Count 

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

func (*ClickHouseX) CreateAlertView 

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

func (*ClickHouseX) CreateBufferNullDataPipe 

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

func (*ClickHouseX) CreateDatabase 

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

func (*ClickHouseX) CreateKafkaTable 

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

CreateKafkaTable Drop and Create

func (*ClickHouseX) CreateMetricsSamples 

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

func (*ClickHouseX) CreateStorage 

func (c *ClickHouseX) 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 (*ClickHouseX) CreateStorageJSONAsString 

func (c *ClickHouseX) CreateStorageJSONAsString(database db.BaseDatabase, ct view.ReqStorageCreate) (dStreamSQL, dDataSQL, dViewSQL, dDistributedSQL string, err error)

func (*ClickHouseX) CreateTable 

func (c *ClickHouseX) 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 (*ClickHouseX) CreateTraceJaegerDependencies 

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

func (*ClickHouseX) DeleteAlertView 

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

func (*ClickHouseX) DeleteDatabase 

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

func (*ClickHouseX) DeleteTable 

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

DeleteTable data view stream

func (*ClickHouseX) DeleteTableListByNames 

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

DeleteTableListByNames data view stream

func (*ClickHouseX) DeleteTraceJaegerDependencies 

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

func (*ClickHouseX) DoSQL 

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

func (*ClickHouseX) GetAlertViewSQL 

func (c *ClickHouseX) 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 (*ClickHouseX) GetCreateSQL 

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

func (*ClickHouseX) GetLogs 

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

func (*ClickHouseX) GetMetricsSamples 

func (c *ClickHouseX) GetMetricsSamples() error

func (*ClickHouseX) GetTraceGraph 

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

func (*ClickHouseX) GroupBy 

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

func (*ClickHouseX) ListColumn 

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

func (*ClickHouseX) ListDatabase 

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

func (*ClickHouseX) ListSystemCluster 

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

func (*ClickHouseX) ListSystemTable 

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

func (*ClickHouseX) Prepare 

func (c *ClickHouseX) Prepare(res view.ReqQuery, table *db.BaseTable, isRegroup bool) (view.ReqQuery, error)

func (*ClickHouseX) SyncView 

func (c *ClickHouseX) 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 (*ClickHouseX) UpdateLogAnalysisFields 

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

UpdateLogAnalysisFields Data table index operation

func (*ClickHouseX) UpdateMergeTreeTable 

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

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

func (*ClickHouseX) Version 

func (c *ClickHouseX) Version() (ver string, err error)

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"`
}

Source Files

View all Source files

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.