forked from Cepave/open-falcon-backend
/
send_queues.go
38 lines (31 loc) · 992 Bytes
/
send_queues.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
package sender
import (
"github.com/Cepave/open-falcon-backend/modules/transfer/g"
nlist "github.com/toolkits/container/list"
)
func initSendQueues() {
cfg := g.Config()
for node := range cfg.Judge.Cluster {
Q := nlist.NewSafeListLimited(DefaultSendQueueMaxSize)
JudgeQueues[node] = Q
}
for node, nitem := range cfg.Graph.ClusterList {
for _, addr := range nitem.Addrs {
Q := nlist.NewSafeListLimited(DefaultSendQueueMaxSize)
GraphQueues[node+addr] = Q
}
}
if cfg.Tsdb.Enabled {
TsdbQueue = nlist.NewSafeListLimited(DefaultSendQueueMaxSize)
}
Q := nlist.NewSafeListLimited(DefaultSendQueueMaxSize)
InfluxdbQueues["default"] = Q
if cfg.NqmRest.Enabled {
NqmIcmpQueue = nlist.NewSafeListLimited(DefaultSendQueueMaxSize)
NqmTcpQueue = nlist.NewSafeListLimited(DefaultSendQueueMaxSize)
NqmTcpconnQueue = nlist.NewSafeListLimited(DefaultSendQueueMaxSize)
}
if cfg.Staging.Enabled {
StagingQueue = nlist.NewSafeListLimited(DefaultSendQueueMaxSize)
}
}