models

package
v5.4.0 Latest Latest
Warning

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

 Go to latest Published: Mar 1, 2022 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

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(bgid, stime, etime int64, severity int, clusters []string, query string) (int64, error)

func AlertHisEventTotal 

func AlertHisEventTotal(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, busiGroupId 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 BusiGroupAdd 

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

func BusiGroupExists 

func BusiGroupExists(where string, args ...interface{}) (bool, 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 CollectRuleDels 

func CollectRuleDels(ids []int64, busiGroupId int64) error

func CollectRuleExists 

func CollectRuleExists(where string, args ...interface{}) (bool, 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 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 AlertCurEvent 

type AlertCurEvent struct {
	Id                 int64             `json:"id" gorm:"primaryKey"`
	Cluster            string            `json:"cluster"`
	GroupId            int64             `json:"group_id"` // busi group id
	Hash               string            `json:"hash"`     // rule_id + vector_key
	RuleId             int64             `json:"rule_id"`
	RuleName           string            `json:"rule_name"`
	RuleNote           string            `json:"rule_note"`
	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
	NotifyRepeatNext   int64             `json:"notify_repeat_next"`
	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:"-"`   // 上次发送时间
}

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 AlertCurEventGetByRule 

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

func AlertCurEventGets 

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

func AlertCurEventNeedRepeat 

func AlertCurEventNeedRepeat(cluster string) ([]*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) IncRepeatStep 

func (e *AlertCurEvent) IncRepeatStep(step int64) 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"`
	Hash               string      `json:"hash"`
	RuleId             int64       `json:"rule_id"`
	RuleName           string      `json:"rule_name"`
	RuleNote           string      `json:"rule_note"`
	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(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"`
	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(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
	Severity             int         `json:"severity"`                     // 0: Emergency 1: Warning 2: 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
	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 (*AlertRule) Add 

func (ar *AlertRule) Add() error

func (*AlertRule) DB2FE 

func (ar *AlertRule) DB2FE()

func (*AlertRule) FE2DB 

func (ar *AlertRule) FE2DB()

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 BusiGroup 

type BusiGroup struct {
	Id         int64                   `json:"id" gorm:"primaryKey"`
	Name       string                  `json:"name"`
	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, 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 CollectRule 

type CollectRule struct {
	Id               int64    `json:"id"`
	GroupId          int64    `json:"group_id"`
	Cluster          string   `json:"cluster"`
	TargetIdents     string   `json:"-"`
	TargetIdentsJSON []string `json:"target_idents" gorm:"-"`
	TargetTags       string   `json:"-"`
	TargetTagsJSON   []string `json:"target_tags" gorm:"-"`
	Name             string   `json:"name"`
	Note             string   `json:"note"`
	Step             int      `json:"step"`
	Type             string   `json:"type"`
	Data             string   `json:"data"`
	AppendTags       string   `json:"-"`
	AppendTagsJSON   []string `json:"append_tags" gorm:"-"`
	CreateAt         int64    `json:"create_at"`
	CreateBy         string   `json:"create_by"`
	UpdateAt         int64    `json:"update_at"`
	UpdateBy         string   `json:"update_by"`
}

func CollectRuleGet 

func CollectRuleGet(where string, args ...interface{}) (*CollectRule, error)

func CollectRuleGetById 

func CollectRuleGetById(id int64) (*CollectRule, error)

func CollectRuleGets 

func CollectRuleGets(groupId int64, typ string) ([]CollectRule, error)

func (*CollectRule) Add 

func (cr *CollectRule) Add() error

func (*CollectRule) DB2FE 

func (cr *CollectRule) DB2FE()

func (*CollectRule) FE2DB 

func (cr *CollectRule) FE2DB()

func (*CollectRule) TableName 

func (cr *CollectRule) TableName() string

func (*CollectRule) Update 

func (cr *CollectRule) Update(crf CollectRule) error

func (*CollectRule) Verify 

func (cr *CollectRule) Verify() error

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 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 LogConfig 

type LogConfig struct {
	FilePath    string            `json:"file_path"`
	Func        string            `json:"func"`
	Pattern     string            `json:"pattern"`
	TagsPattern map[string]string `json:"tags_pattern"`
}

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 PortConfig 

type PortConfig struct {
	Port     int    `json:"port"`
	Protocol string `json:"protocol"` // tcp or udp
	Timeout  int    `json:"timeout"`  // second
}

type ProcConfig 

type ProcConfig struct {
	Method string `json:"method"`
	Param  string `json:"param"`
}

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 ScriptConfig 

type ScriptConfig struct {
	Path    string            `json:"path"`
	Params  string            `json:"params"`
	Stdin   string            `json:"stdin"`
	Env     map[string]string `json:"env"`
	Timeout int               `json:"timeout"` // second
}

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 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 结构
	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) 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.