Skip to content

Commit c98bf71

Browse files
committed
mon: add pind_procs_count metric
1 parent 0732da7 commit c98bf71

File tree

2 files changed

+17
-6
lines changed

2 files changed

+17
-6
lines changed

docs/prometheus.md

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,9 @@ pind_pool_idle_load0{instance="micronode15:9091", job="pind"}
3030

3131
`pind_pool_load_used1` - тоже самое, что и `pind_pool_load_used0` только максимум 100%.
3232

33+
`pind_procs_count` - число процессов (число виртуальных мащин), состояние которых отслеживает
34+
pind и делает привзку к ядрам
35+
3336
### Метрики NUMA node
3437

3538
`pind_node_load_free0` - загрузка свободных ядер выделенных под нагрузку (под привязку) определённой NUMA ноды.

pkg/monitoring/collector/static.go

Lines changed: 14 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -15,12 +15,13 @@ type Static struct {
1515
}
1616

1717
type Pool struct {
18-
IdleLoad0 *prometheus.Desc
19-
IdleLoad1 *prometheus.Desc
20-
LoadFree0 *prometheus.Desc
21-
LoadFree1 *prometheus.Desc
22-
LoadUsed0 *prometheus.Desc
23-
LoadUsed1 *prometheus.Desc
18+
IdleLoad0 *prometheus.Desc
19+
IdleLoad1 *prometheus.Desc
20+
LoadFree0 *prometheus.Desc
21+
LoadFree1 *prometheus.Desc
22+
LoadUsed0 *prometheus.Desc
23+
LoadUsed1 *prometheus.Desc
24+
ProcsCount *prometheus.Desc
2425

2526
Nodes []*PoolNode
2627
}
@@ -62,6 +63,10 @@ func NewPool(nodesCount int) *Pool {
6263
"used cores load, like 0-100 %",
6364
nil, nil,
6465
)
66+
ent.ProcsCount = prometheus.NewDesc("pind_procs_count",
67+
"process counter",
68+
nil, nil,
69+
)
6570

6671
for i := 0; i < nodesCount; i++ {
6772
node := &PoolNode{
@@ -137,6 +142,7 @@ func (x *Static) Collect(ch chan<- prometheus.Metric) {
137142
m3 := prometheus.MustNewConstMetric(x.PoolCollector.LoadFree1, prometheus.GaugeValue, x.State.Pool.LoadFree1)
138143
m4 := prometheus.MustNewConstMetric(x.PoolCollector.LoadUsed0, prometheus.GaugeValue, x.State.Pool.LoadUsed0)
139144
m5 := prometheus.MustNewConstMetric(x.PoolCollector.LoadUsed1, prometheus.GaugeValue, x.State.Pool.LoadUsed1)
145+
m6 := prometheus.MustNewConstMetric(x.PoolCollector.ProcsCount, prometheus.GaugeValue, float64(len(x.State.Procs)))
140146

141147
t0 := x.State.Time
142148
mt0 := prometheus.NewMetricWithTimestamp(t0, m0)
@@ -145,13 +151,15 @@ func (x *Static) Collect(ch chan<- prometheus.Metric) {
145151
mt3 := prometheus.NewMetricWithTimestamp(t0, m3)
146152
mt4 := prometheus.NewMetricWithTimestamp(t0, m4)
147153
mt5 := prometheus.NewMetricWithTimestamp(t0, m5)
154+
mt6 := prometheus.NewMetricWithTimestamp(t0, m6)
148155

149156
ch <- mt0
150157
ch <- mt1
151158
ch <- mt2
152159
ch <- mt3
153160
ch <- mt4
154161
ch <- mt5
162+
ch <- mt6
155163

156164
l0 := len(x.PoolCollector.Nodes)
157165
for i := 0; i < l0; i++ {

0 commit comments

Comments
 (0)