db

package
v0.4.4-rc3 Latest Latest
Warning

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

 Go to latest Published: Nov 16, 2022 License: MIT Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	AlarmModeAggregation int
	AlarmModeAggregationCheck
)
View Source 
const (
	AlarmStatusUnknown = iota
	AlarmStatusClose
	AlarmStatusOpen
	AlarmStatusFiring
	AlarmStatusRuleCheck
)
View Source 
const (
	RuleStoreTypeFile         = 1
	RuleStoreTypeK8sConfigMap = 2
	RuleStoreTypeK8sOperator  = 3
)
View Source 
const (
	ChannelDingDing = iota + 1
	ChannelWeChat
	ChannelFeiShu
	ChannelSlack
	ChannelEmail
	ChannelTelegram
)
View Source 
const (
	FEISHUURL = "https://open.feishu.cn"
	LARKSUITE = "https://open.larksuite.com"
	SLACKURL  = "https://hooks.slack.com/services/"
)
View Source 
const (
	PushedStatusRepeat = iota
	PushedStatusSuccess
	PushedStatusFail
)
View Source 
const (
	HashTypeSip int = 1
	HashTypeURL int = 2
)
View Source 
const (
	DatasourceMySQL      = "mysql"
	DatasourceClickHouse = "ch"
)
View Source 
const (
	TimeFieldTypeDT     = 0 // DateTime
	TimeFieldTypeSecond = 1
	TimeFieldTypeTsMs   = 2 // unix ms
	TimeFieldTypeDT3    = 3 // DataTime64(3)
)
View Source 
const (
	BigdataNodeResultUnknown int = iota
	BigdataNodeResultSucc
	BigdataNodeResultFailed
)
View Source 
const (
	CollectTypeQuery        = 1 << 0
	CollectTypeTableFilter  = 1 << 1
	CollectTypeGlobalFilter = 1 << 2
)
View Source 
const (
	OpnMigration = "system_setting_migration"

	OpnTablesDelete         = "opn_tables_delete"
	OpnTablesCreate         = "opn_tables_create"
	OpnTableCreateSelfBuilt = "opn_tables_create_self_built"
	OpnTablesUpdate         = "opn_tables_update"
	OpnTablesIndexUpdate    = "opn_tables_index_update"
	OpnTablesLogsQuery      = "opn_tables_logs_query"
	OpnDatabasesDelete      = "opn_databases_delete"
	OpnDatabasesCreate      = "opn_databases_create"
	OpnDatabasesUpdate      = "opn_databases_update"
	OpnInstancesDelete      = "opn_instances_delete"
	OpnInstancesCreate      = "opn_instances_create"
	OpnInstancesUpdate      = "opn_instances_update"
	OpnViewsDelete          = "opn_views_delete"
	OpnViewsCreate          = "opn_views_create"
	OpnViewsUpdate          = "opn_views_update"

	OpnConfigsDelete  = "opn_configs_delete"
	OpnConfigsCreate  = "opn_configs_create"
	OpnConfigsUpdate  = "opn_configs_update"
	OpnConfigsPublish = "opn_configs_publish"
	OpnConfigsSync    = "opn_configs_sync"

	OpnClustersDelete          = "opn_clusters_delete"
	OpnClustersCreate          = "opn_clusters_create"
	OpnClustersUpdate          = "opn_clusters_update"
	OpnClustersConfigMapDelete = "opn_clusters_config_map_delete"
	OpnClustersConfigMapCreate = "opn_clusters_config_map_create"
	OpnClustersConfigMapUpdate = "opn_clusters_config_map_update"

	OpnAlarmsDelete         = "opn_alarms_delete"
	OpnAlarmsCreate         = "opn_alarms_create"
	OpnAlarmsUpdate         = "opn_alarms_update"
	OpnAlarmsChannelsDelete = "opn_alarms_channels_delete"
	OpnAlarmsChannelsCreate = "opn_alarms_channels_create"
	OpnAlarmsChannelsUpdate = "opn_alarms_channels_update"

	OpnBigDataNodeCreate        = "opn_big_data_node_create"
	OpnBigDataNodeUpdate        = "opn_big_data_node_update"
	OpnBigDataNodeDelete        = "opn_big_data_node_delete"
	OpnBigDataFolderCreate      = "opn_big_data_folder_create"
	OpnBigDataFolderUpdate      = "opn_big_data_folder_update"
	OpnBigDataFolderDelete      = "opn_big_data_folder_delete"
	OpnBigDataNodeCrontabCreate = "opn_big_data_node_crontab_create"
	OpnBigDataNodeCrontabUpdate = "opn_big_data_node_crontab_update"
	OpnBigDataNodeCrontabDelete = "opn_big_data_node_crontab_delete"
	OpnBigDataNodeCrontabStop   = "opn_big_data_node_crontab_stop"
	OpnBigDataNodeResultUpdate  = "opn_big_data_node_result_update"
	OpnBigDataWorkflowCreate    = "opn_big_data_workflow_create"
	OpnBigDataWorkflowUpdate    = "opn_big_data_workflow_update"
	OpnBigDataWorkflowDelete    = "opn_big_data_workflow_delete"
	OpnBigDataSourceCreate      = "opn_big_data_source_create"
	OpnBigDataSourceUpdate      = "opn_big_data_source_update"
	OpnBigDataSourceDelete      = "opn_big_data_source_delete"
	OpnBigDataNodeLock          = "opn_big_data_node_lock"
	OpnBigDataNodeUnlock        = "opn_big_data_node_unlock"
	OpnBigDataNodeRun           = "opn_big_data_node_run"
	OpnBigDataNodeStop          = "opn_big_data_node_strop"

	OpnUserCreate        = "opn_base_user_create"
	OpnUserDelete        = "opn_base_user_delete"
	OpnUserPasswordReset = "opn_base_user_password_reset"
	OpnUserPwdChange     = "user_pwd_change"
)

abbr. -> fullName "Opn" -> "Operation" "mgt" -> "management"

View Source 
const (
	SourceInquiryMgtCenter = "log_mgt"
	SourceUserMgtCenter    = "user_mgt"
	SourceSystemSetting    = "system_setting"
	SourceClusterMgtCenter = "cluster_mgt"
	SourceAlarmMgtCenter   = "alarm_mgt"
	SourceConfigMgtCenter  = "config_mgt"
	SourceBigDataMgtCenter = "bigdata_mgt"
)
View Source 
const (
	// ReplicaStatusYes This definition is really outrageous
	ReplicaStatusYes = 0
	ReplicaStatusNo  = 1
)
View Source 
const (
	TableNameUser         = "cv_user"
	TableNameEvent        = "cv_event"
	TableNameK8SConfigMap = "cv_k8s_cm"
	TableNameCluster      = "cv_cluster"
	TableNameCollect      = "cv_collect"

	TableNameBaseView        = "cv_base_view"
	TableNameBaseTable       = "cv_base_table"
	TableNameBaseIndex       = "cv_base_index"
	TableNameBaseDatabase    = "cv_base_database"
	TableNameBaseInstance    = "cv_base_instance"
	TableNameBaseShortURL    = "cv_base_short_url"
	TableNameBaseHiddenField = "cv_base_hidden_field"

	TableNameAlarm          = "cv_alarm"
	TableNameAlarmFilter    = "cv_alarm_filter"
	TableNameAlarmHistory   = "cv_alarm_history"
	TableNameAlarmChannel   = "cv_alarm_channel"
	TableNameAlarmCondition = "cv_alarm_condition"

	TableNameConfiguration        = "cv_configuration"
	TableNameConfigurationHistory = "cv_configuration_history"
	TableNameConfigurationPublish = "cv_configuration_publish"

	TableNamePmsRole         = "cv_pms_role"
	TableNamePmsRoleRef      = "cv_pms_role_ref"
	TableNamePmsRoleDetail   = "cv_pms_role_detail"
	TableNamePmsRoleRefGrant = "cv_pms_role_ref_grant"
	TableNamePmsCasbinRule   = "cv_pms_casbin_rule"
	TableNamePmsCustomRole   = "cv_pms_custom_role"
	TableNamePmsDefaultRole  = "cv_pms_default_role"

	TableNameBigDataNode        = "cv_bd_node"
	TableNameBigDataNodeResult  = "cv_bd_node_result"
	TableNameBigDataNodeContent = "cv_bd_node_content"
	TableNameBigDataNodeHistory = "cv_bd_node_history"
	TableNameBigDataFolder      = "cv_bd_folder"
	TableNameBigDataSource      = "cv_bd_source"
	TableNameBigDataWorkflow    = "cv_bd_workflow"
	TableNameBigDataDepend      = "cv_bd_depend"
	TableNameBigDataCrontab     = "cv_bd_crontab"
)
View Source 
const (
	CrontabStatusWait int = iota
	CrontabStatusPreempt
	CrontabStatusDoing
)
View Source 
const (
	SourceTypMySQL      = 1
	SourceTypClickHouse = 2
)
View Source 
const (
	PrimaryMining = 1
	PrimaryShort  = 3
)
View Source 
const (
	SecondaryAny             = 0
	SecondaryDatabase        = 1
	SecondaryDataIntegration = 2
	SecondaryDataMining      = 3
	SecondaryDashboard       = 4
)
View Source 
const (
	TertiaryClickHouse   = 10
	TertiaryMySQL        = 11
	TertiaryOfflineSync  = 20
	TertiaryRealTimeSync = 21
)
View Source 
const (
	NodeStatusDefault = 0
	NodeStatusHandler = 2
	NodeStatusError   = 3
	NodeStatusFinish  = 4
)

0 No status 2 Executing 3 Abnormal execution 4 Completed

View Source 
const (
	PmsRoleTypeDefault
	PmsRoleTypeCustom
)
View Source 
const (
	RefId = "{{ID}}" // is used to replace with real resourceObjId in ruleTpl when adding to casbin
	// used to generate "p" type ruleTpl like: role__{{PmsRole:Id}}__{{PmsRole:BelongResource}}__{{ID}},{{PmsRole:BelongResource}}__{{ID}}__subResource__(SubResourceRegex),ActsRegex,{{DOM}}
	TplOfRuleTpl = "role__%d__%s__{{ID}},%s__{{ID}}__subResource__%s,%s,*" // contains the const RefId. do not contain any blank chars
)
View Source 
const (
	ClusterStatusMaintaining
)

status of kubernetes cluster

View Source 
const (
	CrontabTypSuspended int
)
View Source 
const (
	SuffixJaegerJSON = "_jaeger_dependencies"
)
View Source 
const TimeFieldNanoseconds = "_time_nanosecond_"
View Source 
const TimeFieldSecond = "_time_second_"
View Source 
const (
	V3TableTypeJaegerJSON
)

Variables

View Source 
var (
	ErrCollectCreator      = errors.New("only the creator can modify")
	ErrCollectUpdateParams = errors.New("collect update params error")
)
View Source 
var (
	SourceMap = map[string]string{
		SourceInquiryMgtCenter: "Log",
		SourceUserMgtCenter:    "User",
		SourceSystemSetting:    "System",
		SourceClusterMgtCenter: "K8s",
		SourceAlarmMgtCenter:   "Alarm",
		SourceConfigMgtCenter:  "Configuration",
		SourceBigDataMgtCenter: "Analysis",
	}
	SourceOpnMap = map[string][]string{
		SourceInquiryMgtCenter: {
			OpnTablesDelete,
			OpnTablesCreate,
			OpnTablesUpdate,
			OpnTablesIndexUpdate,
			OpnTablesLogsQuery,
			OpnDatabasesDelete,
			OpnDatabasesCreate,
			OpnDatabasesUpdate,
			OpnInstancesDelete,
			OpnInstancesCreate,
			OpnInstancesUpdate,
			OpnViewsDelete,
			OpnViewsCreate,
			OpnViewsUpdate,
		},
		SourceClusterMgtCenter: {
			OpnClustersDelete,
			OpnClustersCreate,
			OpnClustersUpdate,
		},
		SourceAlarmMgtCenter: {
			OpnAlarmsDelete,
			OpnAlarmsCreate,
			OpnAlarmsUpdate,
			OpnAlarmsChannelsDelete,
			OpnAlarmsChannelsCreate,
			OpnAlarmsChannelsUpdate,
		},
		SourceConfigMgtCenter: {
			OpnConfigsDelete,
			OpnConfigsCreate,
			OpnConfigsUpdate,
			OpnConfigsPublish,
		},
		SourceUserMgtCenter: {OpnUserPwdChange, OpnUserCreate, OpnUserDelete, OpnUserPasswordReset},
		SourceSystemSetting: {OpnMigration},
		SourceBigDataMgtCenter: {
			OpnBigDataNodeCreate,
			OpnBigDataNodeUpdate,
			OpnBigDataNodeDelete,
			OpnBigDataFolderCreate,
			OpnBigDataFolderUpdate,
			OpnBigDataFolderDelete,
			OpnBigDataNodeCrontabCreate,
			OpnBigDataNodeCrontabUpdate,
			OpnBigDataNodeCrontabDelete,
			OpnBigDataNodeCrontabStop,
			OpnBigDataNodeResultUpdate,
			OpnBigDataWorkflowCreate,
			OpnBigDataWorkflowUpdate,
			OpnBigDataWorkflowDelete,
			OpnBigDataSourceCreate,
			OpnBigDataSourceUpdate,
			OpnBigDataSourceDelete,
			OpnBigDataNodeLock,
			OpnBigDataNodeUnlock,
			OpnBigDataNodeRun,
			OpnBigDataNodeStop},
	}
)
View Source 
var OperationMap = map[string]string{
	OpnTablesDelete:         "table delete",
	OpnTablesCreate:         "table create",
	OpnTablesUpdate:         "table update",
	OpnTableCreateSelfBuilt: "an existing data table is connected",
	OpnTablesIndexUpdate:    "table analysis field updates",
	OpnTablesLogsQuery:      "log query",
	OpnDatabasesDelete:      "database delete",
	OpnDatabasesCreate:      "database create",
	OpnDatabasesUpdate:      "database update",
	OpnInstancesDelete:      "instance delete",
	OpnInstancesCreate:      "instance create",
	OpnInstancesUpdate:      "instance update",
	OpnViewsDelete:          "custom time field delete",
	OpnViewsCreate:          "custom time field create",
	OpnViewsUpdate:          "custom time field update",

	OpnConfigsDelete:  "config delete",
	OpnConfigsCreate:  "config create",
	OpnConfigsUpdate:  "config update",
	OpnConfigsPublish: "config publish",
	OpnConfigsSync:    "synchronize the configuration from the target cluster",

	OpnClustersDelete:          "cluster delete",
	OpnClustersCreate:          "cluster create",
	OpnClustersUpdate:          "cluster update",
	OpnClustersConfigMapDelete: "cluster configmap delete",
	OpnClustersConfigMapCreate: "cluster configmap create",
	OpnClustersConfigMapUpdate: "cluster configmap update",

	OpnAlarmsDelete:         "alarm delete",
	OpnAlarmsCreate:         "alarm create",
	OpnAlarmsUpdate:         "alarm update",
	OpnAlarmsChannelsDelete: "alarm channel delete",
	OpnAlarmsChannelsCreate: "alarm channel create",
	OpnAlarmsChannelsUpdate: "alarm channel update",

	OpnMigration: "upgrading the database structure",

	OpnBigDataNodeCreate:        "node create",
	OpnBigDataNodeUpdate:        "node update",
	OpnBigDataNodeDelete:        "node delete",
	OpnBigDataFolderCreate:      "folder create",
	OpnBigDataFolderUpdate:      "folder update",
	OpnBigDataFolderDelete:      "folder delete",
	OpnBigDataNodeCrontabCreate: "node crontab create",
	OpnBigDataNodeCrontabUpdate: "node crontab update",
	OpnBigDataNodeCrontabDelete: "node crontab delete",
	OpnBigDataNodeCrontabStop:   "node crontab stop",
	OpnBigDataNodeResultUpdate:  "node run result update",
	OpnBigDataWorkflowCreate:    "workflow create",
	OpnBigDataWorkflowUpdate:    "workflow update",
	OpnBigDataWorkflowDelete:    "workflow delete",
	OpnBigDataSourceCreate:      "source create",
	OpnBigDataSourceUpdate:      "source update",
	OpnBigDataSourceDelete:      "source delete",
	OpnBigDataNodeLock:          "node lock",
	OpnBigDataNodeUnlock:        "node unlock",
	OpnBigDataNodeRun:           "node run",
	OpnBigDataNodeStop:          "node stop",

	OpnUserCreate:        "user create",
	OpnUserDelete:        "user delete",
	OpnUserPasswordReset: "user password reset",
	OpnUserPwdChange:     "change the password",
}
View Source 
var UnitMap = map[int]UnitItem{
	0: {
		Alias:    "m",
		Duration: time.Minute,
	},
	1: {
		Alias:    "s",
		Duration: time.Second,
	},
	2: {
		Alias:    "h",
		Duration: time.Hour,
	},
	3: {
		Alias:    "d",
		Duration: time.Hour * 24,
	},
	4: {
		Alias:    "w",
		Duration: time.Hour * 24 * 7,
	},
}

Functions

func AlarmChannelCreate 

func AlarmChannelCreate(db *gorm.DB, data *AlarmChannel) (err error)

func AlarmChannelDelete 

func AlarmChannelDelete(db *gorm.DB, id int) (err error)

func AlarmChannelUpdate 

func AlarmChannelUpdate(db *gorm.DB, id int, ups map[string]interface{}) (err error)

func AlarmConditionCreate 

func AlarmConditionCreate(db *gorm.DB, data *AlarmCondition) (err error)

func AlarmConditionDeleteBatch 

func AlarmConditionDeleteBatch(db *gorm.DB, alarmId int) (err error)

func AlarmCreate 

func AlarmCreate(db *gorm.DB, data *Alarm) (err error)

func AlarmDelete 

func AlarmDelete(db *gorm.DB, id int) (err error)

func AlarmFilterCreate 

func AlarmFilterCreate(db *gorm.DB, data *AlarmFilter) (err error)

func AlarmFilterDeleteBatch 

func AlarmFilterDeleteBatch(db *gorm.DB, alarmId int) (err error)

func AlarmFilterUpdateStatus added in v0.4.4 

func AlarmFilterUpdateStatus(db *gorm.DB, alarmId int, ups map[string]interface{}) (err error)

func AlarmHistoryCreate 

func AlarmHistoryCreate(db *gorm.DB, data *AlarmHistory) (err error)

func AlarmHistoryUpdate 

func AlarmHistoryUpdate(db *gorm.DB, id int, ups map[string]interface{}) (err error)

func AlarmUpdate 

func AlarmUpdate(db *gorm.DB, id int, ups map[string]interface{}) (err error)

func BuildPreloadArgs 

func BuildPreloadArgs(conds Conds) (args []interface{})

func BuildQuery 

func BuildQuery(conds Conds) (sql string, binds []interface{})

BuildQuery 根据conds构建sql和绑定的参数

func ClusterCreate 

func ClusterCreate(db *gorm.DB, data *Cluster) (err error)

ClusterCreate CRUD

func ClusterDelete 

func ClusterDelete(db *gorm.DB, id int) (err error)

ClusterDelete soft delete item by id

func ClusterUpdate 

func ClusterUpdate(db *gorm.DB, paramId int, ups map[string]interface{}) (err error)

ClusterUpdate ...

func ConfigurationCreate 

func ConfigurationCreate(db *gorm.DB, data *Configuration) (err error)

ConfigurationCreate CRUD

func ConfigurationDelete 

func ConfigurationDelete(db *gorm.DB, id int) (err error)

ConfigurationDelete 硬删除

func ConfigurationUpdate 

func ConfigurationUpdate(db *gorm.DB, paramId int, ups map[string]interface{}) (err error)

ConfigurationUpdate ...

func CreatePmsRole 

func CreatePmsRole(db *gorm.DB, data *PmsRole) (err error)

func CreatePmsRoleDetail 

func CreatePmsRoleDetail(db *gorm.DB, data *PmsRoleDetail) (err error)

func CrontabCreate added in v0.3.2 

func CrontabCreate(db *gorm.DB, data *BigdataCrontab) (err error)

func CrontabDelete added in v0.3.2 

func CrontabDelete(db *gorm.DB, nodeId int) (err error)

func CrontabUpdate added in v0.3.2 

func CrontabUpdate(db *gorm.DB, nodeId int, ups map[string]interface{}) (err error)

func DatabaseCreate 

func DatabaseCreate(db *gorm.DB, data *BaseDatabase) (err error)

DatabaseCreate ...

func DatabaseDelete 

func DatabaseDelete(db *gorm.DB, id int) (err error)

DatabaseDelete Soft delete

func DatabaseUpdate 

func DatabaseUpdate(db *gorm.DB, paramId int, ups map[string]interface{}) (err error)

DatabaseUpdate ...

func DeletePmsRoleById 

func DeletePmsRoleById(tx *gorm.DB, pmsRoleId int) (err error)

please make sure the associated casbinRules have removed after deleted pmsRole. do not only invoke this func to delete pmsRole.

func DeletePmsRoleRef 

func DeletePmsRoleRef(tx *gorm.DB, id int) (err error)

func DependsBatchInsert added in v0.3.2 

func DependsBatchInsert(db *gorm.DB, rows []*BigdataDepend) (err error)

func DependsDeleteAll added in v0.3.2 

func DependsDeleteAll(db *gorm.DB, iid int) (err error)

func FolderCreate added in v0.3.1 

func FolderCreate(db *gorm.DB, data *BigdataFolder) (err error)

func FolderDelete added in v0.3.1 

func FolderDelete(db *gorm.DB, id int) (err error)

func FolderUpdate added in v0.3.1 

func FolderUpdate(db *gorm.DB, id int, ups map[string]interface{}) (err error)

func GetAlarmTableInstanceInfo 

func GetAlarmTableInstanceInfo(id int) (alarmInfo Alarm, relatedList []*RespAlarmListRelatedInfo, err error)

func GetAlarmTableInstanceInfoWithCache added in v0.4.4 

func GetAlarmTableInstanceInfoWithCache(id int, cache map[int]*RespAlarmListRelatedInfo) (alarmInfo Alarm, relatedList []*RespAlarmListRelatedInfo, err error)

func HiddenFieldCreateBatch added in v0.3.1 

func HiddenFieldCreateBatch(db *gorm.DB, data []*BaseHiddenField) (err error)

func HiddenFieldDeleteByFields added in v0.3.1 

func HiddenFieldDeleteByFields(db *gorm.DB, fields []string) (err error)

func IndexCreate 

func IndexCreate(db *gorm.DB, data *BaseIndex) (err error)

func IndexDeleteBatch 

func IndexDeleteBatch(db *gorm.DB, tid int) (err error)

func InstanceCreate 

func InstanceCreate(db *gorm.DB, data *BaseInstance) (err error)

func InstanceDelete 

func InstanceDelete(db *gorm.DB, id int) (err error)

func InstanceKey 

func InstanceKey(id int) string

func InstanceUpdate 

func InstanceUpdate(db *gorm.DB, id int, ups map[string]interface{}) (err error)

func K8SConfigMapCreate 

func K8SConfigMapCreate(db *gorm.DB, data *K8SConfigMap) (err error)

K8SConfigMapCreate CRUD

func NodeContentCreate added in v0.3.1 

func NodeContentCreate(db *gorm.DB, data *BigdataNodeContent) (err error)

func NodeContentDelete added in v0.3.1 

func NodeContentDelete(db *gorm.DB, id int) (err error)

func NodeContentUpdate added in v0.3.1 

func NodeContentUpdate(db *gorm.DB, id int, ups map[string]interface{}) (err error)

func NodeCreate added in v0.3.1 

func NodeCreate(db *gorm.DB, data *BigdataNode) (err error)

func NodeDelete added in v0.3.1 

func NodeDelete(db *gorm.DB, id int) (err error)

func NodeHistoryCreate added in v0.3.1 

func NodeHistoryCreate(db *gorm.DB, data *BigdataNodeHistory) (err error)

func NodeResultCreate added in v0.3.2 

func NodeResultCreate(db *gorm.DB, data *BigdataNodeResult) (err error)

func NodeResultDelete30Days added in v0.3.2 

func NodeResultDelete30Days()

func NodeResultUpdate added in v0.3.2 

func NodeResultUpdate(db *gorm.DB, id int, ups map[string]interface{}) (err error)

func NodeUpdate added in v0.3.1 

func NodeUpdate(db *gorm.DB, id int, ups map[string]interface{}) (err error)

func PmsCustomRoleCreate 

func PmsCustomRoleCreate(item *PmsCustomRole) (err error)

func PmsCustomRoleDelete 

func PmsCustomRoleDelete(paramId int) (err error)

func PmsDefaultRoleCreate 

func PmsDefaultRoleCreate(item *PmsDefaultRole) (err error)

func PmsDefaultRoleDelete 

func PmsDefaultRoleDelete(paramId int) (err error)

func ShortURLCreate added in v0.4.3 

func ShortURLCreate(db *gorm.DB, data *BaseShortURL) (err error)

func ShortURLDelete30Days added in v0.4.3 

func ShortURLDelete30Days()

func ShortURLUpdate added in v0.4.3 

func ShortURLUpdate(db *gorm.DB, id int, ups map[string]interface{}) (err error)

func SourceCreate added in v0.3.1 

func SourceCreate(db *gorm.DB, data *BigdataSource) (err error)

func SourceDelete added in v0.3.1 

func SourceDelete(db *gorm.DB, id int) (err error)

func SourceUpdate added in v0.3.1 

func SourceUpdate(db *gorm.DB, id int, ups map[string]interface{}) (err error)

func TableCreate 

func TableCreate(db *gorm.DB, data *BaseTable) (err error)

TableCreate ...

func TableDelete 

func TableDelete(db *gorm.DB, id int) (err error)

TableDelete Soft delete

func TableUpdate 

func TableUpdate(db *gorm.DB, paramId int, ups map[string]interface{}) (err error)

TableUpdate ...

func UserCreate 

func UserCreate(db *gorm.DB, data *User) (err error)

UserCreate CRUD

func UserDelete 

func UserDelete(db *gorm.DB, id int) (err error)

UserDelete soft delete item by id

func UserUpdate 

func UserUpdate(db *gorm.DB, paramId int, ups map[string]interface{}) (err error)

UserUpdate ...

func ViewCreate 

func ViewCreate(db *gorm.DB, data *BaseView) (err error)

func ViewDelete 

func ViewDelete(db *gorm.DB, id int) (err error)

ViewDelete Soft delete

func ViewDeleteByTableID 

func ViewDeleteByTableID(db *gorm.DB, tid int) (err error)

ViewDeleteByTableID Soft delete

func ViewUpdate 

func ViewUpdate(db *gorm.DB, paramId int, ups map[string]interface{}) (err error)

ViewUpdate ...

func WorkflowCreate added in v0.3.1 

func WorkflowCreate(db *gorm.DB, data *BigdataWorkflow) (err error)

func WorkflowDelete added in v0.3.1 

func WorkflowDelete(db *gorm.DB, id int) (err error)

func WorkflowUpdate added in v0.3.1 

func WorkflowUpdate(db *gorm.DB, id int, ups map[string]interface{}) (err error)

Types

type Alarm 

type Alarm struct {
	BaseModel

	Uid        int           `gorm:"column:uid;type:int(11)" json:"uid"`                              // uid of alarm operator
	Uuid       string        `gorm:"column:uuid;type:varchar(128);NOT NULL" json:"uuid"`              // foreign key
	Name       string        `gorm:"column:name;type:varchar(128);NOT NULL" json:"alarmName"`         // name of an alarm
	Desc       string        `gorm:"column:desc;type:varchar(255);NOT NULL" json:"desc"`              // description
	Interval   int           `gorm:"column:interval;type:int(11)" json:"interval"`                    // interval second between alarm
	Unit       int           `gorm:"column:unit;type:int(11)" json:"unit"`                            // 0 m 1 s 2 h 3 d 4 w 5 y
	Tags       String2String `gorm:"column:tag;type:text" json:"tag"`                                 // tags
	ChannelIds Ints          `gorm:"column:channel_ids;type:varchar(255);NOT NULL" json:"channelIds"` // channel of an alarm
	NoDataOp   int           `gorm:"column:no_data_op;type:int(11)" db:"no_data_op" json:"noDataOp"`  // noDataOp 0 nodata 1 ok 2 alert
	Level      int           `gorm:"column:level;type:int(11)" json:"level"`                          // 0 m 1 s 2 h 3 d 4 w 5 y
	Status     int           `gorm:"column:status;type:int(11)" json:"status"`                        // status

	User *User `json:"user,omitempty" gorm:"foreignKey:uid;references:id"`

	// v2 field to support multiple alarm conditions
	ViewDDLs   String2String `gorm:"column:view_ddl_s;type:text" json:"viewDDLs"` // Users to store data generates the alarm condition
	TableIds   Ints          `gorm:"column:table_ids;type:varchar(255);NOT NULL" json:"tableIds"`
	AlertRules String2String `gorm:"column:alert_rules;type:text" json:"alertRules"` // prometheus alert rule

	// Deprecated: Tid
	Tid int `gorm:"column:tid;type:int(11)" json:"tid"` // table id
	// Deprecated: AlertRule will be replaced by AlertRules field, is expected to delete 0.5.0 version
	AlertRule string `gorm:"column:alert_rule;type:text" json:"alertRule"` // prometheus alert rule
	// Deprecated: View
	View string `gorm:"column:view;type:text" json:"view"` // view table ddl
	// Deprecated: ViewTableName
	ViewTableName string `gorm:"column:view_table_name;type:varchar(255)" json:"viewTableName"` // name of view table
}

func AlarmInfo 

func AlarmInfo(db *gorm.DB, id int) (resp Alarm, err error)

func AlarmInfoX 

func AlarmInfoX(db *gorm.DB, conds map[string]interface{}) (resp Alarm, err error)

func AlarmList 

func AlarmList(conds egorm.Conds) (resp []*Alarm, err error)

func AlarmListByDidPage 

func AlarmListByDidPage(conds egorm.Conds, reqList *ReqPage) (total int64, respList []*Alarm)

func AlarmListByTidArr added in v0.4.4 

func AlarmListByTidArr(conds egorm.Conds, tidArr []int) (resp []*Alarm, err error)

func AlarmListPageByTidArr added in v0.4.4 

func AlarmListPageByTidArr(conds egorm.Conds, reqList *ReqPage, tidArr []int) (total int64, respList []*Alarm)

AlarmListPageByTidArr return item list by pagination SELECT * FROM `cv_alarm` WHERE JSON_CONTAINS(`table_ids`, '[1]') OR JSON_CONTAINS(`table_ids`, '[7]')

func (*Alarm) AlertInterval 

func (m *Alarm) AlertInterval() string

func (*Alarm) GetStatus added in v0.4.4 

func (m *Alarm) GetStatus(db *gorm.DB) int

func (*Alarm) RuleName added in v0.4.3 

func (m *Alarm) RuleName(filterId int) string

func (*Alarm) RuleNameMap added in v0.4.3 

func (m *Alarm) RuleNameMap() map[int][]string

RuleNameMap 提供 rule 兼容

func (*Alarm) TableName 

func (m *Alarm) TableName() string

func (*Alarm) UniqueName added in v0.4.3 

func (m *Alarm) UniqueName(filterId int) string

func (*Alarm) UpdateStatus added in v0.4.4 

func (m *Alarm) UpdateStatus(db *gorm.DB, status int) (err error)

func (*Alarm) ViewName added in v0.4.3 

func (m *Alarm) ViewName(database, table string, seq int) string

type AlarmChannel 

type AlarmChannel struct {
	BaseModel

	Name string `gorm:"column:name;type:varchar(128);NOT NULL" json:"name"` // 告警渠道名称
	Key  string `gorm:"column:key;type:text" json:"key"`                    // 关键信息
	Typ  int    `gorm:"column:typ;type:int(11)" json:"typ"`                 // 告警类型：0 dd
	Uid  int    `gorm:"column:uid;type:int(11)" json:"uid"`                 // 操作人
}

AlarmChannel 告警渠道

func AlarmChannelInfo 

func AlarmChannelInfo(db *gorm.DB, id int) (resp AlarmChannel, err error)

func AlarmChannelList 

func AlarmChannelList(conds egorm.Conds) (resp []*AlarmChannel, err error)

func (*AlarmChannel) JudgmentType added in v0.4.4 

func (m *AlarmChannel) JudgmentType() (err error)

JudgmentType judgment channel key legality temporary support slack feishu

func (*AlarmChannel) TableName 

func (m *AlarmChannel) TableName() string

type AlarmCondition 

type AlarmCondition struct {
	BaseModel

	AlarmId        int `gorm:"column:alarm_id;type:int(11)" json:"alarmId"`              // alarm id
	FilterId       int `gorm:"column:filter_id;type:int(11)" json:"filterId"`            // filter id
	SetOperatorTyp int `gorm:"column:set_operator_typ;type:int(11);NOT NULL" json:"typ"` // 0 WHEN 1 AND 2 OR
	SetOperatorExp int `gorm:"column:set_operator_exp;type:int(11);NOT NULL" json:"exp"` // 0 avg 1 min 2 max 3 sum 4 count
	Cond           int `gorm:"column:cond;type:int(11)" json:"cond"`                     // 0 above 1 below 2 outside range 3 within range
	Val1           int `gorm:"column:val_1;type:int(11)" json:"val1"`                    // 基准值/最小值
	Val2           int `gorm:"column:val_2;type:int(11)" json:"val2"`                    // 最大值
}

AlarmCondition alarm statement，the trigger condition

func AlarmConditionList 

func AlarmConditionList(conds egorm.Conds) (resp []*AlarmCondition, err error)

func (*AlarmCondition) TableName 

func (m *AlarmCondition) TableName() string

type AlarmFilter 

type AlarmFilter struct {
	BaseModel

	Tid            int    `gorm:"column:tid;type:int(11)" json:"tid"`                            // table id
	AlarmId        int    `gorm:"column:alarm_id;type:int(11)" json:"alarmId"`                   // alarm id
	When           string `gorm:"column:when;type:text" json:"when"`                             // 执行条件
	SetOperatorTyp int    `gorm:"column:set_operator_typ;type:int(11);NOT NULL" json:"typ"`      // 0 default 1 INNER 2 LEFT OUTER 3 RIGHT OUTER 4 FULL OUTER 5 CROSS
	SetOperatorExp string `gorm:"column:set_operator_exp;type:varchar(255);NOT NULL" json:"exp"` // 操作
	Mode           int    `gorm:"column:mode;type:int(11)" json:"mode"`                          // 0 m 1 s 2 h 3 d 4 w 5 y
	Status         int    `gorm:"column:status;type:int(11)" json:"status"`
}

func AlarmFilterInfo 

func AlarmFilterInfo(db *gorm.DB, id int) (resp AlarmFilter, err error)

func AlarmFilterList 

func AlarmFilterList(db *gorm.DB, conds egorm.Conds) (resp []*AlarmFilter, err error)

func (*AlarmFilter) TableName 

func (m *AlarmFilter) TableName() string

func (*AlarmFilter) UpdateStatus added in v0.4.4 

func (m *AlarmFilter) UpdateStatus(db *gorm.DB) error

type AlarmHistory 

type AlarmHistory struct {
	BaseModel

	AlarmId      int `gorm:"column:alarm_id;type:int(11)" json:"alarmId"`   // alarm id
	FilterId     int `gorm:"column:filter_id;type:int(11)" json:"filterId"` // filter id
	FilterStatus int `gorm:"column:filter_status;type:int(11)" json:"filterStatus"`
	IsPushed     int `gorm:"column:is_pushed;type:int(11)" json:"isPushed"` // alarm id
}

AlarmHistory 告警渠道

func AlarmHistoryInfo 

func AlarmHistoryInfo(db *gorm.DB, id int) (resp AlarmHistory, err error)

func AlarmHistoryPage 

func AlarmHistoryPage(conds egorm.Conds, reqList *ReqPage) (total int64, respList []*AlarmHistory)

func (*AlarmHistory) TableName 

func (m *AlarmHistory) TableName() string

type Alert added in v0.4.4 

type Alert struct {
	Labels      map[string]string `json:"labels"`
	Annotations map[string]string `json:"annotations"`
	StartsAt    time.Time         `json:"startsAt"`
	EndsAt      time.Time         `json:"endsAt"`
}

type BaseDatabase added in v0.3.1 

type BaseDatabase struct {
	BaseModel

	Iid          int    `gorm:"column:iid;type:int(11);index:uix_iid_name,unique" json:"iid"`                // datasource instance id
	Name         string `gorm:"column:name;type:varchar(64);index:uix_iid_name,unique;NOT NULL" json:"name"` // datasource database name
	Uid          int    `gorm:"column:uid;type:int(11)" json:"uid"`                                          // datasource operator uid
	Cluster      string `gorm:"column:cluster;type:varchar(128);NOT NULL" json:"cluster"`                    // cluster
	IsCreateByCV int    `gorm:"column:is_create_by_cv;type:tinyint(1)" json:"isCreateByCV"`
	Desc         string `gorm:"column:desc;type:varchar(255)" json:"desc"`

	Instance *BaseInstance `json:"instance,omitempty" gorm:"foreignKey:Iid;references:ID"`
}

BaseDatabase 数据库管理

func DatabaseGetOrCreate 

func DatabaseGetOrCreate(db *gorm.DB, uid, iid int, name, cluster string) (resp BaseDatabase, err error)

func DatabaseInfo 

func DatabaseInfo(db *gorm.DB, paramId int) (resp BaseDatabase, err error)

func DatabaseInfoX 

func DatabaseInfoX(db *gorm.DB, conds map[string]interface{}) (resp BaseDatabase, err error)

DatabaseInfoX Info extension method to query a single record according to Cond

func DatabaseList 

func DatabaseList(db *gorm.DB, conds egorm.Conds) (resp []*BaseDatabase, err error)

DatabaseList Get all currently undeleted clusters. Mainly used for front end

func (*BaseDatabase) TableName added in v0.3.1 

func (b *BaseDatabase) TableName() string

type BaseHiddenField added in v0.3.1 

type BaseHiddenField struct {
	BaseModel

	Tid   int    `gorm:"column:tid;type:int(11);index:uix_tid_field,unique" json:"tid"`                   // table id idx
	Field string `gorm:"column:field;type:varchar(128);NOT NULL;index:uix_tid_field,unique" json:"field"` // index field name
}

func HiddenFieldList added in v0.3.1 

func HiddenFieldList(conds egorm.Conds) (resp []*BaseHiddenField, err error)

func (*BaseHiddenField) TableName added in v0.3.1 

func (b *BaseHiddenField) TableName() string

type BaseIndex added in v0.3.1 

type BaseIndex struct {
	BaseModel

	Tid      int    `gorm:"column:tid;type:int(11);index:uix_tid_field_root,unique" json:"tid"`                         // table id
	Field    string `gorm:"column:field;type:varchar(64);NOT NULL;index:uix_tid_field_root,unique" json:"field"`        // index field name
	RootName string `gorm:"column:root_name;type:varchar(64);NOT NULL;index:uix_tid_field_root,unique" json:"rootName"` // root_name
	Typ      int    `gorm:"column:typ;type:int(11);NOT NULL" json:"typ"`                                                // 0 string 1 int 2 float
	HashTyp  int    `gorm:"column:hash_typ;type:tinyint(1)" json:"hashTyp"`                                             // hash type, 0 no hash 1 sipHash64 2 URLHash
	Alias    string `gorm:"column:alias;type:varchar(128);NOT NULL" json:"alias"`                                       // index filed alias name
}

BaseIndex 索引数据存储

func IndexInfo 

func IndexInfo(db *gorm.DB, id int) (resp BaseIndex, err error)

func IndexList 

func IndexList(conds egorm.Conds) (resp []*BaseIndex, err error)

func (*BaseIndex) GetFieldName added in v0.3.1 

func (t *BaseIndex) GetFieldName() string

func (*BaseIndex) GetHashFieldName added in v0.3.1 

func (t *BaseIndex) GetHashFieldName() (string, bool)

func (*BaseIndex) TableName added in v0.3.1 

func (b *BaseIndex) TableName() string

type BaseInstance added in v0.3.1 

type BaseInstance struct {
	BaseModel

	Datasource       string  `gorm:"column:datasource;type:varchar(32);NOT NULL;index:idx_datasource_name,unique" json:"datasource"` // datasource type
	Name             string  `gorm:"column:name;type:varchar(128);NOT NULL;index:idx_datasource_name,unique" json:"name"`            // datasource instance name
	Dsn              string  `gorm:"column:dsn;type:text" json:"dsn"`                                                                // dsn
	RuleStoreType    int     `gorm:"column:rule_store_type;type:int(11)" json:"ruleStoreType"`                                       // rule_store_type 1 文件 2 集群
	FilePath         string  `gorm:"column:file_path;type:varchar(255)" json:"filePath"`                                             // file_path
	Desc             string  `gorm:"column:desc;type:varchar(255)" json:"desc"`                                                      // file_path
	ClusterId        int     `gorm:"column:cluster_id;type:int(11)" json:"clusterId"`                                                // cluster_id
	Namespace        string  `gorm:"column:namespace;type:varchar(128)" json:"namespace"`                                            // namespace
	Configmap        string  `gorm:"column:configmap;type:varchar(128)" json:"configmap"`                                            // configmap
	PrometheusTarget string  `gorm:"column:prometheus_target;type:varchar(128)" json:"prometheusTarget"`                             // prometheus ip or domain, eg: https://prometheus:9090
	Mode             int     `gorm:"column:mode;type:tinyint(1)" json:"mode"`                                                        // 0 standalone 1 cluster
	ReplicaStatus    int     `gorm:"column:replica_status;type:tinyint(1)" json:"replicaStatus"`                                     // status 0 has replica 1 no replica
	Clusters         Strings `gorm:"column:clusters;type:text" json:"clusters"`
}

BaseInstance 服务配置存储

func InstanceInfo 

func InstanceInfo(db *gorm.DB, id int) (resp BaseInstance, err error)

func InstanceInfoX 

func InstanceInfoX(db *gorm.DB, conds map[string]interface{}) (resp BaseInstance, err error)

InstanceInfoX Info extension method to query a single record according to Cond

func InstanceList 

func InstanceList(conds egorm.Conds, extra ...string) (resp []*BaseInstance, err error)

InstanceList ..

func (*BaseInstance) DsKey added in v0.3.1 

func (b *BaseInstance) DsKey() string

func (*BaseInstance) TableName added in v0.3.1 

func (b *BaseInstance) TableName() string

type BaseModel 

type BaseModel struct {
	ID    int               `gorm:"not null;primary_key;AUTO_INCREMENT;comment:自增id" json:"id"`
	Ctime int64             `gorm:"bigint;autoCreateTime;comment:创建时间" json:"ctime"`
	Utime int64             `gorm:"bigint;autoUpdateTime;comment:更新时间" json:"utime"`
	Dtime sdelete.DeletedAt `gorm:"bigint;comment:删除时间" json:"dtime"`
}

type BaseShortURL added in v0.4.3 

type BaseShortURL struct {
	BaseModel

	OriginUrl string `gorm:"column:origin_url;type:text" json:"origin_url"`
	SCode     string `gorm:"column:s_code;type:varchar(64);NOT NULL" json:"s_code"`
	CallCnt   int    `gorm:"column:call_cnt;type:int(11)" json:"call_cnt"`
}

func ShortURLInfoBySCode added in v0.4.3 

func ShortURLInfoBySCode(db *gorm.DB, sCode string) (resp BaseShortURL, err error)

func (*BaseShortURL) TableName added in v0.4.3 

func (b *BaseShortURL) TableName() string

type BaseTable added in v0.3.1 

type BaseTable struct {
	BaseModel

	Did                     int    `gorm:"column:did;type:int(11);index:uix_did_name,unique" json:"did"`                 // database id
	Name                    string `gorm:"column:name;type:varchar(128);NOT NULL;index:uix_did_name,unique" json:"name"` // table
	Typ                     int    `gorm:"column:typ;type:int(11)" json:"typ"`                                           // table type, 1 string 2 float
	Days                    int    `gorm:"column:days;type:int(11)" json:"days"`                                         // data expire days
	Brokers                 string `gorm:"column:brokers;type:varchar(255);NOT NULL" json:"brokers"`                     // kafka broker
	Topic                   string `gorm:"column:topic;type:varchar(128);NOT NULL" json:"topic"`                         // kafka topic
	ConsumerNum             int    `gorm:"column:consumer_num;type:int(11)" json:"consumerNum"`                          // kafka consumer number
	SqlData                 string `gorm:"column:sql_data;type:text" json:"sqlData"`                                     // sql_data
	SqlStream               string `gorm:"column:sql_stream;type:text" json:"sqlStream"`                                 // sql_stream
	SqlView                 string `gorm:"column:sql_view;type:text" json:"sqlView"`                                     // sql_view
	SqlDistributed          string `gorm:"column:sql_distributed;type:text" json:"sqlDistributed"`                       // sql_distributed
	Uid                     int    `gorm:"column:uid;type:int(11)" json:"uid"`                                           // operator uid
	CreateType              int    `gorm:"column:create_type;type:tinyint(1)" json:"createType"`                         // operation type, 0 means create clickvisual fresh table, 1 means use exists table
	TimeField               string `gorm:"column:time_field;type:varchar(128);NOT NULL" json:"timeField"`                // custom time filed name of _time_
	TimeFieldType           int    `gorm:"column:time_field_type;type:int(11);default:0;NOT NULL" json:"timeFieldType"`  // custom time filed type name of _time_
	Desc                    string `gorm:"column:desc;type:varchar(255)" json:"desc"`
	RawLogField             string `gorm:"column:raw_log_field;type:varchar(255)" json:"rawLogField"`
	SelectFields            string `gorm:"column:select_fields;type:text" json:"selectFields"` // sql_distributed
	AnyJSON                 string `gorm:"column:any_json;type:text" json:"anyJSON"`
	KafkaSkipBrokenMessages int    `gorm:"column:kafka_skip_broken_messages;type:int(11)" json:"kafkaSkipBrokenMessages"`
	IsKafkaTimestamp        int    `gorm:"column:is_kafka_timestamp;type:tinyint(1)" json:"isKafkaTimestamp"`

	TraceTableId int `gorm:"column:trace_table_id;type:int(11)" json:"traceTableId"`
	V3TableType  int `gorm:"column:v3_table_type;type:int(11)" json:"v3TableType"` // 0 default 1 jaegerJson

	Database *BaseDatabase `json:"database,omitempty" gorm:"foreignKey:Did;references:ID"`
}

func TableInfo 

func TableInfo(db *gorm.DB, paramId int) (resp BaseTable, err error)

func TableInfoX 

func TableInfoX(db *gorm.DB, conds map[string]interface{}) (resp BaseTable, err error)

TableInfoX Info extension method to query a single record according to Cond

func TableList 

func TableList(db *gorm.DB, conds egorm.Conds) (resp []*BaseTable, err error)

TableList Get all currently undeleted clusters. Mainly used for front end

func TableListByInstanceId added in v0.4.4 

func TableListByInstanceId(db *gorm.DB, iid int) (resp []*BaseTable, err error)

func (*BaseTable) GetTimeField added in v0.3.1 

func (b *BaseTable) GetTimeField() string

func (*BaseTable) TableName added in v0.3.1 

func (b *BaseTable) TableName() string

type BaseView added in v0.3.1 

type BaseView struct {
	BaseModel

	Tid              int    `gorm:"column:tid;type:int(11);index:uix_tid_name,unique" json:"tid"`                // table id
	Name             string `gorm:"column:name;type:varchar(64);NOT NULL;index:uix_tid_name,unique" json:"name"` // view name
	IsUseDefaultTime int    `gorm:"column:is_use_default_time;type:int(11)" json:"isUseDefaultTime"`             // use system time or not
	Key              string `gorm:"column:key;type:varchar(64);NOT NULL" json:"key"`                             // field name of time in raw log
	Format           string `gorm:"column:format;type:varchar(64);NOT NULL" json:"format"`                       // timestamp parse to extract time from raw log and parse it to datetime
	SqlView          string `gorm:"column:sql_view;type:text" json:"sqlView"`                                    // sql_view
	Uid              int    `gorm:"column:uid;type:int(11)" json:"uid"`                                          // operator uid
}

BaseView Materialized view management

func ViewInfo 

func ViewInfo(db *gorm.DB, paramId int) (resp BaseView, err error)

func ViewInfoX 

func ViewInfoX(conds map[string]interface{}) (resp BaseView, err error)

ViewInfoX Info extension method to query a single record according to Cond

func ViewList 

func ViewList(db *gorm.DB, conds egorm.Conds) (resp []*BaseView, err error)

ViewList Get all currently undeleted clusters. Mainly used for front end

func (*BaseView) TableName added in v0.3.1 

func (b *BaseView) TableName() string

type BigdataCrontab added in v0.3.2 

type BigdataCrontab struct {
	NodeId        int    `gorm:"column:node_id;type:int(11);uix_node_id,unique" json:"nodeId"`
	Desc          string `gorm:"column:desc;type:varchar(255);NOT NULL" json:"desc"` // description
	DutyUid       int    `gorm:"column:duty_uid;type:int(11)" json:"dutyUid"`        // person in charge
	Cron          string `gorm:"column:cron;type:varchar(255);NOT NULL" json:"cron"` // cron expression
	Typ           int    `gorm:"column:typ;type:int(11)" json:"typ"`                 // typ 0 Normal scheduling 1 Suspended scheduling
	Status        int    `gorm:"column:status;type:int(11)" json:"status"`           // status 0 default 1 preempt 2 doing
	Uid           int    `gorm:"column:uid;type:int(11)" json:"uid"`                 // user id
	Args          string `gorm:"args:sql_view;type:text" json:"args"`                // sql_view
	IsRetry       int    `gorm:"column:is_retry;type:tinyint(1)" json:"isRetry"`
	RetryTimes    int    `gorm:"column:retry_times;type:int(11)" json:"retryTimes"`
	RetryInterval int    `gorm:"column:retry_interval;type:int(11)" json:"retryInterval"`
	Ctime         int64  `gorm:"bigint;autoCreateTime;comment:创建时间" json:"ctime"`
	Utime         int64  `gorm:"bigint;autoUpdateTime;comment:更新时间" json:"utime"`
	ChannelIds    Ints   `gorm:"column:channel_ids;type:varchar(255);NOT NULL" json:"channelIds"` // channel of an alarm
}

func CrontabInfo added in v0.3.2 

func CrontabInfo(db *gorm.DB, nodeId int) (resp BigdataCrontab, err error)

func CrontabList added in v0.3.2 

func CrontabList(conds egorm.Conds) (resp []*BigdataCrontab, err error)

func (*BigdataCrontab) TableName added in v0.3.2 

func (m *BigdataCrontab) TableName() string

type BigdataDepend added in v0.3.2 

type BigdataDepend struct {
	Iid                  int     `gorm:"column:iid;type:int(11);index:uix_iid_database_table,unique" json:"iid"`
	Database             string  `gorm:"column:database;type:varchar(64);index:uix_iid_database_table,unique;NOT NULL" json:"database"`
	Table                string  `gorm:"column:table;type:varchar(128);index:uix_iid_database_table,unique;NOT NULL" json:"table"`
	Engine               string  `gorm:"column:engine;type:varchar(128);NOT NULL" json:"engine"`
	DownDepDatabaseTable Strings `gorm:"column:down_dep_database_table;type:text;NOT NULL" json:"downDepDatabaseTable"`
	UpDepDatabaseTable   Strings `gorm:"column:up_dep_database_table;type:text;NOT NULL" json:"upDepDatabaseTable"`
	Rows                 uint64  `gorm:"column:rows;type:bigint(20);default:0;NOT NULL" json:"rows"`
	Bytes                uint64  `gorm:"column:bytes;type:bigint(20);default:0;NOT NULL" json:"bytes"`

	Utime int64 `gorm:"bigint;autoUpdateTime;comment:更新时间" json:"utime"`
}

func DependsList added in v0.3.2 

func DependsList(conds egorm.Conds) (resp []*BigdataDepend, err error)

func EarliestDependRow added in v0.4.3 

func EarliestDependRow(iid int) (resp BigdataDepend, err error)

func (*BigdataDepend) Key added in v0.3.2 

func (m *BigdataDepend) Key() string

func (*BigdataDepend) Name added in v0.3.2 

func (m *BigdataDepend) Name() string

func (*BigdataDepend) TableName added in v0.3.2 

func (m *BigdataDepend) TableName() string

type BigdataFolder added in v0.3.1 

type BigdataFolder struct {
	BaseModel

	Uid        int    `gorm:"column:uid;type:int(11)" json:"uid"` // uid of alarm operator
	Iid        int    `gorm:"column:iid;type:int(11)" json:"iid"`
	Name       string `gorm:"column:name;type:varchar(128);NOT NULL" json:"name"` // name of an alarm
	Desc       string `gorm:"column:desc;type:varchar(255);NOT NULL" json:"desc"` // description
	Primary    int    `gorm:"column:primary;type:int(11)" json:"primary"`
	Secondary  int    `gorm:"column:secondary;type:int(11)" json:"secondary"`
	WorkflowId int    `gorm:"column:workflow_id;type:int(11)" json:"workflowId"`
	ParentId   int    `gorm:"column:parent_id;type:int(11)" json:"parentId"`
}

func FolderInfo added in v0.3.1 

func FolderInfo(db *gorm.DB, id int) (resp BigdataFolder, err error)

func FolderList added in v0.3.1 

func FolderList(conds egorm.Conds) (resp []*BigdataFolder, err error)

func (*BigdataFolder) TableName added in v0.3.1 

func (m *BigdataFolder) TableName() string

type BigdataNode added in v0.3.1 

type BigdataNode struct {
	BaseModel

	Uid        int    `gorm:"column:uid;type:int(11)" json:"uid"`
	Iid        int    `gorm:"column:iid;type:int(11)" json:"iid"`
	FolderID   int    `gorm:"column:folder_id;type:int(11)" json:"folderId"`
	Primary    int    `gorm:"column:primary;type:int(11)" json:"primary"`
	Secondary  int    `gorm:"column:secondary;type:int(11)" json:"secondary"`
	Tertiary   int    `gorm:"column:tertiary;type:int(11)" json:"tertiary"`
	WorkflowId int    `gorm:"column:workflow_id;type:int(11)" json:"workflowId"`
	SourceId   int    `gorm:"column:sourceId;type:int(11)" json:"sourceId"`
	Name       string `gorm:"column:name;type:varchar(128);NOT NULL" json:"name"`
	Desc       string `gorm:"column:desc;type:varchar(255);NOT NULL" json:"desc"`
	LockUid    int    `gorm:"column:lock_uid;type:int(11) unsigned" json:"lockUid"`
	LockAt     int64  `gorm:"column:lock_at;type:int(11)" json:"lockAt"`
	Status     int    `gorm:"column:status;type:int(11)" json:"status"` // 0 无状态 1 待执行 2 执行中 3 执行异常 4 执行完成
	UUID       string `gorm:"column:uuid;type:varchar(128)" json:"uuid"`
}

func NodeInfo added in v0.3.1 

func NodeInfo(db *gorm.DB, id int) (resp BigdataNode, err error)

func NodeList added in v0.3.1 

func NodeList(conds egorm.Conds) (resp []*BigdataNode, err error)

func NodeListWithWorker added in v0.4.3 

func NodeListWithWorker() (resp []*BigdataNode, err error)

NodeListWithWorker ... TertiaryClickHouse = 10 TertiaryMySQL = 11 TertiaryOfflineSync = 20

func (*BigdataNode) TableName added in v0.3.1 

func (m *BigdataNode) TableName() string

type BigdataNodeContent added in v0.3.1 

type BigdataNodeContent struct {
	NodeId          int    `gorm:"column:node_id;type:int(11);uix_node_id,unique" json:"nodeId"`
	Content         string `gorm:"column:content;type:longtext" json:"content"`
	Result          string `gorm:"column:result;type:longtext" json:"result"`
	PreviousContent string `gorm:"column:previous_content;type:longtext" json:"previousContent"`
	Utime           int64  `gorm:"bigint;autoUpdateTime;comment:update time" json:"utime"`
}

func NodeContentInfo added in v0.3.1 

func NodeContentInfo(db *gorm.DB, id int) (resp BigdataNodeContent, err error)

func (*BigdataNodeContent) TableName added in v0.3.1 

func (m *BigdataNodeContent) TableName() string

type BigdataNodeHistory added in v0.3.1 

type BigdataNodeHistory struct {
	UUID    string `gorm:"column:uuid;type:varchar(128);uix_uuid,unique" json:"uuid"`
	NodeId  int    `gorm:"column:node_id;type:int(11)" json:"nodeId"`
	Content string `gorm:"column:content;type:longtext" json:"content"`
	Uid     int    `gorm:"column:uid;type:int(11)" json:"uid"`
	Utime   int64  `gorm:"bigint;autoUpdateTime;comment:update time" json:"utime"`
}

func NodeHistoryInfo added in v0.3.1 

func NodeHistoryInfo(db *gorm.DB, uuid string) (resp BigdataNodeHistory, err error)

func NodeHistoryListPage added in v0.3.1 

func NodeHistoryListPage(conds egorm.Conds, reqList *ReqPage) (total int64, respList []*BigdataNodeHistory)

func (*BigdataNodeHistory) TableName added in v0.3.1 

func (m *BigdataNodeHistory) TableName() string

type BigdataNodeResult added in v0.3.2 

type BigdataNodeResult struct {
	BaseModel

	NodeId       int    `gorm:"column:node_id;type:int(11)" json:"nodeId"`
	Content      string `gorm:"column:content;type:longtext" json:"content"`
	Result       string `gorm:"column:result;type:longtext" json:"result"`
	ExcelProcess string `gorm:"column:excel_process;type:longtext" json:"excelProcess"`
	Uid          int    `gorm:"column:uid;type:int(11)" json:"uid"`
	Cost         int64  `gorm:"column:cost;type:bigint(20)" json:"cost"` // ms
	Status       int    `gorm:"column:status;type:int(11)" json:"status"`
}

func NodeResultInfo added in v0.3.2 

func NodeResultInfo(db *gorm.DB, id int) (resp BigdataNodeResult, err error)

func NodeResultList added in v0.3.2 

func NodeResultList(conds egorm.Conds) (resp []*BigdataNodeResult, err error)

func NodeResultListPage added in v0.3.2 

func NodeResultListPage(conds egorm.Conds, reqList *ReqPage) (total int64, respList []*BigdataNodeResult)

func (*BigdataNodeResult) TableName added in v0.3.2 

func (m *BigdataNodeResult) TableName() string

type BigdataSource added in v0.3.1 

type BigdataSource struct {
	BaseModel

	Iid      int    `gorm:"column:iid;type:int(11)" json:"iid"`
	Name     string `gorm:"column:name;type:varchar(128);NOT NULL" json:"name"` // name of an alarm
	Desc     string `gorm:"column:desc;type:varchar(255);NOT NULL" json:"desc"` // description
	URL      string `gorm:"column:url;type:varchar(255);NOT NULL" json:"url"`
	UserName string `gorm:"column:username;type:varchar(255);NOT NULL" json:"username"`
	Password string `gorm:"column:password;type:varchar(255);NOT NULL" json:"password"`
	Typ      int    `gorm:"column:typ;type:int(11)" json:"typ"`
	Uid      int    `gorm:"column:uid;type:int(11)" json:"uid"`
}

func SourceInfo added in v0.3.1 

func SourceInfo(db *gorm.DB, id int) (resp BigdataSource, err error)

func SourceList added in v0.3.1 

func SourceList(conds egorm.Conds) (resp []*BigdataSource, err error)

func (*BigdataSource) TableName added in v0.3.1 

func (m *BigdataSource) TableName() string

type BigdataWorkflow added in v0.3.1 

type BigdataWorkflow struct {
	BaseModel

	Iid  int    `gorm:"column:iid;type:int(11)" json:"iid"`
	Name string `gorm:"column:name;type:varchar(128);NOT NULL" json:"name"` // name of an alarm
	Desc string `gorm:"column:desc;type:varchar(255);NOT NULL" json:"desc"` // description
	Uid  int    `gorm:"column:uid;type:int(11)" json:"uid"`
}

func WorkflowInfo added in v0.3.1 

func WorkflowInfo(db *gorm.DB, id int) (resp BigdataWorkflow, err error)

func WorkflowList added in v0.3.1 

func WorkflowList(conds egorm.Conds) (resp []*BigdataWorkflow, err error)

func (*BigdataWorkflow) TableName added in v0.3.1 

func (m *BigdataWorkflow) TableName() string

type CasbinRules 

type CasbinRules []*PmsCasbinRule

type Cluster 

type Cluster struct {
	BaseModel

	Name        string `gorm:"column:name;type:varchar(128);NOT NULL;index:uix_cluster_name,unique" json:"clusterName"` // unique name of cluster
	Description string `gorm:"column:description;type:varchar(128)" json:"description"`                                 // brief description of cluster
	Status      int    `gorm:"column:status;type:tinyint(1)" json:"status"`                                             // 0 means Well-Running, others mean not running
	ApiServer   string `gorm:"column:api_server;type:varchar(255);NOT NULL" json:"apiServer"`                           // address of cluster API server
	KubeConfig  string `gorm:"column:kube_config;type:mediumtext;NOT NULL" json:"kubeConfig"`                           // raw content of kube config
}

func ClusterInfo 

func ClusterInfo(paramId int) (resp Cluster, err error)

func ClusterListHideSensitiveInfo 

func ClusterListHideSensitiveInfo(conds egorm.Conds) (resp []*Cluster, err error)

func ClusterListPage 

func ClusterListPage(conds egorm.Conds, reqList *ReqPage) (total int64, respList []*Cluster)

ClusterListPage return item list by pagination

func ClusterNormalInfo 

func ClusterNormalInfo(paramId int) (resp Cluster, err error)

func ClusterNormalList 

func ClusterNormalList(conds egorm.Conds) (resp []*Cluster, err error)

func (*Cluster) Key 

func (m *Cluster) Key() string

func (*Cluster) TableName 

func (m *Cluster) TableName() string

type Collect added in v0.4.4 

type Collect struct {
	BaseModel

	Uid         int    `gorm:"column:uid;type:int(11)" json:"uid"`
	TableId     int    `gorm:"column:table_id;type:int(11)" json:"tableId"`
	Alias       string `gorm:"column:alias;type:varchar(255);NOT NULL" json:"alias"`
	Statement   string `gorm:"column:statement;type:text" json:"statement"`
	CollectType int    `gorm:"column:collect_type;type:int" json:"collectType"`
}

func (*Collect) Create added in v0.4.4 

func (model *Collect) Create(db *gorm.DB) (err error)

func (*Collect) Delete added in v0.4.4 

func (model *Collect) Delete(db *gorm.DB) (err error)

func (*Collect) Info added in v0.4.4 

func (model *Collect) Info(db *gorm.DB) (err error)

func (*Collect) InfoX added in v0.4.4 

func (model *Collect) InfoX(db *gorm.DB, conds map[string]interface{}) (err error)

func (*Collect) List added in v0.4.4 

func (model *Collect) List(db *gorm.DB, conds egorm.Conds) (resp []*Collect, err error)

func (*Collect) ListPage added in v0.4.4 

func (model *Collect) ListPage(db *gorm.DB, conds egorm.Conds, reqList *ReqPage) (total int64, respList []*Collect)

func (*Collect) TableName added in v0.4.4 

func (model *Collect) TableName() string

func (*Collect) Update added in v0.4.4 

func (model *Collect) Update(db *gorm.DB, ups map[string]interface{}) (err error)

type Cond 

type Cond struct {
	// Op MySQL中查询条件，如like,=,in
	Op string
	// Val 查询条件对应的值
	Val interface{}
}

Cond 为字段查询结构体

type Conds 

type Conds map[string]interface{}

Conds 为Cond类型map，用于定义Where方法参数 map[field.name]interface{}

type Configuration 

type Configuration struct {
	BaseModel

	K8SCmId     int    `gorm:"column:k8s_cm_id;type:int(11);" json:"k8sConfigmapId"` // config map id
	Name        string `gorm:"column:name;type:varchar(64);" json:"name"`
	Content     string `gorm:"column:content;type:longtext" json:"content"`
	Format      string `gorm:"column:format;type:varchar(32)" json:"format"`
	Version     string `gorm:"column:version;type:varchar(64)" json:"version"`
	Uid         int    `gorm:"column:uid;type:int(11) unsigned" json:"uid"`
	PublishTime int64  `gorm:"column:publish_time;type:int(11)" json:"publishTime"`
	LockUid     int    `gorm:"column:lock_uid;type:int(11) unsigned" json:"lockUid"`
	LockAt      int64  `gorm:"column:lock_at;type:bigint(11) unsigned" json:"lockAt"`

	K8SConfigMap K8SConfigMap `gorm:"foreignKey:K8SCmId;references:ID" json:"-"`
}

func ConfigurationInfo 

func ConfigurationInfo(paramId int) (resp Configuration, err error)

func ConfigurationInfoX 

func ConfigurationInfoX(conds map[string]interface{}) (resp Configuration, err error)

ConfigurationInfoX Info extension method to query a single record according to Cond

func ConfigurationList 

func ConfigurationList(conds egorm.Conds) (resp []*Configuration, err error)

ConfigurationList return item list by condition

func (Configuration) FileName 

func (c Configuration) FileName() string

FileName ..

func (*Configuration) TableName 

func (c *Configuration) TableName() string

type ConfigurationHistory 

type ConfigurationHistory struct {
	BaseModel
	Uid             int    `gorm:"column:uid;type:int(11) unsigned" json:"uid"`
	ConfigurationId int    `gorm:"column:configuration_id;type:int(11) unsigned" json:"configurationId"`
	ChangeLog       string `gorm:"column:change_log;type:longtext" json:"changeLog"`
	Content         string `gorm:"column:content;type:longtext" json:"content"`
	Version         string `gorm:"column:version;type:varchar(64)" json:"version"`

	Configuration Configuration `json:"configuration,omitempty" gorm:"foreignKey:ConfigurationId;references:ID"`
}

func ConfigurationHistoryInfoX 

func ConfigurationHistoryInfoX(conds map[string]interface{}) (resp ConfigurationHistory, err error)

ConfigurationHistoryInfoX get single item by condition

func ConfigurationHistoryListPage 

func ConfigurationHistoryListPage(conds egorm.Conds, reqList *ReqPage) (total int64, respList []*ConfigurationHistory)

ConfigurationHistoryListPage return item list by pagination

func (*ConfigurationHistory) TableName 

func (m *ConfigurationHistory) TableName() string

type ConfigurationPublish 

type ConfigurationPublish struct {
	BaseModel

	Uid                    uint `gorm:"column:uid;type:int(11) unsigned" json:"uid"`
	ConfigurationId        uint `gorm:"column:configuration_id;type:int(11) unsigned" json:"configurationId"`
	ConfigurationHistoryId uint `gorm:"column:configuration_history_id;type:int(11) unsigned" json:"configurationHistoryId"`
}

func (*ConfigurationPublish) TableName 

func (m *ConfigurationPublish) TableName() string

type Event 

type Event struct {
	ID            int    `gorm:"primary_key,not null;AUTO_INCREMENT" json:"id"`
	Source        string `gorm:"not null;default:'';size:64;index:idx_source;comment:事件来源" json:"source"`
	UserName      string `gorm:"not null;default:'';size:32;comment:操作用户的名字" json:"userName"`
	UID           int64  `gorm:"not null;default:0;comment:操作用户的uid" json:"uid"`
	Operation     string `gorm:"not null;default:'';size:64;index:idx_operation;comment:操作名" json:"operation"`
	ObjectType    string `gorm:"not null;default:'';size:64;comment:被操作对象的类型(一般为db.Table名)" json:"objectType"`
	ObjectId      int    `gorm:"not null;default:0;comment:被操作对象类型(db.BaseTable)下的具体对象的主键(id)" json:"objectId"`
	Metadata      string `gorm:"not null;type:text;comment:事件内容" json:"metadata"`
	Ctime         int64  `gorm:"bigint;autoCreateTime;comment:创建时间" json:"ctime"`
	OperationName string `gorm:"-" json:"operationName"`
	SourceName    string `gorm:"-" json:"sourceName"`
}

func (*Event) HandleOperationName 

func (a *Event) HandleOperationName()

func (*Event) HandleSourceName 

func (a *Event) HandleSourceName()

func (Event) TableName 

func (Event) TableName() string

type ICollect added in v0.4.4 

type ICollect interface {
	TableName() string
	Create(db *gorm.DB) (err error)
	Update(db *gorm.DB, ups map[string]interface{}) (err error)
	Info(db *gorm.DB) (err error)
	InfoX(db *gorm.DB, conds map[string]interface{}) (err error)
	List(db *gorm.DB, conds egorm.Conds) (resp []*Collect, err error)
	ListPage(db *gorm.DB, conds egorm.Conds, reqList *ReqPage) (total int64, respList []*Collect)
	Delete(db *gorm.DB) (err error)
}

type Ints 

type Ints []int

func (*Ints) Scan 

func (t *Ints) Scan(input interface{}) error

func (Ints) Value 

func (t Ints) Value() (driver.Value, error)

type K8SConfigMap 

type K8SConfigMap struct {
	BaseModel

	ClusterId int    `gorm:"column:cluster_id;type:int(11);index:uix_cluster_id_name_namespace,unique" json:"clusterId"` // 集群ID
	Name      string `gorm:"column:name;type:varchar(128);index:uix_cluster_id_name_namespace,unique" json:"name"`
	Namespace string `gorm:"column:namespace;type:varchar(64);index:uix_cluster_id_name_namespace,unique" json:"namespace"`
}

func K8SConfigMapInfo 

func K8SConfigMapInfo(paramId int) (resp K8SConfigMap, err error)

func K8SConfigMapInfoX 

func K8SConfigMapInfoX(conds map[string]interface{}) (resp K8SConfigMap, err error)

K8SConfigMapInfoX get single item by condition

func K8SConfigMapListX 

func K8SConfigMapListX(conds map[string]interface{}) (resp []K8SConfigMap, err error)

K8SConfigMapListX get single item by condition

func K8SConfigMapLoadOrSave 

func K8SConfigMapLoadOrSave(db *gorm.DB, data *K8SConfigMap) (resp *K8SConfigMap, err error)

func (*K8SConfigMap) TableName 

func (m *K8SConfigMap) TableName() string

type Notification added in v0.4.4 

type Notification struct {
	Version           string            `json:"version"`
	GroupKey          string            `json:"groupKey"`
	Status            string            `json:"status"`
	Receiver          string            `json:"receiver"`
	GroupLabels       map[string]string `json:"groupLabels"`
	CommonLabels      map[string]string `json:"commonLabels"`
	CommonAnnotations map[string]string `json:"commonAnnotations"`
	ExternalURL       string            `json:"externalURL"`
	Alerts            []Alert           `json:"alerts"`
}

func (*Notification) GetStatus added in v0.4.4 

func (n *Notification) GetStatus() int

type OAuthToken 

type OAuthToken struct {
	*oauth2.Token
}

func (*OAuthToken) Scan 

func (t *OAuthToken) Scan(input interface{}) error

func (OAuthToken) Value 

func (t OAuthToken) Value() (driver.Value, error)

type Pagination added in v0.4.3 

type Pagination struct {
	// Current 总记录数
	Current int `json:"current" form:"current"`
	// PageSize 每页记录数
	PageSize int `json:"pageSize" form:"pageSize"`
	// Total 总页数
	Total int64 `json:"total" form:"total"`
	// Sort 顺序
	Sort string `json:"sort"  form:"sort"`
}

type PmsCasbinRule 

type PmsCasbinRule struct {
	Id    uint   `gorm:"column:id;not null;primaryKey;autoIncrement;comment:'id'" json:"id" form:"id"`
	Ptype string `gorm:"column:ptype;not null;type:varchar(100);comment:'ptype: value in [p, g, g2, g3]'" json:"ptype" form:"ptype"`
	V0    string `gorm:"column:v0;not null;type:varchar(100);comment:'sub'" json:"v0" form:"v0"`
	V1    string `gorm:"column:v1;not null;type:varchar(100);comment:'obj'" json:"v1" form:"v1"`
	V2    string `gorm:"column:v2;not null;type:varchar(100);comment:'act'" json:"v2" form:"v2"`
	V3    string `gorm:"column:v3;not null;type:varchar(100);comment:'dom'" json:"v3" form:"v3"`
	V4    string `gorm:"column:v4;not null;type:varchar(25);comment:'reserved'" json:"v4" form:"v4"`
	V5    string `gorm:"column:v5;not null;type:varchar(25);comment:'reserved'" json:"v5" form:"v5"`
}

func (*PmsCasbinRule) TableName 

func (t *PmsCasbinRule) TableName() string

type PmsCustomRole 

type PmsCustomRole struct {
	BaseModel
	BelongType   string  `gorm:"not null;size:50;comment:所属资源类型,如'app'" json:"belong_type"`
	ReferId      int     `gorm:"not null;comment:所属资源类型的对应资源id" json:"refer_id"`
	RoleName     string  `gorm:"not null;size:50;comment:所属对应资源的角色名称" json:"role_name"`
	Description  string  `gorm:"not null;size:255;default:'';comment:对角色的中文描述" json:"description"`
	SubResources Strings `gorm:"not null;type:json;comment:角色所属refer_id资源的子资源列表" json:"sub_resources"`
	Acts         Strings `gorm:"not null;type:json;comment:对资源列表中各资源的actions" json:"acts"`
	UpdatedBy    int     `gorm:"not null;default:0;comment:最近一次对记录做更新的用户id" json:"updated_by"`
}
PmsCustomRole: 对资源的自定义角色表; 该表记录的增删会实时反映到 casbin_rule表中 (那么为什么不直接用casbin_rule表去维护?

因为, casbin_rule表中没有description描述, 该表的作用是供app负责人自定义一些在default_role_pms之外的一些角色.) 

note: 1. 需要保证 belong_type, refer_id, role_name, resources, act 这5个字段建立联合唯一索引.
	     但由于resources字段是json类型, 不能用于uniqueIndex, 所以需要代码去保证这5个字段的uniqueIndex
	  2. 是否支持custom_role_pms的自定义, 需要看当前代码实现, 目前支持的belong_type 为 ["app"]

func GetCustomRolePmsList 

func GetCustomRolePmsList(conds Conds) (resp []*PmsCustomRole, err error)

func (*PmsCustomRole) TableName 

func (t *PmsCustomRole) TableName() string

type PmsDefaultRole 

type PmsDefaultRole struct {
	BaseModel

	BelongType   string  `gorm:"column:belong_type;not null;size:50;comment:所属资源类型,如'app'" json:"belongType"`
	RoleName     string  `gorm:"column:role_name;not null;size:50;comment:所属资源的角色名称" json:"roleName"`
	Description  string  `gorm:"column:description;not null;size:255;default:'';comment:对角色的中文描述" json:"description"`
	SubResources Strings `gorm:"column:sub_resources;not null;type:json;comment:角色所属belongType资源下的子资源列表" json:"subResources"`
	Acts         Strings `gorm:"column:acts;not null;type:json;comment:对资源列表中各资源的actions" json:"acts"`
	UpdatedBy    int     `gorm:"column:updated_by;type:int(11);not null;default:0;comment:最近一次对记录做更新的用户id" json:"updatedBy"`
}
	TableDefaultRolePms: 记录belongType资源的默认角色; i.e. 当belongType资源创建时, 会根据该表中的记录去创建对应的casbinRules
	note: 需要保证 belong_type, role_name, resources, act 这4个字段建立联合唯一索引.
		  但由于resources字段是json类型, 不能用于uniqueIndex, TODO: 代码中保证4个字段的uniqueIndex
 		  不能只对belong_type和role_name两个字段设置uniqueIndex, 应为存在belong_type和role_name相同的情况(它们sub_resources不同)

func GetDefaultRolePmsList 

func GetDefaultRolePmsList(conds Conds) (resp []*PmsDefaultRole, err error)

func (*PmsDefaultRole) TableName 

func (t *PmsDefaultRole) TableName() string

type PmsRole 

type PmsRole struct {
	BaseModel

	Name           string           `gorm:"not null;type:varchar(64);column:name;comment:角色英文名,可修改,不唯一" json:"name"`
	Desc           string           `gorm:"not null;type:varchar(128);default:'';column:desc;comment:角色描述" json:"desc"`
	BelongResource string           `` /* 133-byte string literal not displayed */
	RoleType       int              `` /* 152-byte string literal not displayed */
	ResourceId     int              `` /* 161-byte string literal not displayed */
	Details        []*PmsRoleDetail `gorm:"->" json:"details"`
	Refs           []*PmsRoleRef    `gorm:"->" json:"refs"`
}

func GetPmsRoleList 

func GetPmsRoleList(conds egorm.Conds) (resp []*PmsRole, err error)

func PmsRoleInfo 

func PmsRoleInfo(id int) (resp *PmsRole, err error)

func PmsRoleInfoWithTgtRef 

func PmsRoleInfoWithTgtRef(roleId int, belongResource string, resourceId int) (resp *PmsRole, err error)

not contain grant info

func (*PmsRole) GenerateOnePRuleTplByDetail 

func (pr *PmsRole) GenerateOnePRuleTplByDetail(roleDetail *PmsRoleDetail) (resp string, err error)

GenerateOnePRuleTplByDetail : Generate a pType casbin policy string based on inputParam(PmsRoleDetail) returned resp(if not empty) like, 

role__{{PmsRole:Id}}__{{PmsRole:BelongResource}}__{{ID}},{{PmsRole:BelongResource}}__{{ID}}__subResource__(SubResourceRegex),ActsRegex,*

func (*PmsRole) IsDetailsValid 

func (pr *PmsRole) IsDetailsValid() (err error)

func (*PmsRole) TableName 

func (pr *PmsRole) TableName() string

type PmsRoleDetail 

type PmsRoleDetail struct {
	BaseModel

	PmsRoleId    int     `gorm:"type:int(11);not null;column:pms_role_id;comment:所属pmsRole的id" json:"pmsRoleId"`
	SubResources Strings `gorm:"not null;type:json;column:sub_resources;comment:授权目标资源的子资源列表" json:"subResources"`
	Acts         Strings `gorm:"not null;type:json;column:acts;comment:准许动作列表" json:"acts"`
	RuleTpl      string  `gorm:"not null;type:text;column:rule_tpl;comment:规则模板,用于生成casbin中的p类型规则" json:"-"`
}

PmsRoleDetail uniqueIndex is not support for json column, please make sure (pms_role_id, sub_resources) is unique, and (pms_role_id, acts) is unique.

func (*PmsRoleDetail) TableName 

func (prd *PmsRoleDetail) TableName() string

type PmsRoleRef 

type PmsRoleRef struct {
	ID        int                `json:"id" gorm:"column:id;type:int;not null;primary_key;auto_increment"`
	PmsRoleId int                `gorm:"not null;column:pms_role_id;uniqueIndex:uix_role_ref;comment:已存在的角色(pms_role)的Id" json:"pmsRoleId"`
	RefId     int                `gorm:"not null;column:ref_id;uniqueIndex:uix_role_ref;comment:角色belongResource类型对象的id" json:"refId"`
	Grants    []*PmsRoleRefGrant `gorm:"->" json:"-"`
}

PmsRoleRef the table to store the assignment states of every PmsRole. Note, add or delete one record, must create or remove corresponding p rules(which generated from details)

func GetPmsRoleRefInfo 

func GetPmsRoleRefInfo(conds egorm.Conds) (resp PmsRoleRef, err error)

func GetPmsRoleRefList 

func GetPmsRoleRefList(conds egorm.Conds, withGrants ...bool) (resp []*PmsRoleRef, err error)

GetPmsRoleRefList for resp, default do not contain grants info

func (*PmsRoleRef) TableName 

func (prf *PmsRoleRef) TableName() string

type PmsRoleRefGrant 

type PmsRoleRefGrant struct {
	ID           int    `gorm:"column:id;type:int;not null;primary_key;auto_increment" json:"id" `
	PmsRoleRefId int    `gorm:"not null;column:pms_role_ref_id;uniqueIndex:uix_ref_obj_domain;comment:所关联pms_role_ref的Id" json:"pmsRoleRefId"`
	Ptype        string `` /* 135-byte string literal not displayed */
	ObjectType   string `` /* 155-byte string literal not displayed */
	ObjectId     int    `gorm:"not null;column:object_id;uniqueIndex:uix_ref_obj_domain;comment:被授权对象的id" json:"objectId,omitempty"`
	DomainType   string `` /* 164-byte string literal not displayed */
	DomainId     int    `` /* 151-byte string literal not displayed */
}

PmsRoleRefGrant Note, all columns can NOT be modified after crated. if want to modify, please, remove and add again. add or delete record, must create or remove corresponding gType rules

func (*PmsRoleRefGrant) TableName 

func (prfg *PmsRoleRefGrant) TableName() string

type PushMsg added in v0.4.4 

type PushMsg struct {
	Title string `json:"title"`
	Text  string `json:"text"`
}

type ReqAlarmWebhook added in v0.4.4 

type ReqAlarmWebhook struct {
	Name string `json:"name" form:"name"`
	Key  string `json:"key" form:"key"`
	Typ  int    `json:"typ" form:"typ"`
	Uid  int    `json:"uid" form:"uid"`
}

type ReqAlertSettingUpdate added in v0.4.3 

type ReqAlertSettingUpdate struct {
	RuleStoreType    int    `json:"ruleStoreType" form:"ruleStoreType"` // rule_store_type 1 文件 2 集群
	PrometheusTarget string `json:"prometheusTarget" form:"prometheusTarget"`

	// file
	FilePath string `json:"filePath" form:"filePath"`

	// k8s
	Namespace string `json:"namespace" form:"namespace"`
	Configmap string `json:"configmap" form:"configmap"`
	ClusterId int    `json:"clusterId" form:"clusterId"`
}

type ReqCreateCollect added in v0.4.4 

type ReqCreateCollect struct {
	TableId int `json:"tableId" json:"tableId"`
	ReqUpdateCollect
}

type ReqCreateMetricsSamples added in v0.4.4 

type ReqCreateMetricsSamples struct {
	Iid     int    `json:"iid" form:"iid"`
	Cluster string `json:"cluster" form:"cluster"`
}

type ReqListCollect added in v0.4.4 

type ReqListCollect struct {
	CollectType int `json:"collectType" form:"collectType" required:"true"` // 1 query 2 table filter 4 global filter, if query table filter and global filter, use collectType 6
	TableId     int `json:"tableId" form:"tableId"`
}

type ReqPage 

type ReqPage struct {
	Current  int `json:"current" form:"current"`
	PageSize int `json:"pageSize" form:"pageSize"`
}

func (*ReqPage) Valid 

func (r *ReqPage) Valid() error

type ReqShortURLCreate added in v0.4.4 

type ReqShortURLCreate struct {
	OriginUrl string `json:"originUrl" form:"originUrl"`
}

type ReqUpdateCollect added in v0.4.4 

type ReqUpdateCollect struct {
	Alias       string `json:"alias" form:"alias"`
	Statement   string `json:"statement" form:"statement"`
	CollectType int    `json:"collectType" form:"collectType"` // 1 query 2 table filter 4 global filter
}

type RespAlarmListRelatedInfo added in v0.4.3 

type RespAlarmListRelatedInfo struct {
	Table    BaseTable    `json:"table"`
	Instance BaseInstance `json:"instance"`
}

type RespAlertSettingInfo added in v0.4.3 

type RespAlertSettingInfo struct {
	InstanceId int `json:"instanceId"`
	ReqAlertSettingUpdate
}

type RespAlertSettingListItem added in v0.4.3 

type RespAlertSettingListItem struct {
	InstanceId       int    `json:"instanceId"`
	InstanceName     string `json:"instanceName"`
	RuleStoreType    int    `json:"ruleStoreType"` // rule_store_type 1 文件 2 集群
	PrometheusTarget string `json:"prometheusTarget"`

	// check
	IsPrometheusOK            int    `json:"isPrometheusOK"` // 0 no 1 yes
	CheckPrometheusResult     string `json:"checkPrometheusResult"`
	IsAlertManagerOK          int    `json:"isAlertManagerOK"` // 0 no 1 yes
	CheckAlertManagerResult   string `json:"checkAlertManagerResult"`
	IsMetricsSamplesOk        int    `json:"isMetricsSamplesOk"` // 0 no 1 yes
	CheckMetricsSamplesResult string `json:"checkMetricsSamplesResult"`
}

type RespAllEnums 

type RespAllEnums struct {
	SourceEnums    map[string]string `json:"sourceEnums"`
	OperationEnums map[string]string `json:"operationEnums"`
	UserEnums      map[int]string    `json:"userEnums"`
}

type RespEnumsOfSource 

type RespEnumsOfSource struct {
	TargetSource   string            `json:"targetSource"`
	OperationEnums map[string]string `json:"operationEnums"`
}

type RespListCollect added in v0.4.4 

type RespListCollect struct {
	Total int64                  `json:"total"`
	List  []*RespListCollectItem `json:"list"`
}

type RespListCollectItem added in v0.4.4 

type RespListCollectItem struct {
	ID        int    `json:"id"`
	Alias     string `json:"alias"`
	Statement string `json:"statement"`
}

type String2String 

type String2String map[string]string

func (*String2String) Scan 

func (t *String2String) Scan(input interface{}) error

func (String2String) Value 

func (t String2String) Value() (driver.Value, error)

type Strings 

type Strings []string

func (*Strings) Scan 

func (t *Strings) Scan(input interface{}) error

func (Strings) Value 

func (t Strings) Value() (driver.Value, error)

type UnitItem 

type UnitItem struct {
	Alias    string        `json:"alias"`
	Duration time.Duration `json:"duration"`
}

type Ups 

type Ups = map[string]interface{}

Ups 为更新某一条记录时存放的变更数据集合 map[field.name]field.value

type User 

type User struct {
	BaseModel
	Uid              int        `gorm:"-" json:"uid"`
	OaId             int64      `gorm:"column:oa_id;type:bigint(20);NOT NULL" json:"oaId"`                           // oa_id
	Username         string     `gorm:"column:username;type:varchar(256);NOT NULL" json:"username"`                  // 用户名
	Nickname         string     `gorm:"column:nickname;type:varchar(256);NOT NULL" json:"nickname"`                  // 昵称
	Secret           string     `gorm:"column:secret;type:varchar(256);NOT NULL" json:"secret"`                      // 实例名称
	Email            string     `gorm:"column:email;type:varchar(64);NOT NULL" json:"email"`                         // email
	Avatar           string     `gorm:"column:avatar;type:varchar(256);NOT NULL" json:"avatar"`                      // avatar
	Hash             string     `gorm:"column:hash;type:varchar(256);NOT NULL" json:"hash"`                          // hash
	WebUrl           string     `gorm:"column:web_url;type:varchar(256);NOT NULL" json:"webUrl"`                     // webUrl
	Oauth            string     `gorm:"column:oauth;type:varchar(256);NOT NULL" json:"oauth"`                        // oauth
	State            string     `gorm:"column:state;type:varchar(256);NOT NULL" json:"state"`                        // state
	OauthId          string     `gorm:"column:oauth_id;type:varchar(256);NOT NULL" json:"oauthId"`                   // oauthId
	Password         string     `gorm:"column:password;type:varchar(256);NOT NULL" json:"password"`                  // password
	CurrentAuthority string     `gorm:"column:current_authority;type:varchar(256);NOT NULL" json:"currentAuthority"` // currentAuthority
	Access           string     `gorm:"column:access;type:varchar(256);NOT NULL" json:"access"`                      // access
	OauthToken       OAuthToken `gorm:"column:oauth_token;type:text" json:"-"`                                       // oauth_token
}

func UserInfo 

func UserInfo(paramId int) (resp User, err error)

func UserInfoX 

func UserInfoX(conds map[string]interface{}) (resp User, err error)

UserInfoX get single item by condition

func UserList 

func UserList(conds egorm.Conds) (resp []*User, err error)

UserList return item list by condition

func UserListPage 

func UserListPage(conds egorm.Conds, reqList *ReqPage) (total int64, respList []*User)

UserListPage return item list by pagination

func (User) TableName 

func (User) TableName() string

type UserIdName 

type UserIdName struct {
	ID       int
	Username string
}

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.