The highest tagged major version is v5.

models

package

v4.0.4 Latest Latest Go to latest Published: Aug 4, 2021 License: Apache-2.0 Imports: 30 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/didi/nightingale

Documentation ¶

Index ¶

Constants
Variables
func AggrCalcDel(id int64) error
func AlertUpgradeMarshal(alterUpgrade AlertUpgrade) (string, error)
func AuthConfigSet(config *AuthConfig) error
func CancelTask(id int64) error
func CancelWaitingHosts(id int64) error
func CleanDoneTask(id int64) error
func CleanExpireMask(now int64) error
func ConfigsGet(ckey string) (string, error)
func ConfigsGets(ckeys []string) (map[string]string, error)
func ConfigsSet(ckey, cval string) error
func CreateCollect(collectType, creator string, collect interface{}, dryRun bool) (err error)
func CryptoPass(raw string) (string, error)
func DeadTaskSchedulers() ([]string, error)
func DelById(id int64) error
func DelDeadTaskScheduler(scheduler string) error
func DelEventCurOlder(ts int64, batch int) error
func DelEventOlder(ts int64, batch int) error
func DeleteCollectById(collectType, creator string, cid int64) error
func DeleteCollectRule(sid int64) error
func DoingHostCount(where string, args ...interface{}) (int64, error)
func EventAlertUpgradeMarshal(alertUpgrade AlertUpgrade) (string, error)
func EventCnt(hashid uint64, stime, etime int64, isUpgrade bool) (int64, error)
func EventCurDel(hashid uint64) error
func EventCurDelById(id interface{}) error
func EventCurTotal(stime, etime int64, nodePath, query string, priorities, sendTypes []string) (int64, error)
func EventDelById(id interface{}) error
func EventTotal(stime, etime int64, nodePath, query, eventType string, ...) (int64, error)
func GenUUIDForUser(username string) string
func GetFlagsByStatus(ss []string) []uint16
func GetRelatedNidsForMon(nid int64, exclNid []int64) ([]int64, error)
func GetStatus(status string) int
func GetStatusByFlag(flag uint16) []string
func GetTeamsNameByIds(ids string) ([]string, error)
func GetUsernameByToken(token string) (string, error)
func HostFieldNew(objPtr *HostField) error
func HostFieldValuePuts(hostId int64, objs []HostFieldValue) error
func HostIdsByIps(ips []string) (ids []int64, err error)
func HostRegister(f HostRegisterForm) error
func HostTotalForAdmin(tenant, query, batch, field string) (int64, error)
func HostUpdateCate(ids []int64, cate string) error
func HostUpdateNote(ids []int64, note string) error
func HostUpdateTenant(ids []int64, tenant string) error
func IngStatusHostCount(id int64) (int64, error)
func InitLDAP(conf LDAPSection)
func InitMySQL(names ...string)
func InitRooter()
func InitSalt()
func InviteNew(token, creator string) error
func KillTask(id int64) error
func LeafIdsByNodes(nodes []Node) ([]int64, error)
func LoginLogNew(username, client, inout string, err error) error
func LoginLogTotal(username string, btime, etime int64) (int64, error)
func LongTaskIds() ([]int64, error)
func MapKeyClear(src map[string]interface{}, save map[string]struct{})
func MarkDoneStatus(id, clock int64, host, status, stdout, stderr string) error
func MaskconfDel(id int64) error
func MibDel(id int64) error
func MibTotal(query string) (int64, error)
func NetworkHardwareCount(where string, args ...interface{}) (int64, error)
func NetworkHardwareDel(id int64) error
func NetworkHardwareNew(objPtr *NetworkHardware) error
func NetworkHardwareResourceRegister(hws []*NetworkHardware, tenant string) error
func NetworkHardwareTotal(query string) (int64, error)
func NodeAdminExists(session *xorm.Session, nodeId, userId int64) (bool, error)
func NodeAdminNew(session *xorm.Session, nodeId, userId int64) error
func NodeCateFieldNew(objPtr *NodeCateField) error
func NodeCateNew(objPtr *NodeCate) error
func NodeClearAdmins(session *xorm.Session, nodeId int64) error
func NodeFieldValuePuts(nodeId int64, objs []NodeFieldValue) error
func NodeIdsBindingUsername(username string) ([]int64, error)
func NodeIdsBindingUsernameWithOp(username, op string) ([]int64, error)
func NodeIdsBindingUsernameWithRoles(username string, roleIds []int64) ([]int64, error)
func NodeIdsByPaths(paths []string) ([]int64, error)
func NodeIdsGetByResIds(rids []int64) ([]int64, error)
func NodeIdsIamAdmin(userId int64) ([]int64, error)
func NodeNew(objPtr *Node, adminIds []int64) error
func NodeResourceBind(nid, rid int64) error
func NodeResourceUnbind(nid, rid int64) error
func NodeResourceUnbindByRids(rids []int64) error
func NodeRoleDel(nodeId, roleId int64, username string) error
func NodeRoleExists(nodeIds, roleIds []int64, username string) (bool, error)
func NodeTrashRecycle(ids []int64) error
func NodeTrashTotal(query string) (int64, error)
func NodesAdminExists(nodeIds []int64, userId int64) (bool, error)
func NwTotalForAdmin(tenant, query, batch, field string) (int64, error)
func OperationLogNew(username, rescl string, resid interface{}, detail string) error
func OperationLogTotal(query string, btime, etime int64) (int64, error)
func OperationLogTotalByRes(rescl, resid string, btime, etime int64) (int64, error)
func OperationsOfRoles(rids []int64) ([]string, error)
func OrphanTaskIds() ([]int64, error)
func ParseEtime(etime int64) string
func Paths(longPath string) []string
func ReportHeartBeat(rev Instance) error
func ResCountGetByNodeIdsAndCate(nids []int64, cate string) (int, error)
func ResIdsGetByNodeIds(nids []int64) ([]int64, error)
func ResourceBindingsForMon(idents []string) ([]string, error)
func ResourceIdentsByIds(ids []int64) ([]string, error)
func ResourceIdsByIdents(idents []string) ([]int64, error)
func ResourceIdsByUUIDs(uuids []string) ([]int64, error)
func ResourceOrphanTotal(tenant, query, batch, field string) (int64, error)
func ResourceRegister(hosts []Host, tenant string) error
func ResourceRegisterFor3rd(item ResourceRegisterItem) (errCode int, err error)
func ResourceUnderNodeTotal(leafIds []int64, query, batch, field string) (int64, error)
func ResourceUnregister(uuids []string) error
func RoleBiggerThan(roleid int64) ([]int64, error)
func RoleIdsBindingUsername(username string, nids []int64) ([]int64, error)
func RoleIdsGetByUserId(userId int64) ([]int64, error)
func RoleIdsHasOp(op string) ([]int64, error)
func RoleMap(cate string) (map[int64]string, error)
func RunWaitingHosts(hosts []TaskHost) error
func SaveEvent(event *Event) error
func SaveEventCur(eventCur *EventCur) error
func SaveEventCurStatus(hashid uint64, status string) error
func SaveEventStatus(id int64, status string) error
func SaveStraCommit(id int64, action, username, body string, session *xorm.Session) error
func SessionAll() (int64, error)
func SessionCleanupByCreatedAt(ts int64) error
func SessionCleanupByUpdatedAt(ts int64) error
func SessionDelete(sid string) error
func SessionTotal(where string, args ...interface{}) (int64, error)
func SessionUpdate(in *Session) error
func SessionUserAll(username string) (int64, error)
func SetDoingCache(v map[string][]TaskHostDoing)
func StartTask(id int64) error
func StatusConvert(s []string) []string
func StraDel(id int64) error
func StraDelByNid(nid int64) error
func TakeOverTask(id int64, pre, current string) (bool, error)
func TaskActionExistsIds(ids []int64) ([]int64, error)
func TaskMetaTotal(creator, query string, before time.Time) (int64, error)
func TaskSchedulerHeartbeat(endpoint string) error
func TaskTplTotal(nodeId int64, query string) (int64, error)
func TasksOfScheduler(scheduler string) ([]int64, error)
func TeamAdd(ident, name, note string, mgmt int, creator int64) (int64, error)
func TeamHasMember(tid, uid int64, isAdmin ...int) (bool, error)
func TeamIdentByIds(ids []int64) ([]string, error)
func TeamIdsByUserId(uid int64, isAdmin ...int) ([]int64, error)
func TeamTotal(query string) (int64, error)
func TeamTotalInIds(ids []int64, query string) (int64, error)
func TokenAll() (int64, error)
func TokenDelete(token string) error
func UnexpectedHostCount(id int64) (int64, error)
func UpdateClaimantsById(userId, id int64) error
func UpdateClaimantsByNodePath(userId int64, nodePath string) error
func UpdateEventCurPriority(hashid uint64, priority int) error
func UpdateEventPriority(id int64, priority int) error
func UpdateIconColor(newColor, cate string) error
func UserFillUUIDs() error
func UserHasGlobalRole(userId int64, roleIds []int64) (bool, error)
func UserIdsByTeamIds(tids []int64, isAdmin ...int) ([]int64, error)
func UserIdsGetByRoleIds(roleIds []int64) ([]int64, error)
func UserSearchTotalInIds(ids []int64, query string) (int64, error)
func UserTotal(ids []int64, where string, args ...interface{}) (int64, error)
func UsernameByUUID(uuid string) string
func UsernameCandoGlobalOp(username, operation string) (bool, error)
func UsernameCandoNodeOp(username, operation string, nodeId int64) (bool, error)
func WaitingHostCount(id int64) (int64, error)
func WarningStr(s string) bool
func WhiteListAccess(addr string) error
func WhiteListTotal(query string) (int64, error)
type AggrCalc
- func AggrCalcGet(where string, args ...interface{}) (*AggrCalc, error)
- func AggrCalcsList(name string, nid int64) ([]*AggrCalc, error)
- func (a *AggrCalc) Decode() error
- func (a *AggrCalc) Encode() error
- func (a *AggrCalc) Save() error
- func (a *AggrCalc) Update(cols ...string) error
type AggrTagsFilter
type AlertUpgrade
- func AlertUpgradeUnMarshal(str string) (AlertUpgrade, error)
type ApiCollect
- func GetApiCollects() ([]*ApiCollect, error)
- func (a *ApiCollect) Decode() error
- func (a *ApiCollect) Encode() error
- func (a *ApiCollect) Update() error
type ApiCollectRpcResp
type Auth
type AuthConfig
- func AuthConfigGet() (*AuthConfig, error)
- func (p AuthConfig) MustInclude() string
- func (p AuthConfig) PwdRules() []string
- func (p *AuthConfig) Validate() error
type AuthState
- func AuthStateGet(where string, args ...interface{}) (*AuthState, error)
- func (p AuthState) CleanUp() error
- func (p *AuthState) Del() error
- func (p *AuthState) Save() error
type Captcha
- func CaptchaGet(where string, args ...interface{}) (*Captcha, error)
- func (p Captcha) CleanUp() error
- func (p *Captcha) Del() error
- func (p *Captcha) Save() error
type Chart
- func ChartGet(col string, val interface{}) (*Chart, error)
- func ChartGets(subclassId int64) ([]Chart, error)
- func (c *Chart) Add() error
- func (c *Chart) Del() error
- func (c *Chart) Update(cols ...string) error
type Collect
- func NewCollect() *Collect
- func (c *Collect) GetLogConfig() map[string]*LogCollect
- func (c *Collect) GetPlugin() map[string]*PluginCollect
- func (c *Collect) GetPorts() map[int]*PortCollect
- func (c *Collect) GetProcs() map[string]*ProcCollect
- func (c *Collect) Update(cc *Collect)
type CollectHist
type CollectRule
- func DumpCollectRules() ([]*CollectRule, error)
- func GetCollectRules(typ string, nid int64, limit, offset int) (total int64, list []*CollectRule, err error)
- func (p CollectRule) PluginName() string
- func (p *CollectRule) String() string
- func (p *CollectRule) Update() (err error)
- func (p *CollectRule) Validate(v ...interface{}) error
type CollectRuleRpcResp
type Configs
type Event
- func EventGet(col string, value interface{}) (*Event, error)
- func EventGets(stime, etime int64, nodePath, query, eventType string, ...) ([]Event, error)
- func (e *Event) GetEventDetail() ([]EventDetail, error)
type EventAlertUpgrade
- func EventAlertUpgradeUnMarshal(str string) (EventAlertUpgrade, error)
type EventCur
- func AllEventCurGet() ([]EventCur, error)
- func EventCurGet(col string, value interface{}) (*EventCur, error)
- func EventCurGets(stime, etime int64, nodePath, query string, priorities, sendTypes []string, ...) ([]EventCur, error)
- func (e *EventCur) EventIgnore() error
type EventDetail
type EventDetailPoint
type EventSlice
- func (e EventSlice) Len() int
- func (e EventSlice) Less(i, j int) bool
- func (e EventSlice) Swap(i, j int)
type Exp
type Host
- func HostByIds(ids []int64) (hosts []Host, err error)
- func HostGet(where string, args ...interface{}) (*Host, error)
- func HostGets(where string, args ...interface{}) (hosts []Host, err error)
- func HostGetsForAdmin(tenant, query, batch, field string, limit, offset int) ([]Host, error)
- func HostNew(sn, ip, ident, name, cate string, fields map[string]interface{}) (*Host, error)
- func HostSearch(batch, field string) ([]Host, error)
- func (h *Host) Del() error
- func (h *Host) Save() error
- func (h *Host) Update(fields map[string]interface{}) error
type HostField
- func HostFieldGet(where string, args ...interface{}) (*HostField, error)
- func HostFieldGets() ([]HostField, error)
- func (hf *HostField) Del() error
- func (hf *HostField) Update(cols ...string) error
- func (hf *HostField) Validate() error
type HostFieldValue
- func HostFieldValueGets(hostId int64) ([]HostFieldValue, error)
- func (hfv *HostFieldValue) Validate() error
type HostRegisterForm
- func (f HostRegisterForm) Validate() error
type Index
type Instance
- func GetAllInstances(mod string, alive int) ([]*Instance, error)
- func GetInstanceBy(mod, identity, rpcPort, httpPort string) (*Instance, error)
- func (i *Instance) Add() error
- func (i *Instance) Update() error
type InstancesResp
type Invite
- func InviteGet(where string, args ...interface{}) (*Invite, error)
- func InviteMustGet(where string, args ...interface{}) (*Invite, error)
- func (i *Invite) Del() error
type LDAPSection
type LogCollect
- func GetLogCollects() ([]*LogCollect, error)
- func (l *LogCollect) Decode() error
- func (l *LogCollect) Encode() error
- func (p *LogCollect) Update() error
type LoginCode
- func LoginCodeGet(where string, args ...interface{}) (*LoginCode, error)
- func (p *LoginCode) Del() error
- func (p *LoginCode) Save() error
type LoginLog
- func LoginLogGets(username string, btime, etime int64, limit, offset int) ([]LoginLog, error)
type Lookup
type Maskconf
- func MaskconfGet(col string, value interface{}) (*Maskconf, error)
- func MaskconfGetAll() ([]Maskconf, error)
- func MaskconfGets(nodeId int64) ([]Maskconf, error)
- func (mc *Maskconf) AddEndpoints(endpoints []string) error
- func (mc *Maskconf) AddNids(nidPaths map[string]string) error
- func (mc *Maskconf) FillEndpoints() error
- func (mc *Maskconf) FillNids() error
- func (mc *Maskconf) UpdateEndpoints(endpoints []string, cols ...string) error
- func (mc *Maskconf) UpdateNids(nidPaths map[string]string, cols ...string) error
type MaskconfEndpoints
type MaskconfNids
type Metric
type Mib
- func MibGet(where string, args ...interface{}) (*Mib, error)
- func MibGets(where string, args ...interface{}) ([]Mib, error)
- func MibGetsByQuery(query string, limit, offset int) ([]Mib, error)
- func MibGetsGroupBy(group string, where string, args ...interface{}) ([]Mib, error)
- func NewMib(module string, m *Metric) *Mib
- func (m *Mib) Save() error
type Module
type MySQLConf
type NetworkHardware
- func GetHardwareInfoBy(ips []string) []*NetworkHardware
- func MakeNetworkHardware(ip, cate, version, auth, region, note string) *NetworkHardware
- func NetworkHardwareGet(where string, args ...interface{}) (*NetworkHardware, error)
- func NetworkHardwareList(query string, limit, offset int) ([]NetworkHardware, error)
- func NwGetsForAdmin(tenant, query, batch, field string, limit, offset int) ([]NetworkHardware, error)
- func NwSearch(batch, field string) ([]NetworkHardware, error)
- func (n *NetworkHardware) Del() error
- func (n *NetworkHardware) Update(cols ...string) error
type NetworkHardwareRpcResp
type Node
- func NodeByIds(ids []int64) ([]Node, error)
- func NodeByPaths(paths []string) ([]Node, error)
- func NodeGet(where string, args ...interface{}) (*Node, error)
- func NodeGetById(id int64) (*Node, error)
- func NodeGets(where string, args ...interface{}) (nodes []Node, err error)
- func PermNodes(myNodes []Node) ([]Node, error)
- func TenantsGetByUserId(id int64, withAdmins ...bool) (tenants []Node, err error)
- func TreeUntilProjectsGetByNid(nid int64) ([]Node, error)
- func TreeUntilProjectsGetByUser(user *User) ([]Node, error)
- func TreeUntilTypGetByUser(user *User, typ string) ([]Node, error)
- func UserPermNodes(me *User) ([]Node, error)
- func (n *Node) Bind(resIds []int64) error
- func (n *Node) CreateChild(ident, name, note, cate, creator string, leaf, proxy int, adminIds []int64) (*Node, error)
- func (n *Node) Del() error
- func (n *Node) FillAdmins() error
- func (n *Node) FilterMyChildren(nodes []Node) []Node
- func (n *Node) LeafIds() ([]int64, error)
- func (n *Node) Modify(name, cate, note string, adminIds []int64) error
- func (n *Node) Move(tnode *Node) error
- func (n *Node) RelatedNodes() ([]Node, error)
- func (n *Node) RoleList(username string, limit, offset int) ([]NodeRole, error)
- func (n *Node) RoleTotal(username string) (int64, error)
- func (n *Node) Tenant() string
- func (n *Node) Unbind(resIds []int64) error
type NodeAdmin
type NodeCate
- func NodeCateGet(where string, args ...interface{}) (*NodeCate, error)
- func NodeCateGets() ([]NodeCate, error)
- func (nc *NodeCate) Del() error
- func (nc *NodeCate) Update(cols ...string) error
type NodeCateField
- func NodeCateFieldGet(where string, args ...interface{}) (*NodeCateField, error)
- func NodeCateFieldGets(where string, args ...interface{}) ([]NodeCateField, error)
- func (ncf *NodeCateField) Del() error
- func (ncf *NodeCateField) Update(cols ...string) error
- func (ncf *NodeCateField) Validate() error
type NodeFieldValue
- func NodeFieldValueGets(nodeId int64) ([]NodeFieldValue, error)
- func (nfv *NodeFieldValue) Validate() error
type NodeResource
- func NodeResourceGetAll() ([]*NodeResource, error)
type NodeRole
- func (nr *NodeRole) Save() error
type NodeTrash
- func NodeTrashGetByIds(ids []int64) ([]NodeTrash, error)
- func NodeTrashGets(query string, limit, offset int) ([]NodeTrash, error)
type OperationLog
- func OperationLogGetsByRes(rescl, resid string, btime, etime int64, limit, offset int) ([]OperationLog, error)
- func OperationLogQuery(query string, btime, etime int64, limit, offset int) ([]OperationLog, error)
- func (ol *OperationLog) New() error
type PluginCollect
- func GetPluginCollects() ([]*PluginCollect, error)
- func (p *PluginCollect) Update() error
type PortCollect
- func GetPortCollects() ([]*PortCollect, error)
- func (p *PortCollect) Update() error
type ProcCollect
- func GetProcCollects() ([]*ProcCollect, error)
- func (p *ProcCollect) Update() error
type Regexp
type RegexpExtract
type Resource
- func ResourceGet(where string, args ...interface{}) (*Resource, error)
- func ResourceGets(where string, args ...interface{}) ([]Resource, error)
- func ResourceOrphanList(tenant, query, batch, field string, limit, offset int) ([]Resource, error)
- func ResourceSearch(batch, field string) ([]Resource, error)
- func ResourceUnderNodeGets(leafIds []int64, query, batch, field string, limit, offset int) ([]Resource, error)
- func ResourcesByIdents(idents []string) ([]Resource, error)
- func (r *Resource) Save() error
- func (r *Resource) Update(cols ...string) error
type ResourceBinding
- func ResourceBindings(resIds []int64) ([]ResourceBinding, error)
type ResourceRegisterItem
- func (i ResourceRegisterItem) Validate() error
type Role
- func GlobalRolesGetByUserId(id int64) (roles []Role, err error)
- func RoleFind(cate string) ([]Role, error)
- func RoleGet(where string, args ...interface{}) (*Role, error)
- func RoleGetByIds(ids []int64) (roles []Role, err error)
- func (r *Role) BindUsers(userIds []int64) error
- func (r *Role) CheckFields() error
- func (r *Role) Del() error
- func (r *Role) GlobalUserIds() ([]int64, error)
- func (r *Role) Modify(name, note, cate string, ops []string) error
- func (r *Role) Save(ops []string) error
- func (r *Role) UnbindUsers(ids []int64) error
type RoleGlobalUser
- func RoleGlobalUserAll() ([]RoleGlobalUser, error)
type RoleOperation
- func RoleOperationAll() ([]RoleOperation, error)
type Screen
- func ScreenGet(col string, val interface{}) (*Screen, error)
- func ScreenGets(nodeId int64) ([]Screen, error)
- func (s *Screen) Add() error
- func (s *Screen) Del() error
- func (s *Screen) Update(cols ...string) error
type ScreenSubclass
- func ScreenSubclassGet(col string, val interface{}) (*ScreenSubclass, error)
- func ScreenSubclassGets(screenId int64) ([]ScreenSubclass, error)
- func (s *ScreenSubclass) Add() error
- func (s *ScreenSubclass) Del() error
- func (s *ScreenSubclass) Update(cols ...string) error
type Secret
type Session
- func SessionAndTotalGets(query string, limit, offset int) ([]Session, int64, error)
- func SessionGet(sid string) (*Session, error)
- func SessionGetByToken(token string) (*Session, error)
- func SessionGetWithCache(sid string) (*Session, error)
- func SessionGets(limit, offset int, where string, args ...interface{}) ([]Session, error)
- func TokenGetWithCache(accessToken string) (*Session, error)
- func (s *Session) Save() error
- func (s *Session) Update(cols ...string) error
type SnmpCollect
- func GetSnmpCollects(nid int64) ([]*SnmpCollect, error)
- func (s *SnmpCollect) Decode() error
- func (s *SnmpCollect) Encode() error
- func (s *SnmpCollect) GetByOidAndModule() (*SnmpCollect, error)
- func (s *SnmpCollect) Update() error
type Stats
- func MustNewStats(name string) *Stats
- func NewStats(name string) (*Stats, error)
- func (p *Stats) Del() error
- func (p *Stats) Get() int64
- func (p *Stats) Inc(i int) error
- func (p *Stats) Save() error
- func (p *Stats) Update(i int64) error
type Stra
- func EffectiveStrasList() ([]*Stra, error)
- func StraFindOne(where string, args ...interface{}) (*Stra, error)
- func StraGet(col string, val interface{}) (*Stra, error)
- func StrasAll() ([]*Stra, error)
- func StrasList(name string, priority int, nid int64) ([]*Stra, error)
- func (s *Stra) Decode() error
- func (s *Stra) Encode() error
- func (s *Stra) GetMetric() string
- func (s *Stra) HasPermssion() error
- func (s *Stra) Save() error
- func (s *Stra) Update() error
type StraLog
type Tag
type TaskAction
- func TaskActionGet(where string, args ...interface{}) (*TaskAction, error)
- func (a *TaskAction) Update(action string) error
type TaskHost
- func TaskHostGet(id int64, host string) (*TaskHost, error)
- func TaskHostGets(id int64) ([]TaskHost, error)
- func TaskHostStatus(id int64) ([]TaskHost, error)
- func WaitingHostList(id int64, limit ...int) ([]TaskHost, error)
type TaskHostDoing
- func DoingHostList(where string, args ...interface{}) ([]TaskHostDoing, error)
- func GetDoingCache(k string) []TaskHostDoing
type TaskMeta
- func TaskMetaGet(where string, args ...interface{}) (*TaskMeta, error)
- func TaskMetaGetByID(id interface{}) (*TaskMeta, error)
- func TaskMetaGets(creator, query string, before time.Time, limit, offset int) ([]TaskMeta, error)
- func (m *TaskMeta) Action() (*TaskAction, error)
- func (m *TaskMeta) CleanFields() error
- func (m *TaskMeta) HandleFH(fh string)
- func (m *TaskMeta) HostStrs() ([]string, error)
- func (m *TaskMeta) Hosts() ([]TaskHost, error)
- func (m *TaskMeta) IgnoreHost(host string) error
- func (m *TaskMeta) KillHost(host string) error
- func (m *TaskMeta) RedoHost(host string) error
- func (m *TaskMeta) Save(hosts []string, action string) error
- func (m *TaskMeta) Stderrs() ([]TaskHost, error)
- func (m *TaskMeta) Stdouts() ([]TaskHost, error)
type TaskScheduler
type TaskSchedulerHealth
type TaskTpl
- func TaskTplGet(where string, args ...interface{}) (*TaskTpl, error)
- func TaskTplGets(nodeId int64, query string, limit, offset int) ([]TaskTpl, error)
- func (t *TaskTpl) BindTags(tags []string) error
- func (t *TaskTpl) CleanFields() error
- func (t *TaskTpl) Del() error
- func (t *TaskTpl) Hosts() ([]string, error)
- func (t *TaskTpl) Save(hosts []string) error
- func (t *TaskTpl) UnbindTags(tags []string) error
- func (t *TaskTpl) Update(hosts []string) error
- func (t *TaskTpl) UpdateGroup(nodeId int64) error
type Team
- func AllTeams() ([]Team, error)
- func TeamGet(where string, args ...interface{}) (*Team, error)
- func TeamGetByIds(ids []int64) ([]Team, error)
- func TeamGets(query string, limit, offset int) ([]Team, error)
- func TeamGetsInIds(ids []int64, query string, limit, offset int) ([]Team, error)
- func (t *Team) BindUser(ids []int64, isadmin int) error
- func (t *Team) CheckFields() error
- func (t *Team) Del() error
- func (t *Team) Modify(name, note string, mgmt int) error
- func (t *Team) UnbindUser(ids []int64) error
- func (t *Team) Update(cols ...string) error
- func (t *Team) UsersGet(query string, limit, offset int) ([]TeamMember, error)
- func (t *Team) UsersTotal(query string) (int64, error)
type TeamMember
type TeamUser
- func TeamUsers() ([]TeamUser, error)
type TmpChart
- func TmpChartGet(col string, val interface{}) (*TmpChart, error)
- func (t *TmpChart) Add() error
type Token
- func TokenGet(token string) (*Token, error)
- func TokenGets(where string, args ...interface{}) (tokens []Token, err error)
- func (p *Token) Session() *Session
- func (p *Token) Update(cols ...string) error
type User
- func AllUsers() ([]User, error)
- func EmailCodeLogin(email, code string) (*User, error)
- func LdapLogin(username, pass string) (*User, error)
- func PassLogin(username, pass string) (*User, error)
- func SessionGetUserWithCache(sid string) (*User, error)
- func SmsCodeLogin(phone, code string) (*User, error)
- func TeamMembers(tid int64, isAdmin int) ([]User, error)
- func UserAndTotalGets(query, org string, conditions string, limit, offset int, ids []int64) ([]User, int64, error)
- func UserGet(where string, args ...interface{}) (*User, error)
- func UserGetByIds(ids []int64) ([]User, error)
- func UserGetByNames(names []string) ([]User, error)
- func UserGetByUUIDs(uuids []string) ([]User, error)
- func UserGets(ids []int64, limit, offset int, where string, args ...interface{}) ([]User, error)
- func UserGetsByIds(ids []int64) ([]User, error)
- func UserMustGet(where string, args ...interface{}) (*User, error)
- func UserSearchListInIds(ids []int64, query string, limit, offset int) ([]User, error)
- func UsersGet(where string, args ...interface{}) ([]User, error)
- func UsersGetByGlobalRoleIds(ids []int64) (users []User, err error)
- func (u *User) CanModifyTeam(t *Team) (bool, error)
- func (u *User) CheckPermByNode(node *Node, operation string)
- func (u *User) CheckPermGlobal(operation string)
- func (u *User) CopyLdapAttr(sr *ldap.SearchResult)
- func (u *User) Del() error
- func (u *User) HasPermByNode(node *Node, operation string) (bool, error)
- func (u *User) HasPermGlobal(operation string) (bool, error)
- func (u *User) IsRooter() bool
- func (u *User) NopriResIdents(resIds []int64, op string) ([]string, error)
- func (u *User) PermByNode(node *Node, localOpsList []string) ([]string, error)
- func (u *User) PermResIds(operation string) ([]int64, error)
- func (u *User) Save() error
- func (u *User) Update(cols ...string) error
- func (u *User) Validate() error
type UserToken
- func UserTokenGet(where string, args ...interface{}) (*UserToken, error)
- func UserTokenGets(where string, args ...interface{}) ([]UserToken, error)
- func UserTokenNew(userId int64, username string) (*UserToken, error)
- func UserTokenReset(userId int64, token string) (*UserToken, error)
type WalkParams
type WhiteList
- func WhiteListGet(where string, args ...interface{}) (*WhiteList, error)
- func WhiteListGets(query string, limit, offset int) ([]WhiteList, error)
- func (p *WhiteList) Del() error
- func (p *WhiteList) Save() error
- func (p *WhiteList) Update(cols ...string) error
- func (p *WhiteList) Validate() error

Constants ¶

View Source

const (
	FLAG_SEND = iota
	FLAG_CALLBACK
	FLAG_MASK
	FLAG_CONVERGE
	FLAG_NONEUSER
	FLAG_UPGRADE
)

0 0 0 0 0 0 处理中 0 0 0 0 x 1 已发送 0 0 0 0 1 x 已回调 0 0 0 1 0 0 已屏蔽 0 0 1 0 0 0 被收敛 0 1 0 0 x 0 无接收人 1 0 0 0 x 0 升级发送

View Source

const (
	STATUS_DOING    = "doing"     // 处理中
	STATUS_SEND     = "send"      // 已发送
	STATUS_NONEUSER = "none-user" // 无接收人
	STATUS_CALLBACK = "callback"  // 已回调
	STATUS_MASK     = "mask"      // 已屏蔽
	STATUS_CONVERGE = "converge"  // 频率限制
	STATUS_UPGRADE  = "upgrade"   // 升级报警
)

View Source

const (
	PWD_INCLUDE_UPPER = 1 << iota
	PWD_INCLUDE_LOWER
	PWD_INCLUDE_NUMBER
	PWD_INCLUDE_SPEC_CHAR
)

View Source

const (
	LOGIN_T_SMS      = "sms-code"
	LOGIN_T_EMAIL    = "email-code"
	LOGIN_T_PWD      = "password"
	LOGIN_T_LDAP     = "ldap"
	LOGIN_T_RST      = "rst-code"
	LOGIN_T_LOGIN    = "login-code"
	LOGIN_EXPIRES_IN = 300
)

View Source

const (
	USER_S_ACTIVE = iota
	USER_S_INACTIVE
	USER_S_LOCKED
	USER_S_FROZEN
	USER_S_WRITEN_OFF
)

View Source

const (
	USER_T_NATIVE = iota
	USER_T_TEMP
)

View Source

const ALERT = "alert"

View Source

const InnerTenantIdent = "inner"

View Source

const RECOVERY = "recovery"

Variables ¶

View Source

var DB = map[string]*xorm.Engine{}

View Source

var DefaultAuthConfig = AuthConfig{
	MaxConnIdleTime: 30,
	PwdMustInclude:  []string{},
}

View Source

var (
	EventTypeMap = map[string]string{RECOVERY: "恢复", ALERT: "报警"}
)

View Source

var MathOperators = map[string]bool{
	">":  true,
	"<":  true,
	">=": true,
	"<=": true,
	"!=": true,
	"=":  true,
}

Functions ¶

func AggrCalcDel ¶

func AggrCalcDel(id int64) error

func AlertUpgradeMarshal ¶

func AlertUpgradeMarshal(alterUpgrade AlertUpgrade) (string, error)

func AuthConfigSet ¶

func AuthConfigSet(config *AuthConfig) error

func CancelTask ¶

func CancelTask(id int64) error

func CancelWaitingHosts ¶

func CancelWaitingHosts(id int64) error

func CleanDoneTask ¶

func CleanDoneTask(id int64) error

func CleanExpireMask ¶

func CleanExpireMask(now 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 CreateCollect ¶

func CreateCollect(collectType, creator string, collect interface{}, dryRun bool) (err error)

func CryptoPass ¶

func CryptoPass(raw string) (string, error)

CryptoPass crypto password use salt

func DeadTaskSchedulers ¶

func DeadTaskSchedulers() ([]string, error)

func DelById ¶

func DelById(id int64) error

func DelDeadTaskScheduler ¶

func DelDeadTaskScheduler(scheduler string) error

func DelEventCurOlder ¶

func DelEventCurOlder(ts int64, batch int) error

func DelEventOlder ¶

func DelEventOlder(ts int64, batch int) error

func DeleteCollectById ¶

func DeleteCollectById(collectType, creator string, cid int64) error

func DeleteCollectRule ¶

func DeleteCollectRule(sid int64) error

func DoingHostCount ¶

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

func EventAlertUpgradeMarshal ¶

func EventAlertUpgradeMarshal(alertUpgrade AlertUpgrade) (string, error)

func EventCnt ¶

func EventCnt(hashid uint64, stime, etime int64, isUpgrade bool) (int64, error)

func EventCurDel ¶

func EventCurDel(hashid uint64) error

func EventCurDelById ¶

func EventCurDelById(id interface{}) error

func EventCurTotal ¶

func EventCurTotal(stime, etime int64, nodePath, query string, priorities, sendTypes []string) (int64, error)

func EventDelById ¶

func EventDelById(id interface{}) error

func EventTotal ¶

func EventTotal(stime, etime int64, nodePath, query, eventType string, priorities, sendTypes []string) (int64, error)

func GenUUIDForUser ¶

func GenUUIDForUser(username string) string

func GetFlagsByStatus ¶

func GetFlagsByStatus(ss []string) []uint16

func GetRelatedNidsForMon ¶

func GetRelatedNidsForMon(nid int64, exclNid []int64) ([]int64, error)

func GetStatus ¶

func GetStatus(status string) int

func GetStatusByFlag ¶

func GetStatusByFlag(flag uint16) []string

func GetTeamsNameByIds ¶

func GetTeamsNameByIds(ids string) ([]string, error)

func GetUsernameByToken ¶

func GetUsernameByToken(token string) (string, error)

GetUsernameByToken 使用方：rbac-proxy

func HostFieldNew ¶

func HostFieldNew(objPtr *HostField) error

func HostFieldValuePuts ¶

func HostFieldValuePuts(hostId int64, objs []HostFieldValue) error

func HostIdsByIps ¶

func HostIdsByIps(ips []string) (ids []int64, err error)

func HostRegister ¶

func HostRegister(f HostRegisterForm) error

func HostTotalForAdmin ¶

func HostTotalForAdmin(tenant, query, batch, field string) (int64, error)

func HostUpdateCate ¶

func HostUpdateCate(ids []int64, cate string) error

func HostUpdateNote ¶

func HostUpdateNote(ids []int64, note string) error

func HostUpdateTenant ¶

func HostUpdateTenant(ids []int64, tenant string) error

func IngStatusHostCount ¶

func IngStatusHostCount(id int64) (int64, error)

func InitLDAP ¶

func InitLDAP(conf LDAPSection)

func InitMySQL ¶

func InitMySQL(names ...string)

func InitRooter ¶

func InitRooter()

func InitSalt ¶

func InitSalt()

InitSalt generate random salt

func InviteNew ¶

func InviteNew(token, creator string) error

func KillTask ¶

func KillTask(id int64) error

func LeafIdsByNodes ¶

func LeafIdsByNodes(nodes []Node) ([]int64, error)

根据一堆节点获取下面的叶子节点的ID列表

func LoginLogNew ¶

func LoginLogNew(username, client, inout string, err error) error

func LoginLogTotal ¶

func LoginLogTotal(username string, btime, etime int64) (int64, error)

func LongTaskIds ¶

func LongTaskIds() ([]int64, error)

LongTaskIds two weeks ago

func MapKeyClear ¶

func MapKeyClear(src map[string]interface{}, save map[string]struct{})

mapKeyClear map key clear

func MarkDoneStatus ¶

func MarkDoneStatus(id, clock int64, host, status, stdout, stderr string) error

func MaskconfDel ¶

func MaskconfDel(id int64) error

func MibDel ¶

func MibDel(id int64) error

func MibTotal ¶

func MibTotal(query string) (int64, error)

func NetworkHardwareCount ¶

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

func NetworkHardwareDel ¶

func NetworkHardwareDel(id int64) error

func NetworkHardwareNew ¶

func NetworkHardwareNew(objPtr *NetworkHardware) error

func NetworkHardwareResourceRegister ¶

func NetworkHardwareResourceRegister(hws []*NetworkHardware, tenant string) error

ResourceRegister 资源分配给某个租户的时候调用

func NetworkHardwareTotal ¶

func NetworkHardwareTotal(query string) (int64, error)

func NodeAdminExists ¶

func NodeAdminExists(session *xorm.Session, nodeId, userId int64) (bool, error)

func NodeAdminNew ¶

func NodeAdminNew(session *xorm.Session, nodeId, userId int64) error

func NodeCateFieldNew ¶

func NodeCateFieldNew(objPtr *NodeCateField) error

func NodeCateNew ¶

func NodeCateNew(objPtr *NodeCate) error

func NodeClearAdmins ¶

func NodeClearAdmins(session *xorm.Session, nodeId int64) error

func NodeFieldValuePuts ¶

func NodeFieldValuePuts(nodeId int64, objs []NodeFieldValue) error

func NodeIdsBindingUsername ¶

func NodeIdsBindingUsername(username string) ([]int64, error)

NodeIdsBindingUsername 某人在哪些节点配置过权限

func NodeIdsBindingUsernameWithOp ¶

func NodeIdsBindingUsernameWithOp(username, op string) ([]int64, error)

NodeIdsBindingUsernameWithOp 我在哪些节点上有这个操作权限

func NodeIdsBindingUsernameWithRoles ¶

func NodeIdsBindingUsernameWithRoles(username string, roleIds []int64) ([]int64, error)

NodeIdsBindingUsernameWithRoles 我以某些角色的名义绑定在哪些节点

func NodeIdsByPaths ¶

func NodeIdsByPaths(paths []string) ([]int64, error)

func NodeIdsGetByResIds ¶

func NodeIdsGetByResIds(rids []int64) ([]int64, error)

func NodeIdsIamAdmin ¶

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

NodeIdsIamAdmin 我是管理员的节点ID列表

func NodeNew ¶

func NodeNew(objPtr *Node, adminIds []int64) error

func NodeResourceBind ¶

func NodeResourceBind(nid, rid int64) error

func NodeResourceUnbind ¶

func NodeResourceUnbind(nid, rid int64) error

func NodeResourceUnbindByRids ¶

func NodeResourceUnbindByRids(rids []int64) error

func NodeRoleDel ¶

func NodeRoleDel(nodeId, roleId int64, username string) error

func NodeRoleExists ¶

func NodeRoleExists(nodeIds, roleIds []int64, username string) (bool, error)

func NodeTrashRecycle ¶

func NodeTrashRecycle(ids []int64) error

从node_trash表回收部分node，前端一个一个操作，也可以同一层级同时操作之前的父节点可能已经挪动过，所以回收的时候要注意重新更新path信息

func NodeTrashTotal ¶

func NodeTrashTotal(query string) (int64, error)

func NodesAdminExists ¶

func NodesAdminExists(nodeIds []int64, userId int64) (bool, error)

func NwTotalForAdmin ¶

func NwTotalForAdmin(tenant, query, batch, field string) (int64, error)

func OperationLogNew ¶

func OperationLogNew(username, rescl string, resid interface{}, detail string) error

func OperationLogTotal ¶

func OperationLogTotal(query string, btime, etime int64) (int64, error)

func OperationLogTotalByRes ¶

func OperationLogTotalByRes(rescl, resid string, btime, etime int64) (int64, error)

func OperationsOfRoles ¶

func OperationsOfRoles(rids []int64) ([]string, error)

func OrphanTaskIds ¶

func OrphanTaskIds() ([]int64, error)

func ParseEtime ¶

func ParseEtime(etime int64) string

func Paths ¶

func Paths(longPath string) []string

Paths 把长路径切成多个path，比如： cop.sre.falcon.judge.hna被切成： cop、cop.sre、cop.sre.falcon、cop.sre.falcon.judge、cop.sre.falcon.judge.hna

func ReportHeartBeat ¶

func ReportHeartBeat(rev Instance) error

func ResCountGetByNodeIdsAndCate ¶

func ResCountGetByNodeIdsAndCate(nids []int64, cate string) (int, error)

ResCountGetByNodeIdsAndWhere 根据叶子节点和Where条件获取资源数量表

func ResIdsGetByNodeIds ¶

func ResIdsGetByNodeIds(nids []int64) ([]int64, error)

ResIdsGetByNodeIds 根据叶子节点获取资源ID列表

func ResourceBindingsForMon ¶

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

ResourceBindingsForMon 告警消息里要看到资源挂载的节点信息

func ResourceIdentsByIds ¶

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

func ResourceIdsByIdents ¶

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

func ResourceIdsByUUIDs ¶

func ResourceIdsByUUIDs(uuids []string) ([]int64, error)

func ResourceOrphanTotal ¶

func ResourceOrphanTotal(tenant, query, batch, field string) (int64, error)

func ResourceRegister ¶

func ResourceRegister(hosts []Host, tenant string) error

ResourceRegister 资源分配给某个租户的时候调用

func ResourceRegisterFor3rd ¶

func ResourceRegisterFor3rd(item ResourceRegisterItem) (errCode int, err error)

ResourceRegisterFor3rd 用于第三方资源注册 errCode=400: 表示传入的参数有问题 errCode=500: 表示DB出了问题之所以要通过errCode对错误做区分，是因为这个方法同时被同步和异步两种方式调用，上层需要依托这个信息做判断

func ResourceUnderNodeTotal ¶

func ResourceUnderNodeTotal(leafIds []int64, query, batch, field string) (int64, error)

func ResourceUnregister ¶

func ResourceUnregister(uuids []string) error

func RoleBiggerThan ¶

func RoleBiggerThan(roleid int64) ([]int64, error)

func RoleIdsBindingUsername ¶

func RoleIdsBindingUsername(username string, nids []int64) ([]int64, error)

func RoleIdsGetByUserId ¶

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

func RoleIdsHasOp ¶

func RoleIdsHasOp(op string) ([]int64, error)

RoleIdsHasOp 看哪些role里边包含operation

func RoleMap ¶

func RoleMap(cate string) (map[int64]string, error)

RoleMap key: role_id, value: role_name

func RunWaitingHosts ¶

func RunWaitingHosts(hosts []TaskHost) error

func SaveEvent ¶

func SaveEvent(event *Event) error

func SaveEventCur ¶

func SaveEventCur(eventCur *EventCur) error

func SaveEventCurStatus ¶

func SaveEventCurStatus(hashid uint64, status string) error

func SaveEventStatus ¶

func SaveEventStatus(id int64, status string) error

func SaveStraCommit ¶

func SaveStraCommit(id int64, action, username, body string, session *xorm.Session) error

func SessionAll ¶

func SessionAll() (int64, error)

func SessionCleanupByCreatedAt ¶

func SessionCleanupByCreatedAt(ts int64) error

func SessionCleanupByUpdatedAt ¶

func SessionCleanupByUpdatedAt(ts int64) error

func SessionDelete ¶

func SessionDelete(sid string) error

func SessionTotal ¶

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

func SessionUpdate ¶

func SessionUpdate(in *Session) error

func SessionUserAll ¶

func SessionUserAll(username string) (int64, error)

func SetDoingCache ¶

func SetDoingCache(v map[string][]TaskHostDoing)

func StartTask ¶

func StartTask(id int64) error

func StatusConvert ¶

func StatusConvert(s []string) []string

func StraDel ¶

func StraDel(id int64) error

func StraDelByNid ¶

func StraDelByNid(nid int64) error

func TakeOverTask ¶

func TakeOverTask(id int64, pre, current string) (bool, error)

func TaskActionExistsIds ¶

func TaskActionExistsIds(ids []int64) ([]int64, error)

func TaskMetaTotal ¶

func TaskMetaTotal(creator, query string, before time.Time) (int64, error)

func TaskSchedulerHeartbeat ¶

func TaskSchedulerHeartbeat(endpoint string) error

func TaskTplTotal ¶

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

func TasksOfScheduler ¶

func TasksOfScheduler(scheduler string) ([]int64, error)

func TeamAdd ¶

func TeamAdd(ident, name, note string, mgmt int, creator int64) (int64, error)

func TeamHasMember ¶

func TeamHasMember(tid, uid int64, isAdmin ...int) (bool, error)

func TeamIdentByIds ¶

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

func TeamIdsByUserId ¶

func TeamIdsByUserId(uid int64, isAdmin ...int) ([]int64, error)

func TeamTotal ¶

func TeamTotal(query string) (int64, error)

func TeamTotalInIds ¶

func TeamTotalInIds(ids []int64, query string) (int64, error)

func TokenAll ¶

func TokenAll() (int64, error)

func TokenDelete ¶

func TokenDelete(token string) error

func UnexpectedHostCount ¶

func UnexpectedHostCount(id int64) (int64, error)

func UpdateClaimantsById ¶

func UpdateClaimantsById(userId, id int64) error

func UpdateClaimantsByNodePath ¶

func UpdateClaimantsByNodePath(userId int64, nodePath string) error

func UpdateEventCurPriority ¶

func UpdateEventCurPriority(hashid uint64, priority int) error

func UpdateEventPriority ¶

func UpdateEventPriority(id int64, priority int) error

func UpdateIconColor ¶

func UpdateIconColor(newColor, cate string) error

func UserFillUUIDs ¶

func UserFillUUIDs() error

func UserHasGlobalRole ¶

func UserHasGlobalRole(userId int64, roleIds []int64) (bool, error)

UserHasGlobalRole 查看某个用户是否有某个全局角色

func UserIdsByTeamIds ¶

func UserIdsByTeamIds(tids []int64, isAdmin ...int) ([]int64, error)

func UserIdsGetByRoleIds ¶

func UserIdsGetByRoleIds(roleIds []int64) ([]int64, error)

func UserSearchTotalInIds ¶

func UserSearchTotalInIds(ids []int64, query string) (int64, error)

func UserTotal ¶

func UserTotal(ids []int64, where string, args ...interface{}) (int64, error)

func UsernameByUUID ¶

func UsernameByUUID(uuid string) string

Deprecated

func UsernameCandoGlobalOp ¶

func UsernameCandoGlobalOp(username, operation string) (bool, error)

UsernameCandoGlobalOp 使用方：RDB、rbac-proxy

func UsernameCandoNodeOp ¶

func UsernameCandoNodeOp(username, operation string, nodeId int64) (bool, error)

func WaitingHostCount ¶

func WaitingHostCount(id int64) (int64, error)

func WarningStr ¶

func WarningStr(s string) bool

func WhiteListAccess ¶

func WhiteListAccess(addr string) error

func WhiteListTotal ¶

func WhiteListTotal(query string) (int64, error)

Types ¶

type AggrCalc ¶

type AggrCalc struct {
	Id               int64     `xorm:"id pk autoincr" json:"id"`
	Nid              int64     `xorm:"nid" json:"nid"`
	Category         int       `xorm:"category" json:"category"`
	NewMetric        string    `xorm:"new_metric" json:"new_metric"`
	NewStep          int       `xorm:"new_step" json:"new_step"`
	GroupByString    string    `xorm:"groupby" json:"-"`
	RawMetricsString string    `xorm:"raw_metrics" json:"-"`
	GlobalOperator   string    `xorm:"global_operator"json:"global_operator"` //指标聚合方式
	Expression       string    `xorm:"expression" json:"expression"`
	RPN              string    `xorm:"rpn" json:"rpn"`     //用途？
	Status           int       `xorm:"status" json:"-"`    //审核状态
	Quota            int       `xorm:"quota" json:"quota"` //用途？
	Comment          string    `xorm:"comment" json:"comment"`
	Creator          string    `xorm:"creator" json:"creator"`
	Created          time.Time `xorm:"created" json:"created"`
	LastUpdator      string    `xorm:"last_updator" json:"last_updator"`
	LastUpdated      time.Time `xorm:"<-" json:"last_updated"`

	RawMetrics []*dataobj.RawMetric `xorm:"-" json:"raw_metrics"`
	GroupBy    []string             `xorm:"-" json:"groupby"`
	VarNum     int                  `xorm:"-" json:"var_num"`
}

func AggrCalcGet ¶

func AggrCalcGet(where string, args ...interface{}) (*AggrCalc, error)

func AggrCalcsList ¶

func AggrCalcsList(name string, nid int64) ([]*AggrCalc, error)

func (*AggrCalc) Decode ¶

func (a *AggrCalc) Decode() error

func (*AggrCalc) Encode ¶

func (a *AggrCalc) Encode() error

func (*AggrCalc) Save ¶

func (a *AggrCalc) Save() error

func (*AggrCalc) Update ¶

func (a *AggrCalc) Update(cols ...string) error

type AggrTagsFilter ¶

type AggrTagsFilter struct {
	TagK string   `json:"tagk"`
	Opt  string   `json:"opt"`
	TagV []string `json:"tagv"`
}

type AlertUpgrade ¶

type AlertUpgrade struct {
	Users    []int64 `json:"users"`
	Groups   []int64 `json:"groups"`
	Duration int     `json:"duration"`
	Level    int     `json:"level"`
}

func AlertUpgradeUnMarshal ¶

func AlertUpgradeUnMarshal(str string) (AlertUpgrade, error)

type ApiCollect ¶

type ApiCollect struct {
	Id               int64     `json:"id"`
	Nid              int64     `json:"nid"`
	CollectType      string    `json:"collect_type"`
	Name             string    `json:"name"`
	Domain           string    `json:"domain"`
	Path             string    `json:"path"`
	HeaderStr        string    `xorm:"header" json:"-"`
	Step             int       `json:"step"`
	Timeout          int       `json:"timeout"`
	Protocol         string    `json:"protocol"`
	PortStr          string    `xorm:"port" json:"-"`
	Method           string    `json:"method"`
	MaxRedirect      int       `json:"max_redirect"`
	PostBody         string    `json:"post_body"`
	ExpectedCodeStr  string    `xorm:"expected_code" json:"-"`
	ExpectedString   string    `json:"expected_string"`
	UnexpectedString string    `json:"unexpected_string"`
	Region           string    `json:"region"`
	Comment          string    `json:"comment"`
	LastUpdator      string    `xorm:"last_updator" json:"last_updator"`
	LastUpdated      time.Time `xorm:"updated" json:"last_updated"`
	Creator          string    `json:"creator"`
	Created          time.Time `xorm:"updated" json:"created"`

	Header       map[string]string `xorm:"-" json:"header"`
	ExpectedCode []string          `xorm:"-" json:"expected_code"`
	Port         int               `xorm:"-" json:"port"`
}

func GetApiCollects ¶

func GetApiCollects() ([]*ApiCollect, error)

func (*ApiCollect) Decode ¶

func (a *ApiCollect) Decode() error

func (*ApiCollect) Encode ¶

func (a *ApiCollect) Encode() error

func (*ApiCollect) Update ¶

func (a *ApiCollect) Update() error

type ApiCollectRpcResp ¶

type ApiCollectRpcResp struct {
	Data []*ApiCollect
	Msg  string
}

type Auth ¶

type Auth struct {
	Community     Secret `json:"community,omitempty"`
	SecurityLevel string `json:"security_level,omitempty"`
	Username      string `json:"username,omitempty"`
	Password      Secret `json:"password,omitempty"`
	AuthProtocol  string `json:"auth_protocol,omitempty"`
	PrivProtocol  string `json:"priv_protocol,omitempty"`
	PrivPassword  Secret `json:"priv_password,omitempty"`
	ContextName   string `json:"context_name,omitempty"`
}

type AuthConfig ¶

type AuthConfig struct {
	MaxNumErr          int      `json:"maxNumErr"`
	MaxSessionNumber   int64    `json:"maxSessionNumber"`
	MaxConnIdleTime    int64    `json:"maxConnIdleTime" description:"minute"`
	LockTime           int64    `json:"lockTime" description:"minute"`
	PwdHistorySize     int      `json:"pwdHistorySize"`
	PwdMinLenght       int      `json:"pwdMinLenght"`
	PwdExpiresIn       int64    `json:"pwdExpiresIn" description:"month"`
	PwdMustInclude     []string `json:"pwdMustInclude" description:"upper,lower,number,specChar"`
	PwdMustIncludeFlag int      `json:"pwdMustIncludeFlag"`
}

func AuthConfigGet ¶

func AuthConfigGet() (*AuthConfig, error)

func (AuthConfig) MustInclude ¶

func (p AuthConfig) MustInclude() string

func (AuthConfig) PwdRules ¶

func (p AuthConfig) PwdRules() []string

func (*AuthConfig) Validate ¶

func (p *AuthConfig) Validate() error

type AuthState ¶

type AuthState struct {
	State     string `json:"state"`
	Typ       string `json:"typ"`
	Redirect  string `json:"redirect"`
	ExpiresAt int64  `json:"expiresAt"`
}

func AuthStateGet ¶

func AuthStateGet(where string, args ...interface{}) (*AuthState, error)

func (AuthState) CleanUp ¶

func (p AuthState) CleanUp() error

func (*AuthState) Del ¶

func (p *AuthState) Del() error

func (*AuthState) Save ¶

func (p *AuthState) Save() error

type Captcha ¶

type Captcha struct {
	CaptchaId string `json:"captchaId"`
	Answer    string `json:"-"`
	Image     string `xorm:"-" json:"image"`
	CreatedAt int64  `json:"createdAt"`
}

func CaptchaGet ¶

func CaptchaGet(where string, args ...interface{}) (*Captcha, error)

func (Captcha) CleanUp ¶

func (p Captcha) CleanUp() error

func (*Captcha) Del ¶

func (p *Captcha) Del() error

func (*Captcha) Save ¶

func (p *Captcha) Save() error

type Chart ¶

type Chart struct {
	Id         int64  `json:"id"`
	SubclassId int64  `json:"subclass_id"`
	Configs    string `json:"configs"`
	Weight     int    `json:"weight"`
}

func ChartGet ¶

func ChartGet(col string, val interface{}) (*Chart, error)

func ChartGets ¶

func ChartGets(subclassId int64) ([]Chart, error)

func (*Chart) Add ¶

func (c *Chart) Add() error

func (*Chart) Del ¶

func (c *Chart) Del() error

func (*Chart) Update ¶

func (c *Chart) Update(cols ...string) error

type Collect ¶

type Collect struct {
	sync.RWMutex
	Ports   map[int]*PortCollect      `json:"ports"`
	Procs   map[string]*ProcCollect   `json:"procs"`
	Logs    map[string]*LogCollect    `json:"logs"`
	Plugins map[string]*PluginCollect `json:"plugins"`
}

func NewCollect ¶

func NewCollect() *Collect

func (*Collect) GetLogConfig ¶

func (c *Collect) GetLogConfig() map[string]*LogCollect

func (*Collect) GetPlugin ¶

func (c *Collect) GetPlugin() map[string]*PluginCollect

func (*Collect) GetPorts ¶

func (c *Collect) GetPorts() map[int]*PortCollect

func (*Collect) GetProcs ¶

func (c *Collect) GetProcs() map[string]*ProcCollect

func (*Collect) Update ¶

func (c *Collect) Update(cc *Collect)

type CollectHist ¶

type CollectHist struct {
	Id          int64     `json:"id"`
	Cid         int64     `json:"cid"`
	CollectType string    `json:"collect_type"`
	Action      string    `json:"action"`
	Body        string    `json:"body"`
	Creator     string    `json:"creator"`
	Created     time.Time `xorm:"created" json:"created"`
}

type CollectRule ¶

type CollectRule struct {
	Id          int64           `json:"id"`
	Nid         int64           `json:"nid"`
	Step        int64           `json:"step" description:"interval"`
	Timeout     int             `json:"timeout"`
	CollectType string          `json:"collect_type" description:"plugin name"`
	Name        string          `json:"name" describes:"customize name"`
	Region      string          `json:"region"`
	Comment     string          `json:"comment"`
	DryRun      bool            `json:"dryrun" xorm:"-"`
	Data        json.RawMessage `json:"data"`
	Tags        string          `json:"tags" description:"k1=v1,k2=v2,k3=v3,..."`
	Creator     string          `json:"creator" description:"just for output"`
	Updater     string          `json:"updater" description:"just for output"`
	CreatedAt   int64           `json:"created_at" description:"just for output"`
	UpdatedAt   int64           `json:"updated_at" description:"just for output"`
}

func DumpCollectRules ¶

func DumpCollectRules() ([]*CollectRule, error)

func GetCollectRules ¶

func GetCollectRules(typ string, nid int64, limit, offset int) (total int64, list []*CollectRule, err error)

func (CollectRule) PluginName ¶

func (p CollectRule) PluginName() string

func (*CollectRule) String ¶

func (p *CollectRule) String() string

func (*CollectRule) Update ¶

func (p *CollectRule) Update() (err error)

func (*CollectRule) Validate ¶

func (p *CollectRule) Validate(v ...interface{}) error

type CollectRuleRpcResp ¶

type CollectRuleRpcResp struct {
	Data []*CollectRule
	Msg  string
}

type Configs ¶

type Configs struct {
	Id   int64
	Ckey string
	Cval string
}

type Event ¶

type Event struct {
	Id           int64     `json:"id"`
	Sid          int64     `json:"sid"`
	Sname        string    `json:"sname"`
	Nid          int64     `json:"nid"`
	NodePath     string    `json:"node_path"`
	CurNodePath  string    `json:"cur_node_path"`
	Endpoint     string    `json:"endpoint"`
	Priority     int       `json:"priority"`
	EventType    string    `json:"event_type"` // alert|recovery
	Category     int       `json:"category"`
	Status       uint16    `json:"status"`
	HashId       uint64    `json:"hashid"  xorm:"hashid"`
	Etime        int64     `json:"etime"`
	Value        string    `json:"value"`
	Info         string    `json:"info"`
	Created      time.Time `json:"created" xorm:"created"`
	Detail       string    `json:"detail"`
	Users        string    `json:"users"`
	Groups       string    `json:"groups"`
	Runbook      string    `json:"runbook"`
	NeedUpgrade  int       `json:"need_upgrade"`
	AlertUpgrade string    `json:"alert_upgrade"`
	RecvUserIDs  []int64   `json:"recv_user_ids" xorm:"-"`
	RealUpgrade  bool      `json:"real_upgrade" xorm:"-"`
	WorkGroups   []int     `json:"work_groups" xorm:"-"`
	CurNid       string    `json:"cur_nid"`
}

func EventGet ¶

func EventGet(col string, value interface{}) (*Event, error)

func EventGets ¶

func EventGets(stime, etime int64, nodePath, query, eventType string, priorities, sendTypes []string, limit, offset int) ([]Event, error)

func (*Event) GetEventDetail ¶

func (e *Event) GetEventDetail() ([]EventDetail, error)

type EventAlertUpgrade ¶

type EventAlertUpgrade struct {
	Users    string `json:"users"`
	Groups   string `json:"groups"`
	Duration int    `json:"duration"`
	Level    int    `json:"level"`
}

func EventAlertUpgradeUnMarshal ¶

func EventAlertUpgradeUnMarshal(str string) (EventAlertUpgrade, error)

type EventCur ¶

type EventCur struct {
	Id           int64     `json:"id"`
	Sid          int64     `json:"sid"`
	Sname        string    `json:"sname"`
	NodePath     string    `json:"node_path"`
	CurNodePath  string    `json:"cur_node_path"`
	Endpoint     string    `json:"endpoint"`
	Priority     int       `json:"priority"`
	EventType    string    `json:"event_type"` // alert|recovery
	Category     int       `json:"category"`
	Status       uint16    `json:"status"`
	HashId       uint64    `json:"hashid"  xorm:"hashid"`
	Etime        int64     `json:"etime"`
	Value        string    `json:"value"`
	Info         string    `json:"info"`
	Created      time.Time `json:"created" xorm:"created"`
	Detail       string    `json:"detail"`
	Users        string    `json:"users"`
	Groups       string    `json:"groups"`
	Runbook      string    `json:"runbook"`
	Nid          int64     `json:"nid"`
	IgnoreAlert  int       `json:"ignore_alert"`
	Claimants    string    `json:"claimants"`
	NeedUpgrade  int       `json:"need_upgrade"`
	AlertUpgrade string    `json:"alert_upgrade"`
	CurNid       string    `json:"cur_nid"`
	WorkGroups   []int     `json:"work_groups" xorm:"-"`
}

func AllEventCurGet ¶ added in v4.0.4

func AllEventCurGet() ([]EventCur, error)

func EventCurGet ¶

func EventCurGet(col string, value interface{}) (*EventCur, error)

func EventCurGets ¶

func EventCurGets(stime, etime int64, nodePath, query string, priorities, sendTypes []string, limit, offset int) ([]EventCur, error)

func (*EventCur) EventIgnore ¶

func (e *EventCur) EventIgnore() error

type EventDetail ¶

type EventDetail struct {
	Metric     string              `json:"metric"`
	Tags       map[string]string   `json:"tags"`
	Points     []*EventDetailPoint `json:"points"`
	PredPoints []*EventDetailPoint `json:"pred_points,omitempty"` // 预测值, 预测值不为空时, 现场值对应的是实际值
}

type EventDetailPoint ¶

type EventDetailPoint struct {
	Timestamp int64   `json:"timestamp"`
	Value     float64 `json:"value"`
	Extra     string  `json:"extra"`
}

type EventSlice ¶

type EventSlice []*Event

func (EventSlice) Len ¶

func (e EventSlice) Len() int

func (EventSlice) Less ¶

func (e EventSlice) Less(i, j int) bool

func (EventSlice) Swap ¶

func (e EventSlice) Swap(i, j int)

type Exp ¶

type Exp struct {
	Eopt      string  `json:"eopt"`
	Func      string  `json:"func"`      //all,max,min
	Metric    string  `json:"metric"`    //metric
	Params    []int   `json:"params"`    //连续n秒
	Threshold float64 `json:"threshold"` //阈值
}

type Host ¶

type Host struct {
	Id     int64  `json:"id"`
	SN     string `json:"sn" xorm:"'sn'"`
	IP     string `json:"ip" xorm:"'ip'"`
	Ident  string `json:"ident"`
	Name   string `json:"name"`
	Note   string `json:"note"`
	CPU    string `json:"cpu" xorm:"'cpu'"`
	Mem    string `json:"mem"`
	Disk   string `json:"disk"`
	Cate   string `json:"cate"`
	Clock  int64  `json:"clock"`
	Tenant string `json:"tenant"`
}

func HostByIds ¶

func HostByIds(ids []int64) (hosts []Host, err error)

func HostGet ¶

func HostGet(where string, args ...interface{}) (*Host, error)

func HostGets ¶

func HostGets(where string, args ...interface{}) (hosts []Host, err error)

func HostGetsForAdmin ¶

func HostGetsForAdmin(tenant, query, batch, field string, limit, offset int) ([]Host, error)

func HostNew ¶

func HostNew(sn, ip, ident, name, cate string, fields map[string]interface{}) (*Host, error)

func HostSearch ¶

func HostSearch(batch, field string) ([]Host, error)

func (*Host) Del ¶

func (h *Host) Del() error

func (*Host) Save ¶

func (h *Host) Save() error

func (*Host) Update ¶

func (h *Host) Update(fields map[string]interface{}) error

type HostField ¶

type HostField struct {
	Id            int64  `json:"id"`
	FieldIdent    string `json:"field_ident"`
	FieldName     string `json:"field_name"`
	FieldType     string `json:"field_type"`
	FieldRequired int    `json:"field_required"`
	FieldExtra    string `json:"field_extra"`
	FieldCate     string `json:"field_cate"`
}

func HostFieldGet ¶

func HostFieldGet(where string, args ...interface{}) (*HostField, error)

func HostFieldGets ¶

func HostFieldGets() ([]HostField, error)

HostFieldGets 条数非常少，全部返回

func (*HostField) Del ¶

func (hf *HostField) Del() error

func (*HostField) Update ¶

func (hf *HostField) Update(cols ...string) error

func (*HostField) Validate ¶

func (hf *HostField) Validate() error

type HostFieldValue ¶

type HostFieldValue struct {
	Id         int64  `json:"id"`
	HostId     int64  `json:"host_id"`
	FieldIdent string `json:"field_ident"`
	FieldValue string `json:"field_value"`
}

func HostFieldValueGets ¶

func HostFieldValueGets(hostId int64) ([]HostFieldValue, error)

HostFieldValueGets 条数非常少，全部返回

func (*HostFieldValue) Validate ¶

func (hfv *HostFieldValue) Validate() error

type HostRegisterForm ¶

type HostRegisterForm struct {
	SN      string                 `json:"sn"`
	IP      string                 `json:"ip"`
	Ident   string                 `json:"ident"`
	Name    string                 `json:"name"`
	Cate    string                 `json:"cate"`
	UniqKey string                 `json:"uniqkey"`
	Fields  map[string]interface{} `json:"fields"`
	Digest  string                 `json:"digest"`
}

func (HostRegisterForm) Validate ¶

func (f HostRegisterForm) Validate() error

type Index ¶

type Index struct {
	TagKey  string    `json:"tagKey"`
	Type    string    `json:"type"`
	Oid     string    `json:"oid"`
	Lookups []*Lookup `json:"lookups"`
}

type Instance ¶

type Instance struct {
	Id       int64  `json:"id"`
	Module   string `json:"module"`
	Identity string `json:"identity"` //ip 或者 机器名
	RPCPort  string `json:"rpc_port" xorm:"rpc_port"`
	HTTPPort string `json:"http_port" xorm:"http_port"`
	TS       int64  `json:"ts" xorm:"ts"`
	Remark   string `json:"remark"`
	Region   string `json:"region"`
	Active   bool   `xorm:"-" json:"active"`
}

func GetAllInstances ¶

func GetAllInstances(mod string, alive int) ([]*Instance, error)

func GetInstanceBy ¶

func GetInstanceBy(mod, identity, rpcPort, httpPort string) (*Instance, error)

func (*Instance) Add ¶

func (i *Instance) Add() error

func (*Instance) Update ¶

func (i *Instance) Update() error

type InstancesResp ¶

type InstancesResp struct {
	Data []*Instance
	Msg  string
}

rpc

type Invite ¶

type Invite struct {
	Id      int64
	Token   string
	Expire  int64
	Creator string
}

func InviteGet ¶

func InviteGet(where string, args ...interface{}) (*Invite, error)

func InviteMustGet ¶

func InviteMustGet(where string, args ...interface{}) (*Invite, error)

func (*Invite) Del ¶

func (i *Invite) Del() error

type LDAPSection ¶

type LDAPSection struct {
	DefaultUse      bool           `yaml:"defaultUse"`
	Host            string         `yaml:"host"`
	Port            int            `yaml:"port"`
	BaseDn          string         `yaml:"baseDn"`
	BindUser        string         `yaml:"bindUser"`
	BindPass        string         `yaml:"bindPass"`
	AuthFilter      string         `yaml:"authFilter"`
	Attributes      ldapAttributes `yaml:"attributes"`
	CoverAttributes bool           `yaml:"coverAttributes"`
	TLS             bool           `yaml:"tls"`
	StartTLS        bool           `yaml:"startTLS"`
}

var LDAPConfig LDAPSection

type LogCollect ¶

type LogCollect struct {
	Id          int64     `json:"id"`
	Nid         int64     `json:"nid"`
	CollectType string    `json:"collect_type"`
	Name        string    `json:"name"`
	TagsStr     string    `xorm:"tags" json:"-"`
	Step        int       `json:"step"`
	Comment     string    `json:"comment"`
	Creator     string    `json:"creator"`
	Created     time.Time `xorm:"updated" json:"created"`
	LastUpdator string    `xorm:"last_updator" json:"last_updator"`
	LastUpdated time.Time `xorm:"updated" json:"last_updated"`

	Tags map[string]string `xorm:"-" json:"tags"`

	FilePath   string `json:"file_path"`
	TimeFormat string `json:"time_format"`
	Pattern    string `json:"pattern"`
	Func       string `json:"func"`
	FuncType   string `json:"func_type"`
	Unit       string `json:"unit"`

	Degree    int    `json:"degree"`
	Zerofill  int    `xorm:"zero_fill" json:"zerofill"`
	Aggregate string `json:"aggregate"`

	LocalUpdated            int64                     `xorm:"-" json:"-"`
	TimeReg                 *regexp.Regexp            `xorm:"-" json:"-"`
	PatternReg              *regexp.Regexp            `xorm:"-" json:"-"`
	ExcludeReg              *regexp.Regexp            `xorm:"-" json:"-"`
	TagRegs                 map[string]*regexp.Regexp `xorm:"-" json:"-"`
	ParseSucc               bool                      `xorm:"-" json:"-"`
	WhetherAttachOneLogLine int                       `json:"whether_attach_one_log_line" xorm:"'whether_attach_one_log_line'"`
}

func GetLogCollects ¶

func GetLogCollects() ([]*LogCollect, error)

func (*LogCollect) Decode ¶

func (l *LogCollect) Decode() error

func (*LogCollect) Encode ¶

func (l *LogCollect) Encode() error

func (*LogCollect) Update ¶

func (p *LogCollect) Update() error

type LoginCode ¶

type LoginCode struct {
	Username  string `json:"username"`
	Code      string `json:"code"`
	LoginType string `json:"login_type"`
	CreatedAt int64  `json:"created_at"`
}

func LoginCodeGet ¶

func LoginCodeGet(where string, args ...interface{}) (*LoginCode, error)

func (*LoginCode) Del ¶

func (p *LoginCode) Del() error

func (*LoginCode) Save ¶

func (p *LoginCode) Save() error

type LoginLog ¶

type LoginLog struct {
	Id       int64  `json:"id"`
	Username string `json:"username"`
	Client   string `json:"client"`
	Clock    int64  `json:"clock"`
	Loginout string `json:"loginout"`
	Err      string `json:"err"`
}

func LoginLogGets ¶

func LoginLogGets(username string, btime, etime int64, limit, offset int) ([]LoginLog, error)

type Lookup ¶

type Lookup struct {
	Labels    []string `yaml:"labels" json:"labels"`
	Labelname string   `yaml:"labelname" json:"labelname"`
	Oid       string   `yaml:"oid" json:"oid,omitempty"`
	Type      string   `yaml:"type" json:"type,omitempty"`
}

type Maskconf ¶

type Maskconf struct {
	Id          int64             `json:"id"`
	Category    int               `json:"category"`
	Nid         int64             `json:"nid"`
	NodePath    string            `json:"node_path" xorm:"-"`
	Metric      string            `json:"metric"`
	Tags        string            `json:"tags"`
	Cause       string            `json:"cause"`
	User        string            `json:"user"`
	Btime       int64             `json:"btime"`
	Etime       int64             `json:"etime"`
	Endpoints   []string          `json:"endpoints" xorm:"-"`
	Nids        []string          `json:"nids" xorm:"-"`
	CurNidPaths map[string]string `json:"cur_nid_paths" xorm:"-"`
}

func MaskconfGet ¶

func MaskconfGet(col string, value interface{}) (*Maskconf, error)

func MaskconfGetAll ¶

func MaskconfGetAll() ([]Maskconf, error)

func MaskconfGets ¶

func MaskconfGets(nodeId int64) ([]Maskconf, error)

func (*Maskconf) AddEndpoints ¶

func (mc *Maskconf) AddEndpoints(endpoints []string) error

func (*Maskconf) AddNids ¶

func (mc *Maskconf) AddNids(nidPaths map[string]string) error

func (*Maskconf) FillEndpoints ¶

func (mc *Maskconf) FillEndpoints() error

func (*Maskconf) FillNids ¶

func (mc *Maskconf) FillNids() error

func (*Maskconf) UpdateEndpoints ¶

func (mc *Maskconf) UpdateEndpoints(endpoints []string, cols ...string) error

func (*Maskconf) UpdateNids ¶

func (mc *Maskconf) UpdateNids(nidPaths map[string]string, cols ...string) error

type MaskconfEndpoints ¶

type MaskconfEndpoints struct {
	Id       int64  `json:"id"`
	MaskId   int64  `json:"mask_id"`
	Endpoint string `json:"endpoint"`
}

type MaskconfNids ¶

type MaskconfNids struct {
	Id     int64  `json:"id"`
	MaskId int64  `json:"mask_id"`
	Nid    string `json:"nid"`
	Path   string `json:"path"`
}

type Metric ¶

type Metric struct {
	Name           string                     `yaml:"name"`
	Oid            string                     `yaml:"oid"`
	Type           string                     `yaml:"type"`
	Help           string                     `yaml:"help"`
	Indexes        []*Index                   `yaml:"indexes,omitempty"`
	Lookups        []*Lookup                  `yaml:"lookups,omitempty"`
	RegexpExtracts map[string][]RegexpExtract `yaml:"regex_extracts,omitempty"`
	EnumValues     map[int]string             `yaml:"enum_values,omitempty"`
}

type Mib ¶

type Mib struct {
	Id         int64  `json:"id"`
	Module     string `json:"module"`
	Metric     string `json:"metric"`
	Oid        string `json:"oid"`
	Mtype      string `json:"mtype"` //gauge,counter
	EnumValues string `json:"enum_values"`
	Indexes    string `json:"indexes"`
	Note       string `json:"note"`
}

func MibGet ¶

func MibGet(where string, args ...interface{}) (*Mib, error)

func MibGets ¶

func MibGets(where string, args ...interface{}) ([]Mib, error)

func MibGetsByQuery ¶

func MibGetsByQuery(query string, limit, offset int) ([]Mib, error)

func MibGetsGroupBy ¶

func MibGetsGroupBy(group string, where string, args ...interface{}) ([]Mib, error)

func NewMib ¶

func NewMib(module string, m *Metric) *Mib

func (*Mib) Save ¶

func (m *Mib) Save() error

type Module ¶

type Module struct {
	// A list of OIDs.
	Walk       []string   `yaml:"walk,omitempty"`
	Get        []string   `yaml:"get,omitempty"`
	Metrics    []*Metric  `yaml:"metrics"`
	WalkParams WalkParams `yaml:",inline"`
}

type MySQLConf ¶

type MySQLConf struct {
	Addr  string `yaml:"addr"`
	Max   int    `yaml:"max"`
	Idle  int    `yaml:"idle"`
	Debug bool   `yaml:"debug"`
}

type NetworkHardware ¶

type NetworkHardware struct {
	Id          int64  `json:"id"`
	SN          string `json:"sn" xorm:"sn"`
	IP          string `json:"ip" xorm:"ip"`
	Name        string `json:"name"`
	Note        string `json:"note"`
	Cate        string `json:"cate"`
	SnmpVersion string `json:"snmp_version"`
	Auth        string `json:"auth"`
	Region      string `json:"region"`
	Info        string `json:"info"`
	Tenant      string `json:"tenant"`
	Uptime      int64  `json:"uptime"`
}

func GetHardwareInfoBy ¶

func GetHardwareInfoBy(ips []string) []*NetworkHardware

func MakeNetworkHardware ¶

func MakeNetworkHardware(ip, cate, version, auth, region, note string) *NetworkHardware

func NetworkHardwareGet ¶

func NetworkHardwareGet(where string, args ...interface{}) (*NetworkHardware, error)

func NetworkHardwareList ¶

func NetworkHardwareList(query string, limit, offset int) ([]NetworkHardware, error)

func NwGetsForAdmin ¶

func NwGetsForAdmin(tenant, query, batch, field string, limit, offset int) ([]NetworkHardware, error)

func NwSearch ¶

func NwSearch(batch, field string) ([]NetworkHardware, error)

NwSearch 普通用户查询

func (*NetworkHardware) Del ¶

func (n *NetworkHardware) Del() error

func (*NetworkHardware) Update ¶

func (n *NetworkHardware) Update(cols ...string) error

type NetworkHardwareRpcResp ¶

type NetworkHardwareRpcResp struct {
	Data []*NetworkHardware
	Msg  string
}

type Node ¶

type Node struct {
	Id          int64     `json:"id"`
	Pid         int64     `json:"pid"`
	Ident       string    `json:"ident"`
	Name        string    `json:"name"`
	Note        string    `json:"note"`
	Path        string    `json:"path"`
	Leaf        int       `json:"leaf"`
	Cate        string    `json:"cate"`
	IconColor   string    `json:"icon_color"`
	IconChar    string    `json:"icon_char"`
	Proxy       int       `json:"proxy"`
	Creator     string    `json:"creator"`
	LastUpdated time.Time `json:"last_updated" xorm:"<-"`
	Admins      []User    `json:"admins" xorm:"-"`
	LeafNids    []int64   `json:"leafNids" xorm:"-"`
}

func NodeByIds ¶

func NodeByIds(ids []int64) ([]Node, error)

func NodeByPaths ¶

func NodeByPaths(paths []string) ([]Node, error)

func NodeGet ¶

func NodeGet(where string, args ...interface{}) (*Node, error)

func NodeGetById ¶

func NodeGetById(id int64) (*Node, error)

func NodeGets ¶

func NodeGets(where string, args ...interface{}) (nodes []Node, err error)

NodeGets 在所有节点范围查询，比如管理员看服务树，就需要load所有数据

func PermNodes ¶

func PermNodes(myNodes []Node) ([]Node, error)

func TenantsGetByUserId ¶

func TenantsGetByUserId(id int64, withAdmins ...bool) (tenants []Node, err error)

TenantsGetByUserId 使用方：工单

func TreeUntilProjectsGetByNid ¶

func TreeUntilProjectsGetByNid(nid int64) ([]Node, error)

func TreeUntilProjectsGetByUser ¶

func TreeUntilProjectsGetByUser(user *User) ([]Node, error)

暂时保留，不知道外部其他组件是否有调用

func TreeUntilTypGetByUser ¶

func TreeUntilTypGetByUser(user *User, typ string) ([]Node, error)

func UserPermNodes ¶

func UserPermNodes(me *User) ([]Node, error)

func (*Node) Bind ¶

func (n *Node) Bind(resIds []int64) error

Bind 把资源挂载到某个树节点

func (*Node) CreateChild ¶

func (n *Node) CreateChild(ident, name, note, cate, creator string, leaf, proxy int, adminIds []int64) (*Node, error)

CreateChild 返回创建的子节点

func (*Node) Del ¶

func (n *Node) Del() error

func (*Node) FillAdmins ¶

func (n *Node) FillAdmins() error

func (*Node) FilterMyChildren ¶

func (n *Node) FilterMyChildren(nodes []Node) []Node

func (*Node) LeafIds ¶

func (n *Node) LeafIds() ([]int64, error)

LeafIds 叶子节点的id

func (*Node) Modify ¶

func (n *Node) Modify(name, cate, note string, adminIds []int64) error

func (*Node) Move ¶ added in v4.0.2

func (n *Node) Move(tnode *Node) error

func (*Node) RelatedNodes ¶

func (n *Node) RelatedNodes() ([]Node, error)

todo 是否需要待确认

func (*Node) RoleList ¶

func (n *Node) RoleList(username string, limit, offset int) ([]NodeRole, error)

func (*Node) RoleTotal ¶

func (n *Node) RoleTotal(username string) (int64, error)

func (*Node) Tenant ¶

func (n *Node) Tenant() string

func (*Node) Unbind ¶

func (n *Node) Unbind(resIds []int64) error

Unbind 从某个服务树节点解挂机器

type NodeAdmin ¶

type NodeAdmin struct {
	NodeId int64
	UserId int64
}

type NodeCate ¶

type NodeCate struct {
	Id        int64  `json:"id"`
	Ident     string `json:"ident"`
	Name      string `json:"name"`
	IconColor string `json:"icon_color"`
	Protected int    `json:"protected"`
}

func NodeCateGet ¶

func NodeCateGet(where string, args ...interface{}) (*NodeCate, error)

func NodeCateGets ¶

func NodeCateGets() ([]NodeCate, error)

NodeCateGets 条数非常少，全部返回

func (*NodeCate) Del ¶

func (nc *NodeCate) Del() error

Del 删除NodeCate的时候无需去管node表，某些node的cate已经被删除了，也没什么大不了

func (*NodeCate) Update ¶

func (nc *NodeCate) Update(cols ...string) error

type NodeCateField ¶

type NodeCateField struct {
	Id            int64     `json:"id"`
	Cate          string    `json:"cate"`
	FieldIdent    string    `json:"field_ident"`
	FieldName     string    `json:"field_name"`
	FieldType     string    `json:"field_type"`
	FieldRequired int       `json:"field_required"`
	FieldExtra    string    `json:"field_extra"`
	LastUpdated   time.Time `json:"last_updated" xorm:"<-"`
}

func NodeCateFieldGet ¶

func NodeCateFieldGet(where string, args ...interface{}) (*NodeCateField, error)

func NodeCateFieldGets ¶

func NodeCateFieldGets(where string, args ...interface{}) ([]NodeCateField, error)

NodeCateFieldGets 条数非常少，全部返回

func (*NodeCateField) Del ¶

func (ncf *NodeCateField) Del() error

func (*NodeCateField) Update ¶

func (ncf *NodeCateField) Update(cols ...string) error

func (*NodeCateField) Validate ¶

func (ncf *NodeCateField) Validate() error

type NodeFieldValue ¶

type NodeFieldValue struct {
	Id         int64  `json:"id"`
	NodeId     int64  `json:"node_id"`
	FieldIdent string `json:"field_ident"`
	FieldValue string `json:"field_value"`
}

func NodeFieldValueGets ¶

func NodeFieldValueGets(nodeId int64) ([]NodeFieldValue, error)

NodeFieldValueGets 条数非常少，全部返回

func (*NodeFieldValue) Validate ¶

func (nfv *NodeFieldValue) Validate() error

type NodeResource ¶

type NodeResource struct {
	NodeId int64
	ResId  int64
}

func NodeResourceGetAll ¶ added in v4.0.4

func NodeResourceGetAll() ([]*NodeResource, error)

type NodeRole ¶

type NodeRole struct {
	Id       int64  `json:"id"`
	NodeId   int64  `json:"node_id"`
	Username string `json:"username"`
	RoleId   int64  `json:"role_id"`
	NodePath string `xorm:"<- 'node_path'" json:"node_path"`
	RoleTxt  string `xorm:"-" json:"role_txt"`
	Dispname string `xorm:"-" json:"dispname"`
}

func (*NodeRole) Save ¶

func (nr *NodeRole) Save() error

type NodeTrash ¶

type NodeTrash struct {
	Id          int64     `json:"id"`
	Pid         int64     `json:"pid"`
	Ident       string    `json:"ident"`
	Name        string    `json:"name"`
	Note        string    `json:"note"`
	Path        string    `json:"path"`
	Leaf        int       `json:"leaf"`
	Cate        string    `json:"cate"`
	IconColor   string    `json:"icon_color"`
	IconChar    string    `json:"icon_char"`
	Proxy       int       `json:"proxy"`
	Creator     string    `json:"creator"`
	LastUpdated time.Time `json:"last_updated" xorm:"<-"`
}

func NodeTrashGetByIds ¶

func NodeTrashGetByIds(ids []int64) ([]NodeTrash, error)

func NodeTrashGets ¶

func NodeTrashGets(query string, limit, offset int) ([]NodeTrash, error)

type OperationLog ¶

type OperationLog struct {
	Id       int64  `json:"id"`
	Username string `json:"username"`
	Clock    int64  `json:"clock"`
	ResCl    string `json:"res_cl"`
	ResId    string `json:"res_id"`
	Detail   string `json:"detail"`
}

func OperationLogGetsByRes ¶

func OperationLogGetsByRes(rescl, resid string, btime, etime int64, limit, offset int) ([]OperationLog, error)

func OperationLogQuery ¶

func OperationLogQuery(query string, btime, etime int64, limit, offset int) ([]OperationLog, error)

func (*OperationLog) New ¶

func (ol *OperationLog) New() error

type PluginCollect ¶

type PluginCollect struct {
	Id          int64     `json:"id"`
	Nid         int64     `json:"nid"`
	CollectType string    `json:"collect_type"`
	Name        string    `json:"name"`
	Step        int       `json:"step"`
	FilePath    string    `json:"file_path"`
	Params      string    `json:"params"`
	Stdin       string    `json:"stdin"`
	Env         string    `json:"env"`
	Comment     string    `json:"comment"`
	Creator     string    `json:"creator"`
	Created     time.Time `xorm:"updated" json:"created"`
	LastUpdator string    `xorm:"last_updator" json:"last_updator"`
	LastUpdated time.Time `xorm:"updated" json:"last_updated"`
}

func GetPluginCollects ¶

func GetPluginCollects() ([]*PluginCollect, error)

func (*PluginCollect) Update ¶

func (p *PluginCollect) Update() error

type PortCollect ¶

type PortCollect struct {
	Id          int64     `json:"id"`
	Nid         int64     `json:"nid"`
	CollectType string    `json:"collect_type"`
	Name        string    `json:"name"`
	Tags        string    `json:"tags"`
	Step        int       `json:"step"`
	Comment     string    `json:"comment"`
	Creator     string    `json:"creator"`
	Created     time.Time `xorm:"updated" json:"created"`
	LastUpdator string    `xorm:"last_updator" json:"last_updator"`
	LastUpdated time.Time `xorm:"updated" json:"last_updated"`

	Port    int `json:"port"`
	Timeout int `json:"timeout"`
}

func GetPortCollects ¶

func GetPortCollects() ([]*PortCollect, error)

func (*PortCollect) Update ¶

func (p *PortCollect) Update() error

type ProcCollect ¶

type ProcCollect struct {
	Id          int64     `json:"id"`
	Nid         int64     `json:"nid"`
	CollectType string    `json:"collect_type"`
	Name        string    `json:"name"`
	Tags        string    `json:"tags"`
	Step        int       `json:"step"`
	Comment     string    `json:"comment"`
	Creator     string    `json:"creator"`
	Created     time.Time `xorm:"updated" json:"created"`
	LastUpdator string    `xorm:"last_updator" json:"last_updator"`
	LastUpdated time.Time `xorm:"updated" json:"last_updated"`

	Target        string `json:"target"`
	CollectMethod string `json:"collect_method"`

	ProcJiffy map[int]uint64 `xorm:"-" json:"-"`
	Jiffy     uint64         `xorm:"-" json:"-"`
	RBytes    map[int]uint64 `xorm:"-" json:"-"`
	WBytes    map[int]uint64 `xorm:"-" json:"-"`
}

func GetProcCollects ¶

func GetProcCollects() ([]*ProcCollect, error)

func (*ProcCollect) Update ¶

func (p *ProcCollect) Update() error

type Regexp ¶

type Regexp struct {
	*regexp.Regexp
}

Regexp encapsulates a regexp.Regexp and makes it YAML marshalable.

type RegexpExtract ¶

type RegexpExtract struct {
	Value string `yaml:"value"`
	Regex Regexp `yaml:"regex"`
}

type Resource ¶

type Resource struct {
	Id          int64     `json:"id"`
	UUID        string    `json:"uuid" xorm:"'uuid'"`
	Ident       string    `json:"ident"`
	Name        string    `json:"name"`
	Labels      string    `json:"labels"`
	Note        string    `json:"note"`
	Extend      string    `json:"extend"`
	Cate        string    `json:"cate"`
	Tenant      string    `json:"tenant"`
	LastUpdated time.Time `json:"last_updated" xorm:"<-"`
}

func ResourceGet ¶

func ResourceGet(where string, args ...interface{}) (*Resource, error)

func ResourceGets ¶

func ResourceGets(where string, args ...interface{}) ([]Resource, error)

func ResourceOrphanList ¶

func ResourceOrphanList(tenant, query, batch, field string, limit, offset int) ([]Resource, error)

func ResourceSearch ¶

func ResourceSearch(batch, field string) ([]Resource, error)

func ResourceUnderNodeGets ¶

func ResourceUnderNodeGets(leafIds []int64, query, batch, field string, limit, offset int) ([]Resource, error)

func ResourcesByIdents ¶

func ResourcesByIdents(idents []string) ([]Resource, error)

func (*Resource) Save ¶

func (r *Resource) Save() error

func (*Resource) Update ¶

func (r *Resource) Update(cols ...string) error

type ResourceBinding ¶

type ResourceBinding struct {
	Id    int64  `json:"id"`
	UUID  string `json:"uuid"`
	Ident string `json:"ident"`
	Name  string `json:"name"`
	Nodes []Node `json:"nodes"`
}

func ResourceBindings ¶

func ResourceBindings(resIds []int64) ([]ResourceBinding, error)

ResourceBindings 资源与节点的绑定关系，一个资源对应多个节点

type ResourceRegisterItem ¶

type ResourceRegisterItem struct {
	UUID   string `json:"uuid"`
	Ident  string `json:"ident"`
	Name   string `json:"name"`
	Labels string `json:"labels"`
	Extend string `json:"extend"`
	Cate   string `json:"cate"`
	NID    int64  `json:"nid"`
}

func (ResourceRegisterItem) Validate ¶

func (i ResourceRegisterItem) Validate() error

type Role ¶

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

func GlobalRolesGetByUserId ¶

func GlobalRolesGetByUserId(id int64) (roles []Role, err error)

GlobalRolesGetByUserId 使用方：工单

func RoleFind ¶

func RoleFind(cate string) ([]Role, error)

func RoleGet ¶

func RoleGet(where string, args ...interface{}) (*Role, error)

func RoleGetByIds ¶

func RoleGetByIds(ids []int64) (roles []Role, err error)

func (*Role) BindUsers ¶

func (r *Role) BindUsers(userIds []int64) error

func (*Role) CheckFields ¶

func (r *Role) CheckFields() error

func (*Role) Del ¶

func (r *Role) Del() error

func (*Role) GlobalUserIds ¶

func (r *Role) GlobalUserIds() ([]int64, error)

func (*Role) Modify ¶

func (r *Role) Modify(name, note, cate string, ops []string) error

func (*Role) Save ¶

func (r *Role) Save(ops []string) error

func (*Role) UnbindUsers ¶

func (r *Role) UnbindUsers(ids []int64) error

type RoleGlobalUser ¶

type RoleGlobalUser struct {
	RoleId int64 `json:"role_id" xorm:"'role_id'"`
	UserId int64 `json:"user_id" xorm:"'user_id'"`
}

func RoleGlobalUserAll ¶

func RoleGlobalUserAll() ([]RoleGlobalUser, error)

type RoleOperation ¶

type RoleOperation struct {
	Id        int64  `json:"id"`
	RoleId    int64  `json:"role_id"`
	Operation string `json:"operation"`
}

func RoleOperationAll ¶

func RoleOperationAll() ([]RoleOperation, error)

type Screen ¶

type Screen struct {
	Id          int64     `json:"id"`
	NodeId      int64     `json:"node_id"`
	Name        string    `json:"name"`
	LastUpdator string    `json:"last_updator"`
	LastUpdated time.Time `xorm:"<-" json:"last_updated"`

	NodePath string `json:"node_path" xorm:"-"`
}

func ScreenGet ¶

func ScreenGet(col string, val interface{}) (*Screen, error)

func ScreenGets ¶

func ScreenGets(nodeId int64) ([]Screen, error)

func (*Screen) Add ¶

func (s *Screen) Add() error

func (*Screen) Del ¶

func (s *Screen) Del() error

func (*Screen) Update ¶

func (s *Screen) Update(cols ...string) error

type ScreenSubclass ¶

type ScreenSubclass struct {
	Id       int64  `json:"id"`
	ScreenId int64  `json:"screen_id"`
	Name     string `json:"name"`
	Weight   int    `json:"weight"`
}

func ScreenSubclassGet ¶

func ScreenSubclassGet(col string, val interface{}) (*ScreenSubclass, error)

func ScreenSubclassGets ¶

func ScreenSubclassGets(screenId int64) ([]ScreenSubclass, error)

func (*ScreenSubclass) Add ¶

func (s *ScreenSubclass) Add() error

func (*ScreenSubclass) Del ¶

func (s *ScreenSubclass) Del() error

func (*ScreenSubclass) Update ¶

func (s *ScreenSubclass) Update(cols ...string) error

type Secret ¶

type Secret string

Secret is a string that must not be revealed on marshaling.

type Session ¶

type Session struct {
	Sid         string `json:"sid"`
	AccessToken string `json:"-"`
	Username    string `json:"username"`
	RemoteAddr  string `json:"remote_addr"`
	CreatedAt   int64  `json:"created_at"`
	UpdatedAt   int64  `json:"updated_at"`
}

func SessionAndTotalGets ¶

func SessionAndTotalGets(query string, limit, offset int) ([]Session, int64, error)

func SessionGet ¶

func SessionGet(sid string) (*Session, error)

func SessionGetByToken ¶

func SessionGetByToken(token string) (*Session, error)

func SessionGetWithCache ¶

func SessionGetWithCache(sid string) (*Session, error)

SessionGetWithCache will update session.UpdatedAt && token.LastAt

func SessionGets ¶

func SessionGets(limit, offset int, where string, args ...interface{}) ([]Session, error)

func TokenGetWithCache ¶

func TokenGetWithCache(accessToken string) (*Session, error)

TokenGetWithCache will update token.LastAt

func (*Session) Save ¶

func (s *Session) Save() error

func (*Session) Update ¶

func (s *Session) Update(cols ...string) error

type SnmpCollect ¶

type SnmpCollect struct {
	Id          int64     `json:"id"`
	Nid         int64     `json:"nid"`
	CollectType string    `json:"collect_type"`
	OidType     int       `json:"oid_type"` //1 通用指标 2 私有指标 3 自定义指标
	Module      string    `json:"module"`
	Metric      string    `json:"metric"`
	MetricType  string    `json:"metric_type"`
	Oid         string    `json:"oid"`
	Step        int       `json:"step"`
	Timeout     int       `json:"timeout"`
	Port        int       `json:"port"`
	IndexesStr  string    `xorm:"indexes" json:"-"`
	Comment     string    `json:"comment"`
	Creator     string    `json:"creator"`
	Created     time.Time `xorm:"updated" json:"created"`
	LastUpdator string    `xorm:"last_updator" json:"last_updator"`
	LastUpdated time.Time `xorm:"updated" json:"last_updated"`

	Indexes []*Index `xorm:"-" json:"indexes"`
	Region  string   `xorm:"-" json:"region"`
	Version string   `xorm:"-" json:"version"`
	Auth    string   `xorm:"-" json:"auth"`
}

func GetSnmpCollects ¶

func GetSnmpCollects(nid int64) ([]*SnmpCollect, error)

func (*SnmpCollect) Decode ¶

func (s *SnmpCollect) Decode() error

func (*SnmpCollect) Encode ¶

func (s *SnmpCollect) Encode() error

func (*SnmpCollect) GetByOidAndModule ¶

func (s *SnmpCollect) GetByOidAndModule() (*SnmpCollect, error)

func (*SnmpCollect) Update ¶

func (s *SnmpCollect) Update() error

type Stats ¶

type Stats struct {
	Name  string `json:"name"`
	Value int64  `json:"value"`
}

func MustNewStats ¶

func MustNewStats(name string) *Stats

func NewStats ¶

func NewStats(name string) (*Stats, error)

func (*Stats) Del ¶

func (p *Stats) Del() error

func (*Stats) Get ¶

func (p *Stats) Get() int64

func (*Stats) Inc ¶

func (p *Stats) Inc(i int) error

for COUNTER

func (*Stats) Save ¶

func (p *Stats) Save() error

func (*Stats) Update ¶

func (p *Stats) Update(i int64) error

for GAUAGE

type Stra ¶

type Stra struct {
	Id                  int64     `json:"id"`
	Name                string    `json:"name"`
	Category            int       `json:"category"` //机器，非机器
	Nid                 int64     `json:"nid"`
	ExclNidStr          string    `xorm:"excl_nid" json:"-"`            //排除的叶子节点
	AlertDur            int       `json:"alert_dur"`                    //单位秒，持续异常10分钟则产生异常event
	RecoveryDur         int       `json:"recovery_dur"`                 //单位秒，持续正常2分钟则产生恢复event，0表示立即产生恢复event
	RecoveryNotify      int       `json:"recovery_notify"`              //1 发送恢复通知 0不发送恢复通知
	ExprsStr            string    `xorm:"exprs" json:"-"`               //多个条件的监控实例需要相同，并且同时满足才产生event
	TagsStr             string    `xorm:"tags" json:"-"`                //tag过滤条件
	EnableStime         string    `json:"enable_stime"`                 //策略生效开始时间
	EnableEtime         string    `json:"enable_etime"`                 //策略生效终止时间 支持23:00-02:00
	EnableDaysOfWeekStr string    `xorm:"enable_days_of_week" json:"-"` //策略生效日期
	ConvergeStr         string    `xorm:"converge" json:"-"`            //告警通知收敛，第1个值表示收敛周期，单位秒，第2个值表示周期内允许发送告警次数
	Priority            int       `json:"priority"`
	Callback            string    `json:"callback"`
	NotifyGroupStr      string    `xorm:"notify_group" json:"-"`
	NotifyUserStr       string    `xorm:"notify_user" json:"-"`
	Creator             string    `json:"creator"`
	Created             time.Time `xorm:"created" json:"created"`
	LastUpdator         string    `xorm:"last_updator" json:"last_updator"`
	LastUpdated         time.Time `xorm:"<-" json:"last_updated"`
	NeedUpgrade         int       `xorm:"need_upgrade" json:"need_upgrade"`
	AlertUpgradeStr     string    `xorm:"alert_upgrade" json:"-"`
	WorkGroupsStr       string    `xorm:"work_groups" json:"-"`
	Runbook             string    `xorm:"runbook" json:"runbook"`

	ExclNid           []int64      `xorm:"-" json:"excl_nid"`
	Nids              []string     `xorm:"-" json:"nids"`
	Exprs             []Exp        `xorm:"-" json:"exprs"`
	Tags              []Tag        `xorm:"-" json:"tags"`
	EnableDaysOfWeek  []int        `xorm:"-" json:"enable_days_of_week"`
	Converge          []int        `xorm:"-" json:"converge"`
	NotifyGroup       []int64      `xorm:"-" json:"notify_group"`
	NotifyGroupDetail []Team       `xorm:"-" json:"notify_group_detail"`
	NotifyUser        []int64      `xorm:"-" json:"notify_user"`
	NotifyUserDetail  []User       `xorm:"-" json:"notify_user_detail"`
	LeafNids          []int64      `xorm:"-" json:"leaf_nids"` //叶子节点id
	Endpoints         []string     `xorm:"-" json:"endpoints"`
	AlertUpgrade      AlertUpgrade `xorm:"-" json:"alert_upgrade"`
	JudgeInstance     string       `xorm:"-" json:"judge_instance"`
	WorkGroups        []int        `xorm:"-" json:"work_groups"`
}

func EffectiveStrasList ¶

func EffectiveStrasList() ([]*Stra, error)

func StraFindOne ¶

func StraFindOne(where string, args ...interface{}) (*Stra, error)

func StraGet ¶

func StraGet(col string, val interface{}) (*Stra, error)

func StrasAll ¶

func StrasAll() ([]*Stra, error)

func StrasList ¶

func StrasList(name string, priority int, nid int64) ([]*Stra, error)

func (*Stra) Decode ¶

func (s *Stra) Decode() error

func (*Stra) Encode ¶

func (s *Stra) Encode() error

func (*Stra) GetMetric ¶

func (s *Stra) GetMetric() string

func (*Stra) HasPermssion ¶

func (s *Stra) HasPermssion() error

func (*Stra) Save ¶

func (s *Stra) Save() error

func (*Stra) Update ¶

func (s *Stra) Update() error

type StraLog ¶

type StraLog struct {
	Id      int64     `json:"id"`
	Sid     int64     `json:"sid"`
	Action  string    `json:"action"` // update|delete
	Body    string    `json:"body"`
	Creator string    `json:"creator"`
	Created time.Time `json:"created" xorm:"created"`
}

type Tag ¶

type Tag struct {
	Tkey string   `json:"tkey"`
	Topt string   `json:"topt"`
	Tval []string `json:"tval"` //修改为数组
}

type TaskAction ¶

type TaskAction struct {
	Id     int64
	Action string
	Clock  int64
}

func TaskActionGet ¶

func TaskActionGet(where string, args ...interface{}) (*TaskAction, error)

func (*TaskAction) Update ¶

func (a *TaskAction) Update(action string) error

type TaskHost ¶

type TaskHost struct {
	Id     int64  `json:"id"`
	Host   string `json:"host"`
	Status string `json:"status"`
	Stdout string `json:"stdout"`
	Stderr string `json:"stderr"`
}

func TaskHostGet ¶

func TaskHostGet(id int64, host string) (*TaskHost, error)

func TaskHostGets ¶

func TaskHostGets(id int64) ([]TaskHost, error)

func TaskHostStatus ¶

func TaskHostStatus(id int64) ([]TaskHost, error)

func WaitingHostList ¶

func WaitingHostList(id int64, limit ...int) ([]TaskHost, error)

type TaskHostDoing ¶

type TaskHostDoing struct {
	Id     int64
	Host   string
	Clock  int64
	Action string
}

func DoingHostList ¶

func DoingHostList(where string, args ...interface{}) ([]TaskHostDoing, error)

func GetDoingCache ¶

func GetDoingCache(k string) []TaskHostDoing

type TaskMeta ¶

type TaskMeta struct {
	Id        int64     `json:"id"`
	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"`
	Creator   string    `json:"creator"`
	Created   time.Time `xorm:"created" json:"created"`
	Done      bool      `xorm:"-" json:"done"`
}

func TaskMetaGet ¶

func TaskMetaGet(where string, args ...interface{}) (*TaskMeta, error)

func TaskMetaGetByID ¶

func TaskMetaGetByID(id interface{}) (*TaskMeta, error)

TaskMetaGet 根据ID获取任务元信息，会用到内存缓存

func TaskMetaGets ¶

func TaskMetaGets(creator, query string, before time.Time, limit, offset int) ([]TaskMeta, error)

func (*TaskMeta) Action ¶

func (m *TaskMeta) Action() (*TaskAction, error)

func (*TaskMeta) CleanFields ¶

func (m *TaskMeta) CleanFields() error

func (*TaskMeta) HandleFH ¶

func (m *TaskMeta) HandleFH(fh string)

func (*TaskMeta) HostStrs ¶

func (m *TaskMeta) HostStrs() ([]string, error)

func (*TaskMeta) Hosts ¶

func (m *TaskMeta) Hosts() ([]TaskHost, error)

func (*TaskMeta) IgnoreHost ¶

func (m *TaskMeta) IgnoreHost(host string) error

func (*TaskMeta) KillHost ¶

func (m *TaskMeta) KillHost(host string) error

func (*TaskMeta) RedoHost ¶

func (m *TaskMeta) RedoHost(host string) error

func (*TaskMeta) Save ¶

func (m *TaskMeta) Save(hosts []string, action string) error

func (*TaskMeta) Stderrs ¶

func (m *TaskMeta) Stderrs() ([]TaskHost, error)

func (*TaskMeta) Stdouts ¶

func (m *TaskMeta) Stdouts() ([]TaskHost, error)

type TaskScheduler ¶

type TaskScheduler struct {
	Id        int64
	Scheduler string
}

type TaskSchedulerHealth ¶

type TaskSchedulerHealth struct {
	Scheduler string
	Clock     time.Time
}

type TaskTpl ¶

type TaskTpl struct {
	Id          int64     `json:"id"`
	NodeId      int64     `json:"node_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:"tags"`
	Account     string    `json:"account"`
	Creator     string    `json:"creator"`
	LastUpdated time.Time `xorm:"<-" json:"last_updated"`
}

func TaskTplGet ¶

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

func TaskTplGets ¶

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

func (*TaskTpl) BindTags ¶

func (t *TaskTpl) BindTags(tags []string) error

func (*TaskTpl) CleanFields ¶

func (t *TaskTpl) CleanFields() error

func (*TaskTpl) Del ¶

func (t *TaskTpl) Del() error

func (*TaskTpl) Hosts ¶

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

func (*TaskTpl) Save ¶

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

func (*TaskTpl) UnbindTags ¶

func (t *TaskTpl) UnbindTags(tags []string) error

func (*TaskTpl) Update ¶

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

func (*TaskTpl) UpdateGroup ¶

func (t *TaskTpl) UpdateGroup(nodeId int64) error

type Team ¶

type Team struct {
	Id          int64     `json:"id"`
	Ident       string    `json:"ident"`
	Name        string    `json:"name"`
	Note        string    `json:"note"`
	Mgmt        int       `json:"mgmt"`
	Creator     int64     `json:"creator"`
	LastUpdated time.Time `json:"last_updated" xorm:"<-"`
}

func AllTeams ¶ added in v4.0.2

func AllTeams() ([]Team, error)

func TeamGet ¶

func TeamGet(where string, args ...interface{}) (*Team, error)

func TeamGetByIds ¶

func TeamGetByIds(ids []int64) ([]Team, error)

func TeamGets ¶

func TeamGets(query string, limit, offset int) ([]Team, error)

func TeamGetsInIds ¶

func TeamGetsInIds(ids []int64, query string, limit, offset int) ([]Team, error)

func (*Team) BindUser ¶

func (t *Team) BindUser(ids []int64, isadmin int) error

func (*Team) CheckFields ¶

func (t *Team) CheckFields() error

func (*Team) Del ¶

func (t *Team) Del() error

func (*Team) Modify ¶

func (t *Team) Modify(name, note string, mgmt int) error

func (*Team) UnbindUser ¶

func (t *Team) UnbindUser(ids []int64) error

func (*Team) Update ¶

func (t *Team) Update(cols ...string) error

func (*Team) UsersGet ¶

func (t *Team) UsersGet(query string, limit, offset int) ([]TeamMember, error)

UsersGet limit和offset没有用orm来拼接，是因为获取的list会莫名其妙变多

func (*Team) UsersTotal ¶

func (t *Team) UsersTotal(query string) (int64, error)

type TeamMember ¶

type TeamMember struct {
	Id       int64  `json:"id"`
	Username string `json:"username"`
	Dispname string `json:"dispname"`
	Phone    string `json:"phone"`
	Email    string `json:"email"`
	Im       string `json:"im"`
	IsRoot   int    `json:"is_root"`
	TeamId   int64  `json:"team_id"`
	IsAdmin  int    `json:"is_admin"`
}

type TeamUser ¶

type TeamUser struct {
	TeamId  int64 `json:"team_id" xorm:"'team_id'"`
	UserId  int64 `json:"user_id" xorm:"'user_id'"`
	IsAdmin int   `json:"is_admin" xorm:"'is_admin'"`
}

func TeamUsers ¶ added in v4.0.2

func TeamUsers() ([]TeamUser, error)

type TmpChart ¶

type TmpChart struct {
	Id      int64  `json:"id"`
	Configs string `json:"configs"`
	Creator string `json:"creator"`
}

func TmpChartGet ¶

func TmpChartGet(col string, val interface{}) (*TmpChart, error)

func (*TmpChart) Add ¶

func (t *TmpChart) Add() error

type Token ¶

type Token struct {
	Id           int64  `json:"id,omitempty"`
	Name         string `json:"name,omitempty" description:"access token name"`
	AccessToken  string `json:"accessToken,omitempty"`
	RefreshToken string `json:"refreshToken,omitempty"`
	ClientId     string `json:"clientId,omitempty"`
	Authorize    string `json:"authorize,omitempty"`
	Previous     string `json:"previous,omitempty"`
	ExpiresIn    int64  `json:"expiresIn,omitempty" description:"max 3 year, default:0, max time"`
	Scope        string `json:"scope,omitempty" description:"scope split by ' '"`
	RedirectUri  string `json:"redirectUri,omitempty"`
	UserName     string `json:"userName,omitempty"`
	CreatedAt    int64  `json:"createdAt,omitempty" out:",date"`
	LastAt       int64  `json:"lastAt,omitempty" out:",date"`
}

func TokenGet ¶

func TokenGet(token string) (*Token, error)

func TokenGets ¶

func TokenGets(where string, args ...interface{}) (tokens []Token, err error)

func (*Token) Session ¶

func (p *Token) Session() *Session

func (*Token) Update ¶

func (p *Token) Update(cols ...string) error

type User ¶

type User struct {
	Id           int64     `json:"id"`
	UUID         string    `json:"uuid" xorm:"'uuid'"`
	Username     string    `json:"username"`
	Password     string    `json:"-"`
	Passwords    string    `json:"-"`
	Dispname     string    `json:"dispname"`
	Phone        string    `json:"phone"`
	Email        string    `json:"email"`
	Im           string    `json:"im"`
	Portrait     string    `json:"portrait"`
	Intro        string    `json:"intro"`
	Organization string    `json:"organization"`
	Type         int       `json:"type" xorm:"'typ'" description:"0: long-term account; 1: temporary account"`
	Status       int       `json:"status" description:"0: active, 1: inactive, 2: locked, 3: frozen, 4: writen-off"`
	IsRoot       int       `json:"is_root"`
	LeaderId     int64     `json:"leader_id"`
	LeaderName   string    `json:"leader_name"`
	LoginErrNum  int       `json:"login_err_num"`
	ActiveBegin  int64     `json:"active_begin" description:"for temporary account"`
	ActiveEnd    int64     `json:"active_end" description:"for temporary account"`
	LockedAt     int64     `json:"locked_at" description:"locked time"`
	UpdatedAt    int64     `json:"updated_at" description:"user info change time"`
	PwdUpdatedAt int64     `json:"pwd_updated_at" description:"password change time"`
	PwdExpiresAt int64     `xorm:"-" json:"pwd_expires_at" description:"password expires time"`
	LoggedAt     int64     `json:"logged_at" description:"last logged time"`
	CreateAt     time.Time `json:"create_at" xorm:"<-"`
}

func AllUsers ¶ added in v4.0.2

func AllUsers() ([]User, error)

func EmailCodeLogin ¶

func EmailCodeLogin(email, code string) (*User, error)

func LdapLogin ¶

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

func PassLogin ¶

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

func SessionGetUserWithCache ¶

func SessionGetUserWithCache(sid string) (*User, error)

func SmsCodeLogin ¶

func SmsCodeLogin(phone, code string) (*User, error)

func TeamMembers ¶

func TeamMembers(tid int64, isAdmin int) ([]User, error)

func UserAndTotalGets ¶

func UserAndTotalGets(query, org string, conditions string, limit, offset int, ids []int64) ([]User, int64, error)

func UserGet ¶

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

func UserGetByIds ¶

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

func UserGetByNames ¶

func UserGetByNames(names []string) ([]User, error)

func UserGetByUUIDs ¶

func UserGetByUUIDs(uuids []string) ([]User, error)

func UserGets ¶

func UserGets(ids []int64, limit, offset int, where string, args ...interface{}) ([]User, error)

func UserGetsByIds ¶

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

func UserMustGet ¶

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

func UserSearchListInIds ¶

func UserSearchListInIds(ids []int64, query string, limit, offset int) ([]User, error)

func UsersGet ¶

func UsersGet(where string, args ...interface{}) ([]User, error)

func UsersGetByGlobalRoleIds ¶

func UsersGetByGlobalRoleIds(ids []int64) (users []User, err error)

UsersGetByGlobalRoleIds 使用方：工单

func (*User) CanModifyTeam ¶

func (u *User) CanModifyTeam(t *Team) (bool, error)

func (*User) CheckPermByNode ¶

func (u *User) CheckPermByNode(node *Node, operation string)

func (*User) CheckPermGlobal ¶

func (u *User) CheckPermGlobal(operation string)

func (*User) CopyLdapAttr ¶

func (u *User) CopyLdapAttr(sr *ldap.SearchResult)

func (*User) Del ¶

func (u *User) Del() error

func (*User) HasPermByNode ¶

func (u *User) HasPermByNode(node *Node, operation string) (bool, error)

func (*User) HasPermGlobal ¶

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

func (*User) IsRooter ¶

func (u *User) IsRooter() bool

func (*User) NopriResIdents ¶

func (u *User) NopriResIdents(resIds []int64, op string) ([]string, error)

NopriResIdents 我没有权限的资源ident列表

func (*User) PermByNode ¶

func (u *User) PermByNode(node *Node, localOpsList []string) ([]string, error)

func (*User) PermResIds ¶

func (u *User) PermResIds(operation string) ([]int64, error)

PermResIds 我在某些节点是管理员，或者我在某些节点有此权限点，获取下面的叶子节点挂载的资源列表

func (*User) Save ¶

func (u *User) Save() error

func (*User) Update ¶

func (u *User) Update(cols ...string) error

func (*User) Validate ¶

func (u *User) Validate() error

type UserToken ¶

type UserToken struct {
	UserId   int64  `json:"user_id"`
	Username string `json:"username"`
	Token    string `json:"token"`
}

func UserTokenGet ¶

func UserTokenGet(where string, args ...interface{}) (*UserToken, error)

func UserTokenGets ¶

func UserTokenGets(where string, args ...interface{}) ([]UserToken, error)

func UserTokenNew ¶

func UserTokenNew(userId int64, username string) (*UserToken, error)

func UserTokenReset ¶

func UserTokenReset(userId int64, token string) (*UserToken, error)

type WalkParams ¶

type WalkParams struct {
	Version        int           `yaml:"version,omitempty"`
	MaxRepetitions uint8         `yaml:"max_repetitions,omitempty"`
	Retries        int           `yaml:"retries,omitempty"`
	Timeout        time.Duration `yaml:"timeout,omitempty"`
	Auth           Auth          `yaml:"auth,omitempty"`
}

type WhiteList ¶

type WhiteList struct {
	Id         int64  `json:"id"`
	StartIp    string `json:"startIp"`
	StartIpInt int64  `json:"-"`
	EndIp      string `json:"endIp"`
	EndIpInt   int64  `json:"-"`
	StartTime  int64  `json:"startTime"`
	EndTime    int64  `json:"endTime"`
	CreatedAt  int64  `json:"createdAt"`
	UpdatedAt  int64  `json:"updateAt"`
	Creator    string `json:"creator"`
	Updater    string `json:"updater"`
}

func WhiteListGet ¶

func WhiteListGet(where string, args ...interface{}) (*WhiteList, error)

func WhiteListGets ¶

func WhiteListGets(query string, limit, offset int) ([]WhiteList, error)

func (*WhiteList) Del ¶

func (p *WhiteList) Del() error

func (*WhiteList) Save ¶

func (p *WhiteList) Save() error

func (*WhiteList) Update ¶

func (p *WhiteList) Update(cols ...string) error

func (*WhiteList) Validate ¶

func (p *WhiteList) Validate() error

Source Files ¶

View all Source files

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