models

package
v5.9.3 Latest Latest
Warning

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

 Go to latest Published: Jun 27, 2022 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

View Source 
const AdminRole = "Admin"

Variables

This section is empty.

Functions

func AlertAggrViewDel added in v5.5.0 

func AlertAggrViewDel(ids []int64, createBy ...interface{}) error

AlertAggrViewDel: userid for safe delete

func AlertCurEventDel 

func AlertCurEventDel(ids []int64) error

func AlertCurEventDelByHash 

func AlertCurEventDelByHash(hash string) error

func AlertCurEventExists 

func AlertCurEventExists(where string, args ...interface{}) (bool, error)

func AlertCurEventGetMap 

func AlertCurEventGetMap(cluster string) (map[int64]map[string]struct{}, error)

func AlertCurEventTotal 

func AlertCurEventTotal(prod string, bgid, stime, etime int64, severity int, clusters []string, query string) (int64, error)

func AlertHisEventTotal 

func AlertHisEventTotal(prod string, bgid, stime, etime int64, severity int, recovered int, clusters []string, query string) (int64, error)

func AlertMuteDel 

func AlertMuteDel(ids []int64) error

func AlertNumbers 

func AlertNumbers(bgids []int64) (map[int64]int64, error)

for busi_group list page

func AlertRuleDels 

func AlertRuleDels(ids []int64, bgid ...int64) error

func AlertRuleExists 

func AlertRuleExists(where string, args ...interface{}) (bool, error)

func AlertRuleGetName 

func AlertRuleGetName(id int64) (string, error)

func AlertSubscribeDel 

func AlertSubscribeDel(ids []int64) error

func BoardCount added in v5.8.0 

func BoardCount(where string, args ...interface{}) (num int64, err error)

func BoardExists added in v5.8.0 

func BoardExists(where string, args ...interface{}) (bool, error)

func BoardPayloadGet added in v5.8.0 

func BoardPayloadGet(id int64) (string, error)

func BoardPayloadSave added in v5.8.0 

func BoardPayloadSave(id int64, payload string) error

func BusiGroupAdd 

func BusiGroupAdd(name string, labelEnable int, labelValue string, members []BusiGroupMember, creator string) error

func BusiGroupExists 

func BusiGroupExists(where string, args ...interface{}) (bool, error)

func BusiGroupGetMap added in v5.5.0 

func BusiGroupGetMap() (map[int64]*BusiGroup, error)

func BusiGroupIds 

func BusiGroupIds(userGroupIds []int64, permFlag ...string) ([]int64, error)

func BusiGroupMemberAdd 

func BusiGroupMemberAdd(member BusiGroupMember) error

func BusiGroupMemberCount 

func BusiGroupMemberCount(where string, args ...interface{}) (int64, error)

func BusiGroupMemberDel 

func BusiGroupMemberDel(where string, args ...interface{}) error

func ChartGroupIdsOf 

func ChartGroupIdsOf(dashId int64) ([]int64, error)

func ConfigsGet 

func ConfigsGet(ckey string) (string, error)

func ConfigsGets 

func ConfigsGets(ckeys []string) (map[string]string, error)

func ConfigsSet 

func ConfigsSet(ckey, cval string) error

func Count 

func Count(tx *gorm.DB) (int64, error)

func CryptoPass 

func CryptoPass(raw string) (string, error)

CryptoPass crypto password use salt

func DB 

func DB() *gorm.DB

func DashboardCount 

func DashboardCount(where string, args ...interface{}) (num int64, err error)

func DashboardExists 

func DashboardExists(where string, args ...interface{}) (bool, error)

func Exists 

func Exists(tx *gorm.DB) (bool, error)

func IdentsFilter 

func IdentsFilter(idents []string, where string, args ...interface{}) ([]string, error)

func InitRoot 

func InitRoot()

func InitSalt 

func InitSalt()

InitSalt generate random salt

func Insert 

func Insert(obj interface{}) error

func MemberIds 

func MemberIds(groupId int64) ([]int64, error)

func MetricDescriptionDel 

func MetricDescriptionDel(ids []int64) error

func MetricDescriptionMapper 

func MetricDescriptionMapper(metrics []string) (map[string]string, error)

func MetricDescriptionTotal 

func MetricDescriptionTotal(query string) (int64, error)

func MetricDescriptionUpdate 

func MetricDescriptionUpdate(mds []MetricDescription) error

func MetricViewDel added in v5.5.0 

func MetricViewDel(ids []int64, createBy ...interface{}) error

MetricViewDel: userid for safe delete

func MyGroupIds 

func MyGroupIds(userId int64) ([]int64, error)

func NewDefaultChartGroup 

func NewDefaultChartGroup(dashId int64) error

func OperationsOfRole 

func OperationsOfRole(roles []string) ([]string, error)

func RoleHasOperation 

func RoleHasOperation(roles []string, operation string) (bool, error)

func TargetDel 

func TargetDel(idents []string) error

func TargetGetTags 

func TargetGetTags(idents []string) ([]string, error)

func TargetIdents 

func TargetIdents(ids []int64) ([]string, error)

func TargetIds 

func TargetIds(idents []string) ([]int64, error)

func TargetTotal 

func TargetTotal(bgid int64, clusters []string, query string) (int64, error)

func TargetUpdateBgid 

func TargetUpdateBgid(idents []string, bgid int64, clearTags bool) error

func TargetUpdateNote 

func TargetUpdateNote(idents []string, note string) error

func TaskRecordTotal 

func TaskRecordTotal(bgid, beginTime int64, createBy, query string) (int64, error)

list task, filter by group_id, create_by

func TaskTplTotal 

func TaskTplTotal(groupId int64, query string) (int64, error)

func UserGroupCount 

func UserGroupCount(where string, args ...interface{}) (num int64, err error)

func UserGroupIdsOfBusiGroup 

func UserGroupIdsOfBusiGroup(busiGroupId int64, permFlag ...string) ([]int64, error)

func UserGroupMemberAdd 

func UserGroupMemberAdd(groupId, userId int64) error

func UserGroupMemberCount 

func UserGroupMemberCount(where string, args ...interface{}) (int64, error)

func UserGroupMemberDel 

func UserGroupMemberDel(groupId int64, userIds []int64) error

func UserTotal 

func UserTotal(query string) (num int64, err error)

Types

type AggrRule added in v5.5.0 

type AggrRule struct {
	Type  string
	Value string
}

type AlertAggrView added in v5.5.0 

type AlertAggrView struct {
	Id       int64  `json:"id" gorm:"primaryKey"`
	Name     string `json:"name"`
	Rule     string `json:"rule"`
	Cate     int    `json:"cate"`
	CreateAt int64  `json:"create_at"`
	CreateBy int64  `json:"create_by"`
	UpdateAt int64  `json:"update_at"`
}

AlertAggrView 在告警聚合视图查看的时候，要存储一些聚合规则

func AlertAggrViewGet added in v5.5.0 

func AlertAggrViewGet(where string, args ...interface{}) (*AlertAggrView, error)

func AlertAggrViewGets added in v5.5.0 

func AlertAggrViewGets(createBy interface{}) ([]AlertAggrView, error)

func (*AlertAggrView) Add added in v5.5.0 

func (v *AlertAggrView) Add() error

func (*AlertAggrView) TableName added in v5.5.0 

func (v *AlertAggrView) TableName() string

func (*AlertAggrView) Update added in v5.5.0 

func (v *AlertAggrView) Update(name, rule string, cate int, createBy int64) error

func (*AlertAggrView) Verify added in v5.5.0 

func (v *AlertAggrView) Verify() error

type AlertCurEvent 

type AlertCurEvent struct {
	Id                 int64             `json:"id" gorm:"primaryKey"`
	Cluster            string            `json:"cluster"`
	GroupId            int64             `json:"group_id"`   // busi group id
	GroupName          string            `json:"group_name"` // busi group name
	Hash               string            `json:"hash"`       // rule_id + vector_key
	RuleId             int64             `json:"rule_id"`
	RuleName           string            `json:"rule_name"`
	RuleNote           string            `json:"rule_note"`
	RuleProd           string            `json:"rule_prod"`
	RuleAlgo           string            `json:"rule_algo"`
	Severity           int               `json:"severity"`
	PromForDuration    int               `json:"prom_for_duration"`
	PromQl             string            `json:"prom_ql"`
	PromEvalInterval   int               `json:"prom_eval_interval"`
	Callbacks          string            `json:"-"`                  // for db
	CallbacksJSON      []string          `json:"callbacks" gorm:"-"` // for fe
	RunbookUrl         string            `json:"runbook_url"`
	NotifyRecovered    int               `json:"notify_recovered"`
	NotifyChannels     string            `json:"-"`                          // for db
	NotifyChannelsJSON []string          `json:"notify_channels" gorm:"-"`   // for fe
	NotifyGroups       string            `json:"-"`                          // for db
	NotifyGroupsJSON   []string          `json:"notify_groups" gorm:"-"`     // for fe
	NotifyGroupsObj    []*UserGroup      `json:"notify_groups_obj" gorm:"-"` // for fe
	TargetIdent        string            `json:"target_ident"`
	TargetNote         string            `json:"target_note"`
	TriggerTime        int64             `json:"trigger_time"`
	TriggerValue       string            `json:"trigger_value"`
	Tags               string            `json:"-"`                          // for db
	TagsJSON           []string          `json:"tags" gorm:"-"`              // for fe
	TagsMap            map[string]string `json:"-" gorm:"-"`                 // for internal usage
	IsRecovered        bool              `json:"is_recovered" gorm:"-"`      // for notify.py
	NotifyUsersObj     []*User           `json:"notify_users_obj" gorm:"-"`  // for notify.py
	LastEvalTime       int64             `json:"last_eval_time" gorm:"-"`    // for notify.py 上次计算的时间
	LastSentTime       int64             `json:"last_sent_time" gorm:"-"`    // 上次发送时间
	NotifyCurNumber    int               `json:"notify_cur_number" gorm:"-"` // notify: current number
}

func AlertCurEventGet 

func AlertCurEventGet(where string, args ...interface{}) (*AlertCurEvent, error)

func AlertCurEventGetAll 

func AlertCurEventGetAll(cluster string) ([]*AlertCurEvent, error)

func AlertCurEventGetById 

func AlertCurEventGetById(id int64) (*AlertCurEvent, error)

func AlertCurEventGetByIds added in v5.5.0 

func AlertCurEventGetByIds(ids []int64) ([]*AlertCurEvent, error)

func AlertCurEventGetByRule 

func AlertCurEventGetByRule(ruleId int64) ([]*AlertCurEvent, error)

func AlertCurEventGets 

func AlertCurEventGets(prod string, bgid, stime, etime int64, severity int, clusters []string, query string, limit, offset int) ([]AlertCurEvent, error)

func (*AlertCurEvent) Add 

func (e *AlertCurEvent) Add() error

func (*AlertCurEvent) DB2FE 

func (e *AlertCurEvent) DB2FE()

func (*AlertCurEvent) DB2Mem 

func (e *AlertCurEvent) DB2Mem()

func (*AlertCurEvent) FillNotifyGroups 

func (e *AlertCurEvent) FillNotifyGroups(cache map[int64]*UserGroup) error

for webui

func (*AlertCurEvent) GenCardTitle added in v5.5.0 

func (e *AlertCurEvent) GenCardTitle(rules []*AggrRule) string

func (*AlertCurEvent) GetField added in v5.5.0 

func (e *AlertCurEvent) GetField(field string) string

func (*AlertCurEvent) GetTagValue added in v5.5.0 

func (e *AlertCurEvent) GetTagValue(tagkey string) string

func (*AlertCurEvent) ParseRuleNote added in v5.8.0 

func (e *AlertCurEvent) ParseRuleNote() error

func (*AlertCurEvent) TableName 

func (e *AlertCurEvent) TableName() string

func (*AlertCurEvent) ToHis 

func (e *AlertCurEvent) ToHis() *AlertHisEvent

type AlertHisEvent 

type AlertHisEvent struct {
	Id                 int64       `json:"id" gorm:"primaryKey"`
	IsRecovered        int         `json:"is_recovered"`
	Cluster            string      `json:"cluster"`
	GroupId            int64       `json:"group_id"`
	GroupName          string      `json:"group_name"` // busi group name
	Hash               string      `json:"hash"`
	RuleId             int64       `json:"rule_id"`
	RuleName           string      `json:"rule_name"`
	RuleNote           string      `json:"rule_note"`
	RuleProd           string      `json:"rule_prod"`
	RuleAlgo           string      `json:"rule_algo"`
	Severity           int         `json:"severity"`
	PromForDuration    int         `json:"prom_for_duration"`
	PromQl             string      `json:"prom_ql"`
	PromEvalInterval   int         `json:"prom_eval_interval"`
	Callbacks          string      `json:"-"`
	CallbacksJSON      []string    `json:"callbacks" gorm:"-"`
	RunbookUrl         string      `json:"runbook_url"`
	NotifyRecovered    int         `json:"notify_recovered"`
	NotifyChannels     string      `json:"-"`
	NotifyChannelsJSON []string    `json:"notify_channels" gorm:"-"`
	NotifyGroups       string      `json:"-"`
	NotifyGroupsJSON   []string    `json:"notify_groups" gorm:"-"`
	NotifyGroupsObj    []UserGroup `json:"notify_groups_obj" gorm:"-"`
	TargetIdent        string      `json:"target_ident"`
	TargetNote         string      `json:"target_note"`
	TriggerTime        int64       `json:"trigger_time"`
	TriggerValue       string      `json:"trigger_value"`
	RecoverTime        int64       `json:"recover_time"`
	LastEvalTime       int64       `json:"last_eval_time"`
	Tags               string      `json:"-"`
	TagsJSON           []string    `json:"tags" gorm:"-"`
}

func AlertHisEventGet 

func AlertHisEventGet(where string, args ...interface{}) (*AlertHisEvent, error)

func AlertHisEventGetById 

func AlertHisEventGetById(id int64) (*AlertHisEvent, error)

func AlertHisEventGets 

func AlertHisEventGets(prod string, bgid, stime, etime int64, severity int, recovered int, clusters []string, query string, limit, offset int) ([]AlertHisEvent, error)

func (*AlertHisEvent) Add 

func (e *AlertHisEvent) Add() error

func (*AlertHisEvent) DB2FE 

func (e *AlertHisEvent) DB2FE()

func (*AlertHisEvent) FillNotifyGroups 

func (e *AlertHisEvent) FillNotifyGroups(cache map[int64]*UserGroup) error

func (*AlertHisEvent) TableName 

func (e *AlertHisEvent) TableName() string

type AlertMute 

type AlertMute struct {
	Id       int64        `json:"id" gorm:"primaryKey"`
	GroupId  int64        `json:"group_id"`
	Prod     string       `json:"prod"` // product empty means n9e
	Cluster  string       `json:"cluster"`
	Tags     ormx.JSONArr `json:"tags"`
	Cause    string       `json:"cause"`
	Btime    int64        `json:"btime"`
	Etime    int64        `json:"etime"`
	CreateBy string       `json:"create_by"`
	CreateAt int64        `json:"create_at"`
	ITags    []TagFilter  `json:"-" gorm:"-"` // inner tags
}

func AlertMuteGets 

func AlertMuteGets(prods []string, bgid int64, query string) (lst []AlertMute, err error)

func AlertMuteGetsByBG added in v5.9.2 

func AlertMuteGetsByBG(groupId int64) (lst []AlertMute, err error)

func AlertMuteGetsByCluster 

func AlertMuteGetsByCluster(cluster string) ([]*AlertMute, error)

func (*AlertMute) Add 

func (m *AlertMute) Add() error

func (*AlertMute) Parse 

func (m *AlertMute) Parse() error

func (*AlertMute) TableName 

func (m *AlertMute) TableName() string

func (*AlertMute) Verify 

func (m *AlertMute) Verify() error

type AlertNumber 

type AlertNumber struct {
	GroupId    int64
	GroupCount int64
}

type AlertRule 

type AlertRule struct {
	Id                   int64       `json:"id" gorm:"primaryKey"`
	GroupId              int64       `json:"group_id"`                     // busi group id
	Cluster              string      `json:"cluster"`                      // take effect by cluster
	Name                 string      `json:"name"`                         // rule name
	Note                 string      `json:"note"`                         // will sent in notify
	Prod                 string      `json:"prod"`                         // product empty means n9e
	Algorithm            string      `json:"algorithm"`                    // algorithm (”|holtwinters), empty means threshold
	AlgoParams           string      `json:"-" gorm:"algo_params"`         // params algorithm need
	AlgoParamsJson       interface{} `json:"algo_params" gorm:"-"`         //
	Delay                int         `json:"delay"`                        // Time (in seconds) to delay evaluation
	Severity             int         `json:"severity"`                     // 1: Emergency 2: Warning 3: Notice
	Disabled             int         `json:"disabled"`                     // 0: enabled, 1: disabled
	PromForDuration      int         `json:"prom_for_duration"`            // prometheus for, unit:s
	PromQl               string      `json:"prom_ql"`                      // just one ql
	PromEvalInterval     int         `json:"prom_eval_interval"`           // unit:s
	EnableStime          string      `json:"enable_stime"`                 // e.g. 00:00
	EnableEtime          string      `json:"enable_etime"`                 // e.g. 23:59
	EnableDaysOfWeek     string      `json:"-"`                            // split by space: 0 1 2 3 4 5 6
	EnableDaysOfWeekJSON []string    `json:"enable_days_of_week" gorm:"-"` // for fe
	EnableInBG           int         `json:"enable_in_bg"`                 // 0: global 1: enable one busi-group
	NotifyRecovered      int         `json:"notify_recovered"`             // whether notify when recovery
	NotifyChannels       string      `json:"-"`                            // split by space: sms voice email dingtalk wecom
	NotifyChannelsJSON   []string    `json:"notify_channels" gorm:"-"`     // for fe
	NotifyGroups         string      `json:"-"`                            // split by space: 233 43
	NotifyGroupsObj      []UserGroup `json:"notify_groups_obj" gorm:"-"`   // for fe
	NotifyGroupsJSON     []string    `json:"notify_groups" gorm:"-"`       // for fe
	NotifyRepeatStep     int         `json:"notify_repeat_step"`           // notify repeat interval, unit: min
	NotifyMaxNumber      int         `json:"notify_max_number"`            // notify: max number
	RecoverDuration      int64       `json:"recover_duration"`             // unit: s
	Callbacks            string      `json:"-"`                            // split by space: http://a.com/api/x http://a.com/api/y'
	CallbacksJSON        []string    `json:"callbacks" gorm:"-"`           // for fe
	RunbookUrl           string      `json:"runbook_url"`                  // sop url
	AppendTags           string      `json:"-"`                            // split by space: service=n9e mod=api
	AppendTagsJSON       []string    `json:"append_tags" gorm:"-"`         // for fe
	CreateAt             int64       `json:"create_at"`
	CreateBy             string      `json:"create_by"`
	UpdateAt             int64       `json:"update_at"`
	UpdateBy             string      `json:"update_by"`
}

func AlertRuleGet 

func AlertRuleGet(where string, args ...interface{}) (*AlertRule, error)

func AlertRuleGetById 

func AlertRuleGetById(id int64) (*AlertRule, error)

func AlertRuleGets 

func AlertRuleGets(groupId int64) ([]AlertRule, error)

func AlertRuleGetsByCluster 

func AlertRuleGetsByCluster(cluster string) ([]*AlertRule, error)

func AlertRulesGetsBy added in v5.9.2 

func AlertRulesGetsBy(prods []string, query string) ([]*AlertRule, error)

func (*AlertRule) Add 

func (ar *AlertRule) Add() error

func (*AlertRule) DB2FE 

func (ar *AlertRule) DB2FE()

func (*AlertRule) FE2DB 

func (ar *AlertRule) FE2DB() error

func (*AlertRule) FillNotifyGroups 

func (ar *AlertRule) FillNotifyGroups(cache map[int64]*UserGroup) error

func (*AlertRule) TableName 

func (ar *AlertRule) TableName() string

func (*AlertRule) Update 

func (ar *AlertRule) Update(arf AlertRule) error

func (*AlertRule) UpdateFieldsMap 

func (ar *AlertRule) UpdateFieldsMap(fields map[string]interface{}) error

func (*AlertRule) Verify 

func (ar *AlertRule) Verify() error

type AlertSubscribe 

type AlertSubscribe struct {
	Id               int64        `json:"id" gorm:"primaryKey"`
	GroupId          int64        `json:"group_id"`
	Cluster          string       `json:"cluster"`
	RuleId           int64        `json:"rule_id"`
	RuleName         string       `json:"rule_name" gorm:"-"` // for fe
	Tags             ormx.JSONArr `json:"tags"`
	RedefineSeverity int          `json:"redefine_severity"`
	NewSeverity      int          `json:"new_severity"`
	RedefineChannels int          `json:"redefine_channels"`
	NewChannels      string       `json:"new_channels"`
	UserGroupIds     string       `json:"user_group_ids"`
	UserGroups       []UserGroup  `json:"user_groups" gorm:"-"` // for fe
	CreateBy         string       `json:"create_by"`
	CreateAt         int64        `json:"create_at"`
	UpdateBy         string       `json:"update_by"`
	UpdateAt         int64        `json:"update_at"`
	ITags            []TagFilter  `json:"-" gorm:"-"` // inner tags
}

func AlertSubscribeGet 

func AlertSubscribeGet(where string, args ...interface{}) (*AlertSubscribe, error)

func AlertSubscribeGets 

func AlertSubscribeGets(groupId int64) (lst []AlertSubscribe, err error)

func AlertSubscribeGetsByCluster 

func AlertSubscribeGetsByCluster(cluster string) ([]*AlertSubscribe, error)

func (*AlertSubscribe) Add 

func (s *AlertSubscribe) Add() error

func (*AlertSubscribe) FillRuleName 

func (s *AlertSubscribe) FillRuleName(cache map[int64]string) error

func (*AlertSubscribe) FillUserGroups 

func (s *AlertSubscribe) FillUserGroups(cache map[int64]*UserGroup) error

func (*AlertSubscribe) Parse 

func (s *AlertSubscribe) Parse() error

func (*AlertSubscribe) TableName 

func (s *AlertSubscribe) TableName() string

func (*AlertSubscribe) Update 

func (s *AlertSubscribe) Update(selectField interface{}, selectFields ...interface{}) error

func (*AlertSubscribe) Verify 

func (s *AlertSubscribe) Verify() error

type Board added in v5.8.0 

type Board struct {
	Id       int64  `json:"id" gorm:"primaryKey"`
	GroupId  int64  `json:"group_id"`
	Name     string `json:"name"`
	Tags     string `json:"tags"`
	CreateAt int64  `json:"create_at"`
	CreateBy string `json:"create_by"`
	UpdateAt int64  `json:"update_at"`
	UpdateBy string `json:"update_by"`
	Configs  string `json:"configs" gorm:"-"`
}

func BoardGet added in v5.8.0 

func BoardGet(where string, args ...interface{}) (*Board, error)

BoardGet for detail page

func BoardGets added in v5.8.0 

func BoardGets(groupId int64, query string) ([]Board, error)

BoardGets for list page

func (*Board) Add added in v5.8.0 

func (b *Board) Add() error

func (*Board) Del added in v5.8.0 

func (b *Board) Del() error

func (*Board) TableName added in v5.8.0 

func (b *Board) TableName() string

func (*Board) Update added in v5.8.0 

func (b *Board) Update(selectField interface{}, selectFields ...interface{}) error

func (*Board) Verify added in v5.8.0 

func (b *Board) Verify() error

type BoardPayload added in v5.8.0 

type BoardPayload struct {
	Id      int64  `json:"id" gorm:"primaryKey"`
	Payload string `json:"payload"`
}

func BoardPayloadGets added in v5.8.0 

func BoardPayloadGets(ids []int64) ([]*BoardPayload, error)

func (*BoardPayload) TableName added in v5.8.0 

func (p *BoardPayload) TableName() string

func (*BoardPayload) Update added in v5.8.0 

func (p *BoardPayload) Update(selectField interface{}, selectFields ...interface{}) error

type BusiGroup 

type BusiGroup struct {
	Id          int64                   `json:"id" gorm:"primaryKey"`
	Name        string                  `json:"name"`
	LabelEnable int                     `json:"label_enable"`
	LabelValue  string                  `json:"label_value"`
	CreateAt    int64                   `json:"create_at"`
	CreateBy    string                  `json:"create_by"`
	UpdateAt    int64                   `json:"update_at"`
	UpdateBy    string                  `json:"update_by"`
	UserGroups  []UserGroupWithPermFlag `json:"user_groups" gorm:"-"`
}

func BusiGroupGet 

func BusiGroupGet(where string, args ...interface{}) (*BusiGroup, error)

func BusiGroupGetById 

func BusiGroupGetById(id int64) (*BusiGroup, error)

func (*BusiGroup) AddMembers 

func (bg *BusiGroup) AddMembers(members []BusiGroupMember, username string) error

func (*BusiGroup) Del 

func (bg *BusiGroup) Del() error

func (*BusiGroup) DelMembers 

func (bg *BusiGroup) DelMembers(members []BusiGroupMember, username string) error

func (*BusiGroup) FillUserGroups 

func (bg *BusiGroup) FillUserGroups() error

func (*BusiGroup) TableName 

func (bg *BusiGroup) TableName() string

func (*BusiGroup) Update 

func (bg *BusiGroup) Update(name string, labelEnable int, labelValue string, updateBy string) error

type BusiGroupMember 

type BusiGroupMember struct {
	BusiGroupId int64  `json:"busi_group_id"`
	UserGroupId int64  `json:"user_group_id"`
	PermFlag    string `json:"perm_flag"`
}

func BusiGroupMemberGet 

func BusiGroupMemberGet(where string, args ...interface{}) (*BusiGroupMember, error)

func BusiGroupMemberGets 

func BusiGroupMemberGets(where string, args ...interface{}) ([]BusiGroupMember, error)

func BusiGroupMemberGetsByBusiGroupId 

func BusiGroupMemberGetsByBusiGroupId(busiGroupId int64) ([]BusiGroupMember, error)

func (BusiGroupMember) TableName 

func (BusiGroupMember) TableName() string

type Chart 

type Chart struct {
	Id      int64  `json:"id" gorm:"primaryKey"`
	GroupId int64  `json:"group_id"`
	Configs string `json:"configs"`
	Weight  int    `json:"weight"`
}

func ChartsOf 

func ChartsOf(chartGroupId int64) ([]Chart, error)

func (*Chart) Add 

func (c *Chart) Add() error

func (*Chart) Del 

func (c *Chart) Del() error

func (*Chart) TableName 

func (c *Chart) TableName() string

func (*Chart) Update 

func (c *Chart) Update(selectField interface{}, selectFields ...interface{}) error

type ChartGroup 

type ChartGroup struct {
	Id          int64  `json:"id" gorm:"primaryKey"`
	DashboardId int64  `json:"dashboard_id"`
	Name        string `json:"name"`
	Weight      int    `json:"weight"`
}

func ChartGroupsOf 

func ChartGroupsOf(dashId int64) ([]ChartGroup, error)

func (*ChartGroup) Add 

func (cg *ChartGroup) Add() error

func (*ChartGroup) Del 

func (cg *ChartGroup) Del() error

func (*ChartGroup) TableName 

func (cg *ChartGroup) TableName() string

func (*ChartGroup) Update 

func (cg *ChartGroup) Update(selectField interface{}, selectFields ...interface{}) error

func (*ChartGroup) Verify 

func (cg *ChartGroup) Verify() error

type ChartShare 

type ChartShare struct {
	Id       int64  `json:"id" gorm:"primaryKey"`
	Cluster  string `json:"cluster"`
	Configs  string `json:"configs"`
	CreateBy string `json:"create_by"`
	CreateAt int64  `json:"create_at"`
}

func ChartShareGetsByIds 

func ChartShareGetsByIds(ids []int64) ([]ChartShare, error)

func (*ChartShare) Add 

func (cs *ChartShare) Add() error

func (*ChartShare) TableName 

func (cs *ChartShare) TableName() string

type Configs 

type Configs struct {
	Id   int64 `gorm:"primaryKey"`
	Ckey string
	Cval string
}

func (Configs) TableName 

func (Configs) TableName() string

type Dashboard 

type Dashboard struct {
	Id       int64    `json:"id" gorm:"primaryKey"`
	GroupId  int64    `json:"group_id"`
	Name     string   `json:"name"`
	Tags     string   `json:"-"`
	TagsLst  []string `json:"tags" gorm:"-"`
	Configs  string   `json:"configs"`
	CreateAt int64    `json:"create_at"`
	CreateBy string   `json:"create_by"`
	UpdateAt int64    `json:"update_at"`
	UpdateBy string   `json:"update_by"`
}

func DashboardGet 

func DashboardGet(where string, args ...interface{}) (*Dashboard, error)

func DashboardGetAll added in v5.8.0 

func DashboardGetAll() ([]Dashboard, error)

func DashboardGets 

func DashboardGets(groupId int64, query string) ([]Dashboard, error)

func DashboardGetsByIds 

func DashboardGetsByIds(ids []int64) ([]Dashboard, error)

func (*Dashboard) Add 

func (d *Dashboard) Add() error

func (*Dashboard) Del 

func (d *Dashboard) Del() error

func (*Dashboard) TableName 

func (d *Dashboard) TableName() string

func (*Dashboard) Update 

func (d *Dashboard) Update(selectField interface{}, selectFields ...interface{}) error

func (*Dashboard) Verify 

func (d *Dashboard) Verify() error

type MetricDescription 

type MetricDescription struct {
	Id          int64  `json:"id"`
	Metric      string `json:"metric"`
	Description string `json:"description"`
	UpdateAt    int64  `json:"update_at"`
}

func MetricDescGetAll 

func MetricDescGetAll() ([]MetricDescription, error)

func MetricDescriptionGet 

func MetricDescriptionGet(where string, args ...interface{}) (*MetricDescription, error)

func MetricDescriptionGets 

func MetricDescriptionGets(query string, limit, offset int) ([]MetricDescription, error)

func (*MetricDescription) TableName 

func (md *MetricDescription) TableName() string

func (*MetricDescription) Update 

func (md *MetricDescription) Update(desn string, now int64) error

type MetricView added in v5.5.0 

type MetricView struct {
	Id       int64  `json:"id" gorm:"primaryKey"`
	Name     string `json:"name"`
	Cate     int    `json:"cate"`
	Configs  string `json:"configs"`
	CreateAt int64  `json:"create_at"`
	CreateBy int64  `json:"create_by"`
	UpdateAt int64  `json:"update_at"`
}

MetricView 在告警聚合视图查看的时候，要存储一些聚合规则

func MetricViewGet added in v5.5.0 

func MetricViewGet(where string, args ...interface{}) (*MetricView, error)

func MetricViewGets added in v5.5.0 

func MetricViewGets(createBy interface{}) ([]MetricView, error)

func (*MetricView) Add added in v5.5.0 

func (v *MetricView) Add() error

func (*MetricView) TableName added in v5.5.0 

func (v *MetricView) TableName() string

func (*MetricView) Update added in v5.5.0 

func (v *MetricView) Update(name, configs string, cate int, createBy int64) error

func (*MetricView) Verify added in v5.5.0 

func (v *MetricView) Verify() error

type Role 

type Role struct {
	Id   int64  `json:"id" gorm:"primaryKey"`
	Name string `json:"name"`
	Note string `json:"note"`
}

func RoleGets 

func RoleGets(where string, args ...interface{}) ([]Role, error)

func RoleGetsAll 

func RoleGetsAll() ([]Role, error)

func (Role) TableName 

func (Role) TableName() string

type RoleOperation 

type RoleOperation struct {
	RoleName  string
	Operation string
}

func (RoleOperation) TableName 

func (RoleOperation) TableName() string

type Statistics 

type Statistics struct {
	Total       int64 `gorm:"total"`
	LastUpdated int64 `gorm:"last_updated"`
}

func AlertMuteStatistics 

func AlertMuteStatistics(cluster string) (*Statistics, error)

func AlertRuleStatistics 

func AlertRuleStatistics(cluster string) (*Statistics, error)

func AlertSubscribeStatistics 

func AlertSubscribeStatistics(cluster string) (*Statistics, error)

func BusiGroupStatistics added in v5.5.0 

func BusiGroupStatistics() (*Statistics, error)

func MetricDescStatistics 

func MetricDescStatistics() (*Statistics, error)

func TargetStatistics 

func TargetStatistics(cluster string) (*Statistics, error)

func UserGroupStatistics 

func UserGroupStatistics() (*Statistics, error)

func UserStatistics 

func UserStatistics() (*Statistics, error)

type TagFilter 

type TagFilter struct {
	Key    string              `json:"key"`   // tag key
	Func   string              `json:"func"`  // == | =~ | in
	Value  string              `json:"value"` // tag value
	Regexp *regexp.Regexp      // parse value to regexp if func = '=~'
	Vset   map[string]struct{} // parse value to regexp if func = 'in'
}

type Target 

type Target struct {
	Id       int64             `json:"id" gorm:"primaryKey"`
	GroupId  int64             `json:"group_id"`
	GroupObj *BusiGroup        `json:"group_obj" gorm:"-"`
	Cluster  string            `json:"cluster"`
	Ident    string            `json:"ident"`
	Note     string            `json:"note"`
	Tags     string            `json:"-"`
	TagsJSON []string          `json:"tags" gorm:"-"`
	TagsMap  map[string]string `json:"-" gorm:"-"` // internal use, append tags to series
	UpdateAt int64             `json:"update_at"`
}

func TargetGet 

func TargetGet(where string, args ...interface{}) (*Target, error)

func TargetGetById 

func TargetGetById(id int64) (*Target, error)

func TargetGetByIdent 

func TargetGetByIdent(ident string) (*Target, error)

func TargetGets 

func TargetGets(bgid int64, clusters []string, query string, limit, offset int) ([]*Target, error)

func TargetGetsByCluster 

func TargetGetsByCluster(cluster string) ([]*Target, error)

func (*Target) Add 

func (t *Target) Add() error

func (*Target) AddTags 

func (t *Target) AddTags(tags []string) error

func (*Target) DelTags 

func (t *Target) DelTags(tags []string) error

func (*Target) FillGroup 

func (t *Target) FillGroup(cache map[int64]*BusiGroup) error

func (*Target) TableName 

func (t *Target) TableName() string

type TaskRecord 

type TaskRecord struct {
	Id           int64  `json:"id" gorm:"primaryKey"`
	GroupId      int64  `json:"group_id"`
	IbexAddress  string `json:"ibex_address"`
	IbexAuthUser string `json:"ibex_auth_user"`
	IbexAuthPass string `json:"ibex_auth_pass"`
	Title        string `json:"title"`
	Account      string `json:"account"`
	Batch        int    `json:"batch"`
	Tolerance    int    `json:"tolerance"`
	Timeout      int    `json:"timeout"`
	Pause        string `json:"pause"`
	Script       string `json:"script"`
	Args         string `json:"args"`
	CreateAt     int64  `json:"create_at"`
	CreateBy     string `json:"create_by"`
}

func TaskRecordGets 

func TaskRecordGets(bgid, beginTime int64, createBy, query string, limit, offset int) ([]*TaskRecord, error)

func (*TaskRecord) Add 

func (r *TaskRecord) Add() error

create task

func (*TaskRecord) TableName 

func (r *TaskRecord) TableName() string

func (*TaskRecord) UpdateIsDone 

func (r *TaskRecord) UpdateIsDone(isDone int) error

update is_done field

type TaskTpl 

type TaskTpl struct {
	Id        int64    `json:"id" gorm:"primaryKey"`
	GroupId   int64    `json:"group_id"`
	Title     string   `json:"title"`
	Batch     int      `json:"batch"`
	Tolerance int      `json:"tolerance"`
	Timeout   int      `json:"timeout"`
	Pause     string   `json:"pause"`
	Script    string   `json:"script"`
	Args      string   `json:"args"`
	Tags      string   `json:"-"`
	TagsJSON  []string `json:"tags" gorm:"-"`
	Account   string   `json:"account"`
	CreateAt  int64    `json:"create_at"`
	CreateBy  string   `json:"create_by"`
	UpdateAt  int64    `json:"update_at"`
	UpdateBy  string   `json:"update_by"`
}

func TaskTplGet 

func TaskTplGet(where string, args ...interface{}) (*TaskTpl, error)

func TaskTplGets 

func TaskTplGets(groupId int64, query string, limit, offset int) ([]TaskTpl, error)

func (*TaskTpl) AddTags 

func (t *TaskTpl) AddTags(tags []string, updateBy string) error

func (*TaskTpl) CleanFields 

func (t *TaskTpl) CleanFields() error

func (*TaskTpl) Del 

func (t *TaskTpl) Del() error

func (*TaskTpl) DelTags 

func (t *TaskTpl) DelTags(tags []string, updateBy string) error

func (*TaskTpl) Hosts 

func (t *TaskTpl) Hosts() ([]string, error)

func (*TaskTpl) Save 

func (t *TaskTpl) Save(hosts []string) error

func (*TaskTpl) TableName 

func (t *TaskTpl) TableName() string

func (*TaskTpl) Update 

func (t *TaskTpl) Update(hosts []string) error

func (*TaskTpl) UpdateGroup 

func (t *TaskTpl) UpdateGroup(groupId int64, updateBy string) error

type User 

type User struct {
	Id         int64        `json:"id" gorm:"primaryKey"`
	Username   string       `json:"username"`
	Nickname   string       `json:"nickname"`
	Password   string       `json:"-"`
	Phone      string       `json:"phone"`
	Email      string       `json:"email"`
	Portrait   string       `json:"portrait"`
	Roles      string       `json:"-"`              // 这个字段写入数据库
	RolesLst   []string     `json:"roles" gorm:"-"` // 这个字段和前端交互
	Contacts   ormx.JSONObj `json:"contacts"`       // 内容为 map[string]string 结构
	Maintainer int          `json:"maintainer"`     // 是否给管理员发消息 0:not send 1:send
	CreateAt   int64        `json:"create_at"`
	CreateBy   string       `json:"create_by"`
	UpdateAt   int64        `json:"update_at"`
	UpdateBy   string       `json:"update_by"`
	Admin      bool         `json:"admin" gorm:"-"` // 方便前端使用
}

func LdapLogin 

func LdapLogin(username, pass string) (*User, error)

func PassLogin 

func PassLogin(username, pass string) (*User, error)

func UserGet 

func UserGet(where string, args ...interface{}) (*User, error)

func UserGetAll 

func UserGetAll() ([]*User, error)

func UserGetById 

func UserGetById(id int64) (*User, error)

func UserGetByUsername 

func UserGetByUsername(username string) (*User, error)

func UserGets 

func UserGets(query string, limit, offset int) ([]User, error)

func UserGetsByIds 

func UserGetsByIds(ids []int64) ([]User, error)

func (*User) Add 

func (u *User) Add() error

func (*User) BusiGroups 

func (u *User) BusiGroups(limit int, query string, all ...bool) ([]BusiGroup, error)

我是管理员，返回所有 或者我是成员

func (*User) CanDoBusiGroup 

func (u *User) CanDoBusiGroup(bg *BusiGroup, permFlag ...string) (bool, error)

func (*User) CanModifyUserGroup 

func (u *User) CanModifyUserGroup(ug *UserGroup) (bool, error)

func (*User) ChangePassword 

func (u *User) ChangePassword(oldpass, newpass string) error

func (*User) CheckPerm 

func (u *User) CheckPerm(operation string) (bool, error)

func (*User) Del 

func (u *User) Del() error

func (*User) IsAdmin 

func (u *User) IsAdmin() bool

func (*User) NopriIdents 

func (u *User) NopriIdents(idents []string) ([]string, error)

func (*User) TableName 

func (u *User) TableName() string

func (*User) Update added in v5.5.0 

func (u *User) Update(selectField interface{}, selectFields ...interface{}) error

func (*User) UpdateAllFields 

func (u *User) UpdateAllFields() error

func (*User) UpdatePassword 

func (u *User) UpdatePassword(password, updateBy string) error

func (*User) UserGroups added in v5.3.4 

func (u *User) UserGroups(limit int, query string) ([]UserGroup, error)

func (*User) Verify 

func (u *User) Verify() error

type UserGroup 

type UserGroup struct {
	Id       int64   `json:"id" gorm:"primaryKey"`
	Name     string  `json:"name"`
	Note     string  `json:"note"`
	CreateAt int64   `json:"create_at"`
	CreateBy string  `json:"create_by"`
	UpdateAt int64   `json:"update_at"`
	UpdateBy string  `json:"update_by"`
	UserIds  []int64 `json:"-" gorm:"-"`
}

func UserGroupGet 

func UserGroupGet(where string, args ...interface{}) (*UserGroup, error)

func UserGroupGetAll 

func UserGroupGetAll() ([]*UserGroup, error)

func UserGroupGetById 

func UserGroupGetById(id int64) (*UserGroup, error)

func UserGroupGetByIds 

func UserGroupGetByIds(ids []int64) ([]UserGroup, error)

func (*UserGroup) Add 

func (ug *UserGroup) Add() error

func (*UserGroup) AddMembers 

func (ug *UserGroup) AddMembers(userIds []int64) error

func (*UserGroup) Del 

func (ug *UserGroup) Del() error

func (*UserGroup) DelMembers 

func (ug *UserGroup) DelMembers(userIds []int64) error

func (*UserGroup) TableName 

func (ug *UserGroup) TableName() string

func (*UserGroup) Update 

func (ug *UserGroup) Update(selectField interface{}, selectFields ...interface{}) error

func (*UserGroup) Verify 

func (ug *UserGroup) Verify() error

type UserGroupMember 

type UserGroupMember struct {
	GroupId int64
	UserId  int64
}

func UserGroupMemberGetAll 

func UserGroupMemberGetAll() ([]UserGroupMember, error)

func (UserGroupMember) TableName 

func (UserGroupMember) TableName() string

type UserGroupWithPermFlag 

type UserGroupWithPermFlag struct {
	UserGroup *UserGroup `json:"user_group"`
	PermFlag  string     `json:"perm_flag"`
}

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.