README
¶
// common key const ( STAT_IN = "MsgIn" STAT_OUT = "MsgOut" INDEGREE_Recive = "InDegree_Recive(MB)" INDEGREE_Send = "InDegree_Send(MB)" OUTDEGREE_Recive = "OutDegree_Recive(MB)" OUTDEGREE_Send = "OutDegree_Send(MB)"
)
// application key const ( StatRedisGet = "StatRedisGet" )
// base initialize logconfig := make(stat.LoggerParm) logconfig.level = "info" logconfig.path = "./stat" logconfig.namePrefix = "test" logconfig.filename = "stat.log" logconfig.maxfilesize = 10000 logconfig.maxdays = 7 logconfig.maxlines = 10000 logconfig.chanlen = 10000 stat.Init(logconfig, 60) stat.StatProc()
// application initialize stat.SetDelayUp(20,50,100)
// using method add stat data stat.Push(elem)
// exit must call stat.Exit()
Documentation
¶
Index ¶
- func Exit()
- func GetTopn(rawdata map[int]uint, topn int) (arraykeys []int)
- func Init(appName, fileName string)
- func PushStat(itemName string, procTime int, requestIP net.IP, payload int, retcode int)
- func SetDelayUp(delayUp uint, delayUp2 uint, delayUp3 uint)
- func StatProc()
- type Inter
- type Item
- type Mystat
- func (stat *Mystat) AddReportBodyColItem(itemName string)
- func (stat *Mystat) AddReportBodyRowItem(itemName string)
- func (stat *Mystat) AddReportErrorItem(itemName string)
- func (stat *Mystat) AddReportHeadItem(itemName string)
- func (stat *Mystat) AddReportIPError()
- func (stat *Mystat) AddReportTailItem(itemName string)
- func (stat *Mystat) ClearAll()
- func (stat *Mystat) GetStat(itemName string) uint
- func (stat *Mystat) GetStatValueByTab(itemName string, colName string) uint
- func (stat *Mystat) GetTimeout(itemName string) uint
- func (stat *Mystat) IncErrnoIP(ip net.IP, errno int, val uint)
- func (stat *Mystat) IncErrnoStat(errno int, val uint)
- func (stat *Mystat) IncErrnoStatByItem(itemName string, errno int, val uint)
- func (stat *Mystat) IncKey(itemName string)
- func (stat *Mystat) IncStat(itemName string, val uint)
- func (stat *Mystat) IncStatByTab(rowName string, colName string, val uint)
- func (stat *Mystat) IncTimeout(itemName string)
- func (stat *Mystat) NoCheckAndPrint()
- func (stat *Mystat) Print()
- func (stat *Mystat) PrintBody()
- func (stat *Mystat) PrintHeader()
- func (stat *Mystat) PrintIPError()
- func (stat *Mystat) PrintRowError()
- func (stat *Mystat) PrintTail()
- func (stat *Mystat) Reset()
- func (stat *Mystat) SetStat(itemName string, val uint)
- func (stat *Mystat) SetTimeOut(timeout uint)
- func (stat *Mystat) TimeStatGet(rowName string) (count uint, avgDelay, maxDelay float32, ...)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func SetDelayUp ¶
SetDelayUp 设置分段统计延时 初始化调用,线程不安全
Types ¶
type Inter ¶
type Inter interface {
AddReportHeadItem(itemName string)
AddReportBodyRowItem(itemName string)
AddReportBodyColItem(itemName string)
AddReportTailItem(itemName string)
AddReportErrorItem(itemName string)
AddReportIPError()
IncStat(itemName string, val uint)
IncKey(itemName string)
IncStatByTab(rowName string, colName string, val uint)
IncErrnoStat(errno int, val uint)
IncErrnoStatByItem(itemName string, errno int, val uint)
IncErrnoIP(ip uint, errno int, val uint)
SetStat(itemName string, val uint)
GetStat(itemName string) int
GetStatValueByTab(itemName string, colName string)
TimeStatGet(rowName string) (count uint, avgDelay float32, maxDelay float32, upDelay uint, upDelay2 uint, upDelay3 uint)
NoCheckAndPrint()
Print()
PrintHeader()
PrintBody()
PrintTail()
PrintRowError()
PrintIPError()
ClearAll()
Reset()
}
Inter 统计接口
type Item ¶
type Item struct {
Name string // 统计的接口名
Delay uint // 接口执行的延时,单位ms
Errcode int // 当次接口请求的错误码,0--成功`
Ipsrc net.IP // 请求的来源ip
Payload uint // 请求的载荷
Direction int // 上行or下行 1 ---- 上行 0 ----下行
InOrOut int // 入度还是出度 1 ---- in 0 ----out
}
Item 统一单元元素
type Mystat ¶
type Mystat struct {
IsClearFlag bool // 清除标记
// contains filtered or unexported fields
}
Mystat 监控统计对象
var GStat *Mystat
GStat 全局唯一统计对象
func (*Mystat) AddReportBodyColItem ¶
AddReportBodyColItem 添加监控报告主体列元素
func (*Mystat) AddReportBodyRowItem ¶
AddReportBodyRowItem 添加监控报告主体行元素
func (*Mystat) AddReportErrorItem ¶
AddReportErrorItem 添加监控报告错误元素
func (*Mystat) AddReportHeadItem ¶
AddReportHeadItem 添加监控报告头部元素
func (*Mystat) AddReportIPError ¶
func (stat *Mystat) AddReportIPError()
AddReportIPError 添加监控报告IP地址错误
func (*Mystat) AddReportTailItem ¶
AddReportTailItem 添加监控报告尾部元素
func (*Mystat) GetStatValueByTab ¶
GetStatValueByTab 获取列元素的值
func (*Mystat) GetTimeout ¶
GetTimeout 获取单位元素超时计数
func (*Mystat) IncErrnoIP ¶
IncErrnoIP 增加错误IP计数
func (*Mystat) IncErrnoStat ¶
IncErrnoStat 增加错误计数
func (*Mystat) IncErrnoStatByItem ¶
IncErrnoStatByItem 增加单位元素错误计数
func (*Mystat) IncStatByTab ¶
IncStatByTab 增加主体数据单位元素列统计
func (*Mystat) SetTimeOut ¶
SetTimeOut 设置客户端请求超时时间 初始化调用,线程不安全 和delayup参数意义相同, 起一个分段作用,只不过是最大分段
Source Files