db

package

Go to main page

Versions in this module

v0

v0.2.2

Apr 15, 2022

Changes in this version

+ const OpnAlarmsChannelsCreate

+ const OpnAlarmsChannelsDelete

+ const OpnAlarmsChannelsUpdate

+ const OpnAlarmsCreate

+ const OpnAlarmsDelete

+ const OpnAlarmsUpdate

+ const OpnClustersConfigMapCreate

+ const OpnClustersConfigMapDelete

+ const OpnClustersConfigMapUpdate

+ const OpnClustersCreate

+ const OpnClustersDelete

+ const OpnClustersUpdate

+ const OpnConfigsCreate

+ const OpnConfigsDelete

+ const OpnConfigsPublish

+ const OpnConfigsSync

+ const OpnConfigsUpdate

+ const OpnDatabasesCreate

+ const OpnDatabasesDelete

+ const OpnDatabasesUpdate

+ const OpnInstancesCreate

+ const OpnInstancesDelete

+ const OpnInstancesUpdate

+ const OpnLocalUsersPwdChange

+ const OpnMigration

+ const OpnTableCreateSelfBuilt

+ const OpnTablesCreate

+ const OpnTablesDelete

+ const OpnTablesIndexUpdate

+ const OpnTablesLogsQuery

+ const OpnTablesUpdate

+ const OpnViewsCreate

+ const OpnViewsDelete

+ const OpnViewsUpdate

+ const SourceAlarmMgtCenter

+ const SourceClusterMgtCenter

+ const SourceConfigMgtCenter

+ const SourceInquiryMgtCenter

+ const SourceSystemSetting

+ const TimeFieldTypeDT

+ const TimeFieldTypeTs

+ const TimeFieldTypeTsMs

type Alarm

+ User *User

type Database

+ Cluster string

+ IsCreateByMogo int

type Instance

+ Clusters Strings

+ Mode int

+ type RespAllEnums struct

+ OperationEnums map[string]string

+ SourceEnums map[string]string

+ UserEnums map[int]string

+ type RespEnumsOfSource struct

+ OperationEnums map[string]string

+ TargetSource string

+ type Strings []string

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

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

type Table

+ Desc string

+ SqlDistributed string

+ TimeFieldType int

+ type UserIdName struct

+ ID int

+ Username string

v0.2.2-rc2

Apr 7, 2022

v0.2.2-rc1

Apr 2, 2022

v0.2.1

Mar 28, 2022

Changes in this version

+ const TimeFieldNanoseconds

+ const TimeFieldSecond

+ var UnitMap = map[int]UnitItem

type Alarm

+ func (m *Alarm) AlertUniqueName() string

+ func (m *Alarm) AlertViewName(database, table string) string

type Index

+ func (t *Index) GetFieldName() string

type Table

+ func (m *Table) GetTimeField() string

+ type UnitItem struct

+ Alias string

+ Duration time.Duration

v0.2.0

Mar 21, 2022

Changes in this version

+ const AlarmStatusClose

+ const AlarmStatusFiring

+ const AlarmStatusOpen

+ const OpnLocalUserCreate

+ const OpnLocalUserDelete

+ const OpnLocalUserPwdChange

+ const OpnLocalUserPwdReset

+ const OpnLocalUserUpdate

+ const OpnLogTableDelete

+ const RuleStoreTypeFile

+ const RuleStoreTypeK8s

+ const SourceLogMgtCenter

+ const SourceUserMgtCenter

+ const TableMogoAlarm

+ const TableMogoAlarmChannel

+ const TableMogoAlarmCondition

+ const TableMogoAlarmFilter

+ const TableMogoAlarmHistory

+ const TableMogoEvent

+ var OperationMap = map[string]string

+ var SourceMap = map[string]string

+ var SourceOpnMap = map[string][]string

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func AlarmStatusUpdate(id int, status string) (err error)

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

+ func GetAlarmTableInstanceInfo(id int) (instanceInfo Instance, tableInfo Table, alarmInfo Alarm, err error)

+ type Alarm struct

+ AlertRule string

+ ChannelIds Ints

+ Desc string

+ Interval int

+ Name string

+ RuleStoreType int

+ Status int

+ Tags String2String

+ Tid int

+ Uid int

+ Unit int

+ Uuid string

+ View string

+ ViewTableName string

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

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

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

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

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

+ func (m *Alarm) AlertInterval() string

+ func (m *Alarm) AlertRuleName() string

+ func (m *Alarm) TableName() string

+ type AlarmChannel struct

+ Key string

+ Name string

+ Typ int

+ Uid int

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

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

+ func (m *AlarmChannel) TableName() string

+ type AlarmCondition struct

+ AlarmId int

+ Cond int

+ SetOperatorExp int

+ SetOperatorTyp int

+ Val1 int

+ Val2 int

+ func AlarmConditionInfo(db *gorm.DB, id int) (resp AlarmCondition, err error)

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

+ func (m *AlarmCondition) TableName() string

+ type AlarmFilter struct

+ AlarmId int

+ SetOperatorExp string

+ SetOperatorTyp int

+ Tid int

+ When string

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

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

+ func (m *AlarmFilter) TableName() string

+ type AlarmHistory struct

+ AlarmId int

+ IsPushed int

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

+ func AlarmHistoryList(conds egorm.Conds) (resp []*AlarmHistory, err error)

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

+ func (m *AlarmHistory) TableName() string

type Database

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

+ type Event struct

+ Ctime int64

+ ID int

+ Metadata string

+ ObjectId int

+ ObjectType string

+ Operation string

+ OperationName string

+ Source string

+ SourceName string

+ UID int

+ UserName string

+ func (Event) TableName() string

+ func (a *Event) HandleOperationName()

+ func (a *Event) HandleSourceName()

type Index

+ RootName string

type Instance

+ ClusterId int

+ Configmap string

+ FilePath string

+ Namespace string

+ PrometheusTarget string

+ RuleStoreType int

+ type Ints []int

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

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

+ type String2String map[string]string

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

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

type Table

+ CreateType int

+ TimeField string

v0.1.0

Feb 21, 2022

Changes in this version

+ const ClusterStatusMaintaining

+ const ClusterStatusNormal

+ const ClusterStatusNotAvailable

+ const DatasourceClickHouse

+ const DatasourceMySQL

+ const TableNameCluster

+ const TableNameConfiguration

+ const TableNameConfigurationHistory

+ const TableNameConfigurationPublish

+ const TableNameDatabase

+ const TableNameIndex

+ const TableNameInstance

+ const TableNameK8SConfigMap

+ const TableNameTable

+ const TableNameUser

+ const TableNameView

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

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

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

+ func ClusterUpdateX(db *gorm.DB, conds egorm.Conds, ups map[string]interface{}) (err error)

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

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

+ func ConfigurationHistoryCreate(db *gorm.DB, data *ConfigurationHistory) (err error)

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

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

+ func ConfigurationPublishCreate(db *gorm.DB, data *ConfigurationPublish) (err error)

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

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

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

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

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

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

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

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

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

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

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

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

+ func InstanceKey(id int) string

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type BaseModel struct

+ Ctime int64

+ Dtime sdelete.DeletedAt

+ ID int

+ Utime int64

+ type Cluster struct

+ ApiServer string

+ Description string

+ KubeConfig string

+ Name string

+ Status int

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

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

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

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

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

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

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

+ func GetAllNormalClusters() (result []*Cluster, err error)

+ func (m *Cluster) Key() string

+ func (m *Cluster) TableName() string

+ type Configuration struct

+ Content string

+ Format string

+ K8SCmId int

+ K8SConfigMap K8SConfigMap

+ LockAt int64

+ LockUid int

+ Name string

+ PublishTime int64

+ Uid int

+ Version string

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

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

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

+ func ConfigurationListPage(conds egorm.Conds, reqList *ReqPage) (total int64, respList []*Configuration)

+ func (c *Configuration) TableName() string

+ func (c Configuration) FileName() string

+ type ConfigurationHistory struct

+ ChangeLog string

+ Configuration Configuration

+ ConfigurationId int

+ Content string

+ Uid int

+ User User

+ Version string

+ func ConfigurationHistoryInfo(paramId int) (resp ConfigurationHistory, err error)

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

+ func ConfigurationHistoryList(conds egorm.Conds) (resp []*ConfigurationHistory, err error)

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

+ func (m *ConfigurationHistory) TableName() string

+ type ConfigurationPublish struct

+ ConfigurationHistoryId uint

+ ConfigurationId uint

+ Uid uint

+ func ConfigurationPublishInfo(paramId int) (resp ConfigurationPublish, err error)

+ func ConfigurationPublishList(conds egorm.Conds) (resp []*ConfigurationPublish, err error)

+ func ConfigurationPublishListPage(conds egorm.Conds, reqList *ReqPage) (total int64, respList []*ConfigurationPublish)

+ func (m *ConfigurationPublish) TableName() string

+ type Database struct

+ Iid int

+ Instance *Instance

+ Name string

+ Uid int

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

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

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

+ func (m *Database) TableName() string

+ type Index struct

+ Alias string

+ Field string

+ Tid int

+ Typ int

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

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

+ func (t *Index) TableName() string

+ type Instance struct

+ Datasource string

+ Dsn string

+ Name string

+ func InstanceByName(dt, name string) (resp Instance, err error)

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

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

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

+ func (t *Instance) DsKey() string

+ func (t *Instance) TableName() string

+ type K8SConfigMap struct

+ ClusterId int

+ Name string

+ Namespace string

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

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

+ func K8SConfigMapList(conds egorm.Conds) (resp []*K8SConfigMap, err error)

+ func K8SConfigMapListPage(conds egorm.Conds, reqList *ReqPage) (total int64, respList []*K8SConfigMap)

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

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

+ func (m *K8SConfigMap) TableName() string

+ type OAuthToken struct

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

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

+ type ReqPage struct

+ Current int

+ PageSize int

+ func (r *ReqPage) Valid() error

+ type Table struct

+ Brokers string

+ Database *Database

+ Days int

+ Did int

+ Name string

+ SqlData string

+ SqlStream string

+ SqlView string

+ Topic string

+ Typ int

+ Uid int

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

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

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

+ func (m *Table) TableName() string

+ type User struct

+ Access string

+ Avatar string

+ CurrentAuthority string

+ Email string

+ Hash string

+ Nickname string

+ OaId int

+ Oauth string

+ OauthId string

+ OauthToken OAuthToken

+ Password string

+ Secret string

+ State string

+ Username string

+ WebUrl string

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

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

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

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

+ func (User) TableName() string

+ type View struct

+ Ctime int

+ Dtime int

+ Format string

+ IsUseDefaultTime int

+ Key string

+ Name string

+ SqlView string

+ Tid int

+ Uid int

+ Utime int

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

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

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

+ func (m *View) TableName() string

v0.0.1-rc2

Feb 14, 2022

v0.0.1-rc1

Jan 13, 2022

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL