|
|
@@ -392,6 +392,7 @@ func (c *Container) Collect(ch chan<- prometheus.Metric) {
|
|
|
targetAppId := apps[d.dst.String()]
|
|
|
ch <- counter(metrics.NetConnectionsSuccessful, float64(stats.Count), strInstanceID, strAppId, targetAppId, strAppName, stats.Src.String(), d.src.String(), d.dst.String())
|
|
|
ch <- counter(metrics.NetConnectionsTotalTime, stats.TotalTime.Seconds(), strInstanceID, strAppId, targetAppId, strAppName, stats.Src.String(), d.src.String(), d.dst.String())
|
|
|
+ stats.Count = 0
|
|
|
// if stats.Retransmissions > 0 {
|
|
|
// ch <- counter(metrics.NetRetransmits, float64(stats.Retransmissions), strInstanceID, strAppId, targetAppId, strAppName, stats.Src.String(), d.src.String(), d.dst.String())
|
|
|
// }
|
|
|
@@ -423,6 +424,7 @@ func (c *Container) Collect(ch chan<- prometheus.Metric) {
|
|
|
for addrPair, count := range c.connectsFailed {
|
|
|
targetAppId := apps[addrPair.dst.String()]
|
|
|
ch <- counter(metrics.NetConnectionsFailed, float64(count), strInstanceID, strAppId, targetAppId, strAppName, addrPair.src.String(), addrPair.dst.String())
|
|
|
+ c.connectsFailed[addrPair] = 0
|
|
|
}
|
|
|
|
|
|
connections := map[AddrPair]int{}
|