rdb

Documentation

Index

• Variables
• func BuildCacheOfPingList(agentID int32, checkedTime time.Time) *model.PingListLog
• func DiagnoseRdb(dsn string, db *sql.DB) *model.Rdb
• func FalconAgentHeartbeat(agents []*cModel.FalconAgentHeartbeat, updateOnly bool) *cModel.FalconAgentHeartbeatResult
• func GetPingListFromCache(agentID int32, checkedTime time.Time) ([]*nqmModel.HeartbeatTarget, *model.PingListLog)
• func InitRdb(dbConfig *commonDb.DbConfig)
• func InsertNqmAgentByHeartbeat(r *nqmModel.HeartbeatRequest) *nqmModel.Agent
• func ListHosts(paging commonModel.Paging) ([]*model.HostsResult, *commonModel.Paging)
• func ReleaseRdb()
• func SelectNqmAgentByConnId(connId string) *nqmModel.Agent
• func UpdateNqmAgentHeartbeat(reqs []*nqmModel.HeartbeatRequest)

Variables

var DbConfig *commonDb.DbConfig = &commonDb.DbConfig{}

var DbFacade = &f.DbFacade{}

Functions

func BuildCacheOfPingList

func BuildCacheOfPingList(agentID int32, checkedTime time.Time) *model.PingListLog

1. Update(or INSERT) the refresh time 2. Re-build the list of targets

func DiagnoseRdb

func DiagnoseRdb(dsn string, db *sql.DB) *model.Rdb

Performs the diagnosis to RDB

func FalconAgentHeartbeat

func FalconAgentHeartbeat(agents []*cModel.FalconAgentHeartbeat, updateOnly bool) *cModel.FalconAgentHeartbeatResult

func GetPingListFromCache

func GetPingListFromCache(agentID int32, checkedTime time.Time) ([]*nqmModel.HeartbeatTarget, *model.PingListLog)

Gets the ping list from cache

func InitRdb

func InitRdb(dbConfig *commonDb.DbConfig)

func InsertNqmAgentByHeartbeat

func InsertNqmAgentByHeartbeat(r *nqmModel.HeartbeatRequest) *nqmModel.Agent

func ListHosts

func ListHosts(paging commonModel.Paging) ([]*model.HostsResult, *commonModel.Paging)

ListHosts returns the info of hosts by host ID

func ReleaseRdb

func ReleaseRdb()

func SelectNqmAgentByConnId

func SelectNqmAgentByConnId(connId string) *nqmModel.Agent

func UpdateNqmAgentHeartbeat

func UpdateNqmAgentHeartbeat(reqs []*nqmModel.HeartbeatRequest)