代码拉取完成,页面将自动刷新
package stat
import (
"reflect"
"github.com/elastic/beats/libbeat/common"
s "github.com/elastic/beats/libbeat/common/schema"
c "github.com/elastic/beats/libbeat/common/schema/mapstrstr"
"github.com/elastic/beats/metricbeat/module/haproxy"
)
var (
schema = s.Schema{
"status": c.Str("Status"),
"weight": c.Int("Weight", s.Optional),
"downtime": c.Int("Downtime", s.Optional),
"component_type": c.Int("Type"),
"process_id": c.Int("Pid"),
"service_name": c.Str("SvName"),
"in.bytes": c.Int("Bin"),
"out.bytes": c.Int("Bout"),
"last_change": c.Int("Lastchg", s.Optional),
"throttle.pct": c.Int("Throttle", s.Optional),
"selected.total": c.Int("Lbtot", s.Optional),
"tracked.id": c.Int("Tracked", s.Optional),
"connection": s.Object{
"total": c.Int("Stot"),
"retried": c.Int("Wretr", s.Optional),
"time.avg": c.Int("Ctime", s.Optional),
},
"request": s.Object{
"denied": c.Int("Dreq", s.Optional),
"queued.current": c.Int("Qcur", s.Optional),
"queued.max": c.Int("Qmax", s.Optional),
"errors": c.Int("Ereq", s.Optional),
"redispatched": c.Int("Wredis", s.Optional),
"connection.errors": c.Int("Econ", s.Optional),
"rate": s.Object{
"value": c.Int("ReqRate", s.Optional),
"max": c.Int("ReqRateMax", s.Optional),
},
"total": c.Int("ReqTot", s.Optional),
},
"response": s.Object{
"errors": c.Int("Eresp", s.Optional),
"time.avg": c.Int("Rtime", s.Optional),
"denied": c.Int("Dresp"),
"http": s.Object{
"1xx": c.Int("Hrsp1xx", s.Optional),
"2xx": c.Int("Hrsp2xx", s.Optional),
"3xx": c.Int("Hrsp3xx", s.Optional),
"4xx": c.Int("Hrsp4xx", s.Optional),
"5xx": c.Int("Hrsp5xx", s.Optional),
"other": c.Int("HrspOther", s.Optional),
},
},
"session": s.Object{
"current": c.Int("Scur"),
"max": c.Int("Smax"),
"limit": c.Int("Slim", s.Optional),
"rate": s.Object{
"value": c.Int("Rate", s.Optional),
"limit": c.Int("RateLim", s.Optional),
"max": c.Int("RateMax", s.Optional),
},
},
"check": s.Object{
"status": c.Str("CheckStatus"),
"code": c.Int("CheckCode", s.Optional),
"duration": c.Int("CheckDuration", s.Optional),
"health.last": c.Str("LastChk"),
"health.fail": c.Int("Hanafail", s.Optional),
"agent.last": c.Str("LastAgt"),
"failed": c.Int("ChkFail", s.Optional),
"down": c.Int("ChkDown", s.Optional),
},
"client.aborted": c.Int("CliAbrt", s.Optional),
"server": s.Object{
"id": c.Int("Sid"),
"aborted": c.Int("SrvAbrt", s.Optional),
"active": c.Int("Act", s.Optional),
"backup": c.Int("Bck", s.Optional),
},
"compressor": s.Object{
"in.bytes": c.Int("CompIn", s.Optional),
"out.bytes": c.Int("CompOut", s.Optional),
"bypassed.bytes": c.Int("CompByp", s.Optional),
"response.bytes": c.Int("CompRsp", s.Optional),
},
"proxy": s.Object{
"id": c.Int("Iid"),
"name": c.Str("PxName"),
},
"queue": s.Object{
"time.avg": c.Int("Qtime", s.Optional),
"limit": c.Int("Qlimit", s.Optional),
},
}
)
// Map data to MapStr.
func eventMapping(info []*haproxy.Stat) []common.MapStr {
var events []common.MapStr
for _, evt := range info {
st := reflect.ValueOf(evt).Elem()
typeOfT := st.Type()
source := map[string]interface{}{}
for i := 0; i < st.NumField(); i++ {
f := st.Field(i)
source[typeOfT.Field(i).Name] = f.Interface()
}
data, _ := schema.Apply(source)
events = append(events, data)
}
return events
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。