service

Documentation

Index

• Constants
• Variables
• func AlarmAttachInfo(respList []*db.Alarm) []view.RespAlarmList
• func AllPrometheusReload()
• func AnalysisFieldsUpdate(tid int, data []view.IndexItem) (err error)
• func ClickHouseLink(dsn string) (db *sql.DB, err error)
• func DatabaseCreate(req db.BaseDatabase) (out db.BaseDatabase, err error)
• func DepsBatch(isReset bool)
• func DoDepsSync()
• func Init() error
• func InstanceCreate(req view.ReqCreateInstance) (obj db.BaseInstance, err error)
• func IsPermissionDatabase(uid, iid, did int, subResource string) bool
• func IsPermissionInstance(uid int, iid int, subResource string) bool
• func IsPermissionTable(uid, iid, tid int, subResource string) bool
• func NewAlarm() *alarm
• func NewIndex() *index
• func NewInstanceManager() *instanceManager
• func NodeResultRespAssemble(nr *db.BigdataNodeResult) view.RespNodeResult
• func NodeTryLock(uid, configId int) (err error)
• func NodeUnlock(uid, configId int) (err error)
• func ReadAllPermissionInstance(uid int, subResource string) ([]int, string)
• func ReadAllPermissionTable(uid int, subResource string) []int
• func Send(alarmUUID string, notification view.Notification) (err error)
• func SendTestToChannel(c *db.AlarmChannel) (err error)
• func TableCreate(uid int, databaseInfo db.BaseDatabase, param view.ReqTableCreate) (tableInfo db.BaseTable, err error)
• func TableDeps(iid int, database, table string) (res []view.RespTableDeps, err error)

Constants

const (
	NoDataOpDefault = 0
	NoDataOpOK      = 1
	NoDataOpAlert   = 2
)

Variables

var (
	Permission      *permission.Service
	InstanceManager *instanceManager
	Index           *index
	Alarm           *alarm
)

Functions

func AlarmAttachInfo

func AlarmAttachInfo(respList []*db.Alarm) []view.RespAlarmList

func AllPrometheusReload

func AllPrometheusReload()

func AnalysisFieldsUpdate

func AnalysisFieldsUpdate(tid int, data []view.IndexItem) (err error)

func ClickHouseLink

func ClickHouseLink(dsn string) (db *sql.DB, err error)

func DatabaseCreate

func DatabaseCreate(req db.BaseDatabase) (out db.BaseDatabase, err error)

func DepsBatch

func DepsBatch(isReset bool)

DepsBatch Periodically synchronize the data of each instance

func DoDepsSync

func DoDepsSync()

func Init

func Init() error

func InstanceCreate

func InstanceCreate(req view.ReqCreateInstance) (obj db.BaseInstance, err error)

func IsPermissionDatabase

func IsPermissionDatabase(uid, iid, did int, subResource string) bool

func IsPermissionInstance

func IsPermissionInstance(uid int, iid int, subResource string) bool

func IsPermissionTable

func IsPermissionTable(uid, iid, tid int, subResource string) bool

func NewAlarm

func NewAlarm() *alarm

NewAlarm ...

func NewIndex

func NewIndex() *index

NewIndex ...

func NewInstanceManager

func NewInstanceManager() *instanceManager

func NodeResultRespAssemble

func NodeResultRespAssemble(nr *db.BigdataNodeResult) view.RespNodeResult

func NodeTryLock

func NodeTryLock(uid, configId int) (err error)

func NodeUnlock

func NodeUnlock(uid, configId int) (err error)

func ReadAllPermissionInstance

func ReadAllPermissionInstance(uid int, subResource string) ([]int, string)

func ReadAllPermissionTable

func ReadAllPermissionTable(uid int, subResource string) []int

func Send

func Send(alarmUUID string, notification view.Notification) (err error)

func SendTestToChannel

func SendTestToChannel(c *db.AlarmChannel) (err error)

func TableCreate

func TableCreate(uid int, databaseInfo db.BaseDatabase, param view.ReqTableCreate) (tableInfo db.BaseTable, err error)

func TableDeps

func TableDeps(iid int, database, table string) (res []view.RespTableDeps, err error)