-
Notifications
You must be signed in to change notification settings - Fork 6
/
term-output.go
109 lines (94 loc) · 3.37 KB
/
term-output.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
package main
import (
"fmt"
"time"
tm "github.com/buger/goterm"
)
var screenTemplate = `
Welcome to Firehose Analyzer - %s
Selected duration=%s and offset=%s
Job Instance-Counts CPU-User CPU-Sys CPU-Wait Memory
----------------------------------------------------------------------------------------
Traffic Controller %3d %5.2f %5.2f %5.2f %5.2f
Doppler %3d %5.2f %5.2f %5.2f %5.2f
Drain Information:
Syslog Agent drain bindings : %.0f
Syslog Agent Active Drains : %.0f
Syslog Agent Invalid Drains : %.0f
Syslog Agent Non-App Drains : %.0f
Syslog Agent Blacklisted Drains : %.0f
Doppler Ingress Max Dropped : %.0f
Doppler Message Rate Capcity : ` + tm.Color("%.2f", tm.YELLOW) + `
%s
%s
`
func updateTerm(lcc *LCC) {
lcc.Lock()
defer lcc.Unlock()
tm.Clear()
tm.MoveCursor(1, 1)
// check for errors and populate error string
var collectionErrors string
if len(lcc.CollectionErrors) > 0 {
collectionErrors = "Errors Found during Collection (Max 3 Errors displayed):\n"
var maxErrors int
if len(lcc.CollectionErrors) > 3 {
maxErrors = 3
} else {
maxErrors = len(lcc.CollectionErrors)
}
for i := 0; i < maxErrors; i++ {
collectionErrors += fmt.Sprintf("%s\n", lcc.CollectionErrors[i].Error())
}
}
envStats := "Job\t\tSubscriptions\tIngress/s\tEgress/s\tDropped/s\tLoss\n"
envStats += "----------------------------------------------------------------------------------------\n"
envStats += fmt.Sprintf("Doppler\t\t%.0f\t\t%.0f\t\t%.0f\t\t%.0f\t\t%.2f\n", lcc.Metric.Doppler.Subscriptions,
lcc.Metric.Doppler.Ingress,
lcc.Metric.Doppler.Egress,
lcc.Metric.Doppler.Dropped,
float64(lcc.Metric.Doppler.Dropped)/float64(lcc.Metric.Doppler.Ingress))
envStats += fmt.Sprintf("Metron\t\tN/A\t\t%.0f\t\t%.0f\t\t%.0f\t\t%.2f\n", lcc.Metric.Metron.Ingress,
lcc.Metric.Metron.Egress,
lcc.Metric.Metron.Dropped,
float64(lcc.Metric.Metron.Dropped)/float64(lcc.Metric.Metron.Ingress))
envStats += fmt.Sprintf("RLP\t\tN/A\t\t%.0f\t\t%.0f\t\t%.0f\t\t%.2f\n", lcc.Metric.RLP.Ingress,
lcc.Metric.RLP.Egress,
lcc.Metric.RLP.Dropped,
float64(lcc.Metric.RLP.Dropped)/float64(lcc.Metric.RLP.Ingress))
envStats += fmt.Sprintf("Syslog Agent\tN/A\t\t%.0f\t\t%.0f\t\t%.0f\t\t%.2f\n", lcc.Metric.Drain.AgentIngress,
lcc.Metric.Drain.AgentEgress,
lcc.Metric.Drain.AgentDropped,
float64(lcc.Metric.Drain.AgentDropped)/float64(lcc.Metric.Drain.AgentIngress)) // syslog agent loss rate
tm.Printf(screenTemplate,
time.Now().Format(time.UnixDate),
*sampleDuration,
*sampleOffset,
lcc.Metric.TC.System.Count,
lcc.Metric.TC.System.CPUUser,
lcc.Metric.TC.System.CPUSys,
lcc.Metric.TC.System.CPUWait,
lcc.Metric.TC.System.Memory,
lcc.Metric.Doppler.System.Count,
lcc.Metric.Doppler.System.CPUUser,
lcc.Metric.Doppler.System.CPUSys,
lcc.Metric.Doppler.System.CPUWait,
lcc.Metric.Doppler.System.Memory,
lcc.Metric.Drain.AgentBindings,
lcc.Metric.Drain.AgentActiveDrains,
lcc.Metric.Drain.AgentInvalidDrains,
lcc.Metric.Drain.AgentNonAppDrains,
lcc.Metric.Drain.AgentBlacklistedDrains,
lcc.Metric.Doppler.IngressDropped,
lcc.Metric.Doppler.MessageRateCapacity,
envStats,
collectionErrors)
//tm.Printf("%v\n", mc)
tm.Flush()
}
func loopTerm(lcc *LCC) {
for {
time.Sleep(5 * time.Second)
updateTerm(lcc)
}
}