Documentation
¶
Overview ¶
Package netlinkerstater is the stats go routine for the xtcp system
Basically, this go routine recieves stats over the channel and updates Prometheus and statsd stats
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NetlinkerStater ¶
func NetlinkerStater(in <-chan NetlinkerStatsWrapper, cliFlags cliflags.CliFlags)
NetlinkerStater is responsible for incrementing prometheus stats and optionally statsd about the netlink workers netlinkerStater recieves summary stats from each netlinker worker just as it completes Reminder that the netlinker complettes when all packets have been processed, and the process has reached DONE or timeout
Types ¶
type NetlinkerStats ¶
type NetlinkerStats struct {
PacketsProcessed int
NastyContinue int
PacketBufferInSizeTotal int
NetlinkMsgCountTotal int
PacketBufferBytesReadTotal int
InetdiagMsgCopyBytesTotal int
NetlinkMsgErrorCount int
OutBlocked int
LongestBlockedDuration time.Duration
}
NetlinkerStats struct are the actual interesting data from each of the Netlinkers
type NetlinkerStatsWrapper ¶
type NetlinkerStatsWrapper struct {
Af uint8
ID int
Stats NetlinkerStats
}
NetlinkerStatsWrapper struct passes interesting data from the netlinker to the NetlinkerStater The wrapper has the af, id, and stats
Source Files
Click to show internal directories.
Click to hide internal directories.