agent

Documentation

Index

• type Agent
  • func NewFactoryAgent(dsn string) (*Agent, error)
  • func (a *Agent) CalculateInterval(interval int64, timeField string) (sql string, standard int64)
  • func (a *Agent) Chart(query view.ReqQuery) ([]*view.HighChart, string, error)
  • func (a *Agent) ClusterInfo() (clusters map[string]dto.ClusterInfo, err error)
  • func (a *Agent) Conn() *sql.DB
  • func (a *Agent) Count(query view.ReqQuery) (uint64, error)
  • func (a *Agent) CreateAlertView(s string, s2 string, s3 string) error
  • func (a *Agent) CreateBufferNullDataPipe(req db2.ReqCreateBufferNullDataPipe) (names []string, sqls []string, err error)
  • func (a *Agent) CreateDatabase(s string, s2 string) error
  • func (a *Agent) CreateKafkaTable(table *db2.BaseTable, update view.ReqStorageUpdate) (string, error)
  • func (a *Agent) CreateMetricsSamples(s string) error
  • func (a *Agent) CreateStorage(i int, database db2.BaseDatabase, create view.ReqStorageCreate) (string, string, string, string, error)
  • func (a *Agent) CreateStorageJSONAsString(database db2.BaseDatabase, create view.ReqStorageCreate) (string, string, string, string, error)
  • func (a *Agent) CreateTable(i int, database db2.BaseDatabase, create view.ReqTableCreate) (string, string, string, string, error)
  • func (a *Agent) CreateTraceJaegerDependencies(database, cluster, table string, ttl int) (err error)
  • func (a *Agent) DeleteAlertView(s string, s2 string) error
  • func (a *Agent) DeleteDatabase(s string, s2 string) error
  • func (a *Agent) DeleteTable(s string, s2 string, s3 string, i int) error
  • func (a *Agent) DeleteTableListByNames(strings []string, s string) error
  • func (a *Agent) DeleteTraceJaegerDependencies(database, cluster, table string) (err error)
  • func (a *Agent) DoSQL(s string) (view.RespComplete, error)
  • func (a *Agent) GetAlertViewSQL(alarm *db2.Alarm, table db2.BaseTable, i int, item *view.AlarmFilterItem) (string, string, error)
  • func (a *Agent) GetCreateSQL(database, table string) (string, error)
  • func (a *Agent) GetLogs(query view.ReqQuery, i int) (resp view.RespQuery, err error)
  • func (a *Agent) GetMetricsSamples() error
  • func (a *Agent) GetTraceGraph(ctx context.Context) ([]view.RespJaegerDependencyDataModel, error)
  • func (a *Agent) GroupBy(query view.ReqQuery) map[string]uint64
  • func (a *Agent) ListColumn(s string, s2 string, b bool) ([]*view.RespColumn, error)
  • func (a *Agent) ListDatabase() ([]*view.RespDatabaseSelfBuilt, error)
  • func (a *Agent) ListSystemCluster() ([]*view.SystemClusters, map[string]*view.SystemClusters, error)
  • func (a *Agent) ListSystemTable() []*view.SystemTables
  • func (a *Agent) Prepare(query view.ReqQuery, table *db2.BaseTable, b bool) (view.ReqQuery, error)
  • func (a *Agent) SyncView(table db2.BaseTable, view *db2.BaseView, views []*db2.BaseView, b bool) (string, string, error)
  • func (a *Agent) UpdateLogAnalysisFields(database db2.BaseDatabase, table db2.BaseTable, m map[string]*db2.BaseIndex, ...) error
  • func (a *Agent) UpdateMergeTreeTable(table *db2.BaseTable, update view.ReqStorageUpdate) error

Types

type Agent

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

func NewFactoryAgent

func NewFactoryAgent(dsn string) (*Agent, error)

func (*Agent) CalculateInterval

func (a *Agent) CalculateInterval(interval int64, timeField string) (sql string, standard int64)

func (*Agent) Chart

func (a *Agent) Chart(query view.ReqQuery) ([]*view.HighChart, string, error)

func (*Agent) ClusterInfo

func (a *Agent) ClusterInfo() (clusters map[string]dto.ClusterInfo, err error)

func (*Agent) Conn

func (a *Agent) Conn() *sql.DB

func (*Agent) Count

func (a *Agent) Count(query view.ReqQuery) (uint64, error)

func (*Agent) CreateAlertView

func (a *Agent) CreateAlertView(s string, s2 string, s3 string) error

func (*Agent) CreateBufferNullDataPipe

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

func (*Agent) CreateDatabase

func (a *Agent) CreateDatabase(s string, s2 string) error

func (*Agent) CreateKafkaTable

func (a *Agent) CreateKafkaTable(table *db2.BaseTable, update view.ReqStorageUpdate) (string, error)

func (*Agent) CreateMetricsSamples

func (a *Agent) CreateMetricsSamples(s string) error

func (*Agent) CreateStorage

func (a *Agent) CreateStorage(i int, database db2.BaseDatabase, create view.ReqStorageCreate) (string, string, string, string, error)

func (*Agent) CreateStorageJSONAsString

func (a *Agent) CreateStorageJSONAsString(database db2.BaseDatabase, create view.ReqStorageCreate) (string, string, string, string, error)

func (*Agent) CreateTable

func (a *Agent) CreateTable(i int, database db2.BaseDatabase, create view.ReqTableCreate) (string, string, string, string, error)

func (*Agent) CreateTraceJaegerDependencies

func (a *Agent) CreateTraceJaegerDependencies(database, cluster, table string, ttl int) (err error)

func (*Agent) DeleteAlertView

func (a *Agent) DeleteAlertView(s string, s2 string) error

func (*Agent) DeleteDatabase

func (a *Agent) DeleteDatabase(s string, s2 string) error

func (*Agent) DeleteTable

func (a *Agent) DeleteTable(s string, s2 string, s3 string, i int) error

func (*Agent) DeleteTableListByNames

func (a *Agent) DeleteTableListByNames(strings []string, s string) error

func (*Agent) DeleteTraceJaegerDependencies

func (a *Agent) DeleteTraceJaegerDependencies(database, cluster, table string) (err error)

func (*Agent) DoSQL

func (a *Agent) DoSQL(s string) (view.RespComplete, error)

func (*Agent) GetAlertViewSQL

func (a *Agent) GetAlertViewSQL(alarm *db2.Alarm, table db2.BaseTable, i int, item *view.AlarmFilterItem) (string, string, error)

func (*Agent) GetCreateSQL

func (a *Agent) GetCreateSQL(database, table string) (string, error)

func (*Agent) GetLogs

func (a *Agent) GetLogs(query view.ReqQuery, i int) (resp view.RespQuery, err error)

func (*Agent) GetMetricsSamples

func (a *Agent) GetMetricsSamples() error

func (*Agent) GetTraceGraph

func (a *Agent) GetTraceGraph(ctx context.Context) ([]view.RespJaegerDependencyDataModel, error)

func (*Agent) GroupBy

func (a *Agent) GroupBy(query view.ReqQuery) map[string]uint64

func (*Agent) ListColumn

func (a *Agent) ListColumn(s string, s2 string, b bool) ([]*view.RespColumn, error)

func (*Agent) ListDatabase

func (a *Agent) ListDatabase() ([]*view.RespDatabaseSelfBuilt, error)

func (*Agent) ListSystemCluster

func (a *Agent) ListSystemCluster() ([]*view.SystemClusters, map[string]*view.SystemClusters, error)

func (*Agent) ListSystemTable

func (a *Agent) ListSystemTable() []*view.SystemTables

func (*Agent) Prepare

func (a *Agent) Prepare(query view.ReqQuery, table *db2.BaseTable, b bool) (view.ReqQuery, error)

func (*Agent) SyncView

func (a *Agent) SyncView(table db2.BaseTable, view *db2.BaseView, views []*db2.BaseView, b bool) (string, string, error)

func (*Agent) UpdateLogAnalysisFields

func (a *Agent) UpdateLogAnalysisFields(database db2.BaseDatabase, table db2.BaseTable, m map[string]*db2.BaseIndex, m2 map[string]*db2.BaseIndex, m3 map[string]*db2.BaseIndex) error

func (*Agent) UpdateMergeTreeTable

func (a *Agent) UpdateMergeTreeTable(table *db2.BaseTable, update view.ReqStorageUpdate) error