Skip to content

Commit a17abd4

Browse files
author
Tobias Schwab
committedJul 5, 2014
remove reflection functins (Keys())
1 parent 80c5e31 commit a17abd4

21 files changed

+39
-373
lines changed
 

‎cpu.go

-17
Original file line numberDiff line numberDiff line change
@@ -39,23 +39,6 @@ func (*Cpu) Prefix() string {
3939
return "cpu"
4040
}
4141

42-
func (*Cpu) Keys() []string {
43-
return []string{
44-
"Ctxt",
45-
"Btime",
46-
"Processes",
47-
"ProcsRunning",
48-
"ProcsBlocked",
49-
"User",
50-
"Nice",
51-
"System",
52-
"Idle",
53-
"IOWait",
54-
"IRC",
55-
"SoftIRQ",
56-
}
57-
}
58-
5942
func ProcRoot() string {
6043
return os.Getenv("PROC_ROOT")
6144
}

‎df.go

-13
Original file line numberDiff line numberDiff line change
@@ -31,19 +31,6 @@ var dfFlgaMapping = map[string]string{
3131
INODE: "-i",
3232
}
3333

34-
func (self *Df) Keys() []string {
35-
return []string{
36-
SPACE + ".Total",
37-
SPACE + ".Used",
38-
SPACE + ".Available",
39-
SPACE + ".Use",
40-
INODE + ".Total",
41-
INODE + ".Used",
42-
INODE + ".Available",
43-
INODE + ".Use",
44-
}
45-
}
46-
4734
func CollectDf(t string, raw []byte, c *MetricsCollection) (e error) {
4835
if len(raw) == 0 {
4936
if flag, ok := dfFlgaMapping[t]; ok {

‎disk.go

-16
Original file line numberDiff line numberDiff line change
@@ -29,22 +29,6 @@ var diskStatFields = map[int]string{
2929
type Disk struct {
3030
}
3131

32-
func (self *Disk) Keys() []string {
33-
return []string{
34-
"ReadsCompleted",
35-
"ReadsMerged",
36-
"SectorsRead",
37-
"MillisecondsRead",
38-
"WritesCompleted",
39-
"WritesMerged",
40-
"SectorsWritten",
41-
"MillisecondsWritten",
42-
"IosInProgress",
43-
"MillisecondsIO",
44-
"WeightedMillisecondsIO",
45-
}
46-
}
47-
4832
func (self *Disk) Prefix() string {
4933
return "disk"
5034
}

‎elasticsearch.go

-25
Original file line numberDiff line numberDiff line change
@@ -19,31 +19,6 @@ func (es *ElasticSearch) Prefix() string {
1919
return "elasticsearch"
2020
}
2121

22-
func (es *ElasticSearch) Keys() []string {
23-
return []string{
24-
"shards.Total",
25-
"shards.Successful",
26-
"shards.Failed",
27-
"indices.index.SizeInBytes",
28-
"indices.index.PrimarySizeInBytes",
29-
"indices.translog.Operations",
30-
"indices.docs.NumDocs",
31-
"indices.docs.MaxDoc",
32-
"indices.docs.DeletedDocs",
33-
"indices.merges.Current",
34-
"indices.merges.CurrentDocs",
35-
"indices.merges.CurrentSizeInBytes",
36-
"indices.merges.Total",
37-
"indices.merges.TotalTimeInMillis",
38-
"indices.merges.TotalDocs",
39-
"indices.merges.TotalSizeInBytes",
40-
"indices.refresh.Total",
41-
"indices.refresh.TotalTimeInMillis",
42-
"indices.flush.Total",
43-
"indices.flush.TotalTimeInMillis",
44-
}
45-
}
46-
4722
func (es *ElasticSearch) Collect(c *MetricsCollection) (e error) {
4823
b, e := es.ReadStatus()
4924
if e != nil {

‎files.go

-4
Original file line numberDiff line numberDiff line change
@@ -53,10 +53,6 @@ func (f *Files) Collect(col *MetricsCollection) error {
5353
return nil
5454
}
5555

56-
func (f *Files) Keys() []string {
57-
return []string{FILES_OPEN}
58-
}
59-
6056
func (f *Files) Prefix() string {
6157
return FILES
6258
}

‎files_test.go

-1
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,6 @@ func TestFiles(t *testing.T) {
1111
files := &Files{RawStatus: readFile("fixtures/lsof.txt")}
1212

1313
So(files.Prefix(), ShouldEqual, "files")
14-
So(len(files.Keys()), ShouldNotEqual, 0)
1514

1615
mh := new(MetricHandler)
1716
stats, _ := mh.Collect(files)

‎free.go

-13
Original file line numberDiff line numberDiff line change
@@ -66,16 +66,3 @@ func (free *Free) Collect(c *MetricsCollection) error {
6666
func (free *Free) Prefix() string {
6767
return "free"
6868
}
69-
70-
func (free *Free) Keys() []string {
71-
return []string{
72-
FREE_MEM_TOTAL,
73-
FREE_MEM_USED,
74-
FREE_MEM_FREE,
75-
FREE_MEM_BUFFERS,
76-
FREE_MEM_CACHED,
77-
FREE_SWAP_TOTAL,
78-
FREE_SWAP_USED,
79-
FREE_SWAP_FREE,
80-
}
81-
}

‎loadavg.go

-8
Original file line numberDiff line numberDiff line change
@@ -14,14 +14,6 @@ func init() {
1414
type LoadAvg struct {
1515
}
1616

17-
func (l *LoadAvg) Keys() []string {
18-
return []string{
19-
"Load1m",
20-
"Load5m",
21-
"Load15m",
22-
}
23-
}
24-
2517
func (l *LoadAvg) Prefix() string {
2618
return "load"
2719
}

‎main.go

+1-15
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,6 @@
11
package main
22

3-
import (
4-
"fmt"
5-
"os"
6-
)
3+
import "os"
74

85
type Config struct {
96
OpenTSDBUrl string `json:"opentsdb_url"`
@@ -82,17 +79,6 @@ func main() {
8279
os.Exit(0)
8380
}
8481

85-
if parser.Get(KEYS) == "true" {
86-
for k, _ := range parser.Values {
87-
if col, ok := collectors[k]; ok {
88-
for _, m := range mh.Keys(col) {
89-
fmt.Println(m)
90-
}
91-
}
92-
}
93-
return
94-
}
95-
9682
for key, _ := range parser.Values {
9783
if collector, ok := collectors[key]; ok {
9884
if e := processCollector(mh, output, collector); e != nil {

‎memory.go

-10
Original file line numberDiff line numberDiff line change
@@ -18,16 +18,6 @@ func (m *Memory) Prefix() string {
1818
return "memory"
1919
}
2020

21-
func (m *Memory) Keys() []string {
22-
return []string{
23-
"MemTotal", "MemFree", "Buffers", "Cached", "SwapCached", "Active", "Inactive", "Active(anon)", "Inactive(anon)", "Active(file)",
24-
"Inactive(file)", "Unevictable", "Mlocked", "SwapTotal", "SwapFree", "Dirty", "Writeback", "AnonPages", "Mapped", "Shmem",
25-
"Slab", "SReclaimable", "SUnreclaim", "KernelStack", "PageTables", "NFS_Unstable", "Bounce", "WritebackTmp", "CommitLimit",
26-
"Committed_AS", "VmallocTotal", "VmallocUsed", "VmallocChunk", "HardwareCorrupted", "AnonHugePages", "HugePages_Total",
27-
"HugePages_Free", "HugePages_Rsvd", "HugePages_Surp", "Hugepagesize", "DirectMap4k", "DirectMap2M",
28-
}
29-
}
30-
3121
func (memory *Memory) Collect(c *MetricsCollection) (e error) {
3222
s := ReadProcFile("meminfo")
3323
re := regexp.MustCompile("(.*?)\\:\\s+(\\d+)")

‎metric_handler.go

+3-15
Original file line numberDiff line numberDiff line change
@@ -4,24 +4,12 @@ type MetricHandler struct {
44
}
55

66
type MetricCollector interface {
7-
Keys() []string
87
Prefix() string
98
Collect(*MetricsCollection) error
109
}
1110

12-
func (h *MetricHandler) Collect(c MetricCollector) (all []*Metric, e error) {
11+
func (h *MetricHandler) Collect(c MetricCollector) (Metrics, error) {
1312
mc := &MetricsCollection{Prefix: c.Prefix()}
14-
mc.AddSingularMappings(c.Keys())
15-
if e = c.Collect(mc); e != nil {
16-
return
17-
}
18-
all = mc.Metrics
19-
return
20-
}
21-
22-
func (h *MetricHandler) Keys(c MetricCollector) (keys []string) {
23-
for _, m := range c.Keys() {
24-
keys = append(keys, c.Prefix()+"."+m)
25-
}
26-
return
13+
e := c.Collect(mc)
14+
return mc.Metrics, e
2715
}

‎metrics_collection.go

+4-10
Original file line numberDiff line numberDiff line change
@@ -1,14 +1,10 @@
11
package main
22

3-
import (
4-
"errors"
5-
"fmt"
6-
"strconv"
7-
)
3+
import "strconv"
84

95
type MetricsCollection struct {
106
Prefix string
11-
Metrics []*Metric
7+
Metrics Metrics
128
Mapping map[string]string
139
}
1410

@@ -31,11 +27,9 @@ func (m *MetricsCollection) AddMapping(from, to string) {
3127

3228
func (m *MetricsCollection) AddWithTags(key string, v int64, tags map[string]string) (e error) {
3329
if realKey, ok := m.Mapping[key]; ok {
34-
m.Metrics = append(m.Metrics, &Metric{Key: m.Prefix + "." + realKey, Value: v, Tags: tags})
35-
} else {
36-
e = errors.New("no mapping defined for " + key)
37-
fmt.Println("ERROR", e.Error())
30+
key = realKey
3831
}
32+
m.Metrics = append(m.Metrics, &Metric{Key: m.Prefix + "." + key, Value: v, Tags: tags})
3933
return
4034
}
4135

‎net.go

-26
Original file line numberDiff line numberDiff line change
@@ -85,29 +85,3 @@ func (self *Net) Collect(c *MetricsCollection) (e error) {
8585
}
8686
return
8787
}
88-
89-
func (self *Net) Keys() []string {
90-
return []string{
91-
"ip.TotalPacketsReceived",
92-
"ip.Forwarded",
93-
"ip.IncomingPacketsDiscarded",
94-
"ip.IncomingPacketsDelivered",
95-
"ip.RequestsSentOut",
96-
"tcp.ActiveConnectionsOpenings",
97-
"tcp.PassiveConnectionsOpenings",
98-
"tcp.FailedConnectionAttempts",
99-
"tcp.ConnectionResetsReceived",
100-
"tcp.ConnectionsEstablished",
101-
"tcp.SegmentsReceived",
102-
"tcp.SegmentsSendOut",
103-
"tcp.SegmentsTransmitted",
104-
"tcp.BadSegmentsReceived",
105-
"tcp.ResetsSent",
106-
"udp.PacketsReceived",
107-
"udp.PacketsToUnknownPortRecived",
108-
"udp.PacketReceiveErrors",
109-
"udp.PacketsSent",
110-
"ip.InOctets",
111-
"ip.OutOctets",
112-
}
113-
}

‎net_linux.go

+22-48
Original file line numberDiff line numberDiff line change
@@ -13,27 +13,27 @@ func init() {
1313
}
1414

1515
var mapStatMapping = map[string]string{
16-
"Ip.InReceives": "ip.TotalPacketsReceived",
17-
"Ip.ForwDatagrams": "ip.Forwarded",
18-
"Ip.InDiscards": "ip.IncomingPacketsDiscarded",
19-
"Ip.InDelivers": "ip.IncomingPacketsDelivered",
20-
"Ip.OutRequests": "ip.RequestsSentOut",
21-
"Tcp.ActiveOpens": "tcp.ActiveConnectionsOpenings",
22-
"Tcp.PassiveOpens": "tcp.PassiveConnectionsOpenings",
23-
"Tcp.AttemptFails": "tcp.FailedConnectionAttempts",
24-
"Tcp.EstabResets": "tcp.ConnectionResetsReceived",
25-
"Tcp.CurrEstab": "tcp.ConnectionsEstablished",
26-
"Tcp.InSegs": "tcp.SegmentsReceived",
27-
"Tcp.OutSegs": "tcp.SegmentsSendOut",
28-
"Tcp.RetransSegs": "tcp.SegmentsTransmitted",
29-
"Tcp.InErrs": "tcp.BadSegmentsReceived",
30-
"Tcp.OutRsts": "tcp.ResetsSent",
31-
"Udp.InDatagrams": "udp.PacketsReceived",
32-
"Udp.NoPorts.": "udp.PacketsToUnknownPortRecived",
33-
"Udp.InErrors": "udp.PacketReceiveErrors",
34-
"Udp.OutDatagrams": "udp.PacketsSent",
35-
"IpExt.InOctets": "ip.InOctets",
36-
"IpExt.OutOctets": "ip.OutOctets",
16+
"Ip.InReceives": "ip.TotalPacketsReceived",
17+
"Ip.ForwDatagrams": "ip.Forwarded",
18+
"Ip.InDiscards": "ip.IncomingPacketsDiscarded",
19+
"Ip.InDelivers": "ip.IncomingPacketsDelivered",
20+
"Ip.OutRequests": "ip.RequestsSentOut",
21+
"Tcp.ActiveOpens": "tcp.ActiveConnectionsOpenings",
22+
"Tcp.PassiveOpens": "tcp.PassiveConnectionsOpenings",
23+
"Tcp.AttemptFails": "tcp.FailedConnectionAttempts",
24+
"Tcp.EstabResets": "tcp.ConnectionResetsReceived",
25+
"Tcp.CurrEstab": "tcp.ConnectionsEstablished",
26+
"Tcp.InSegs": "tcp.SegmentsReceived",
27+
"Tcp.OutSegs": "tcp.SegmentsSendOut",
28+
"Tcp.RetransSegs": "tcp.SegmentsTransmitted",
29+
"Tcp.InErrs": "tcp.BadSegmentsReceived",
30+
"Tcp.OutRsts": "tcp.ResetsSent",
31+
"Udp.InDatagrams": "udp.PacketsReceived",
32+
"Udp.NoPorts.": "udp.PacketsToUnknownPortRecived",
33+
"Udp.InErrors": "udp.PacketReceiveErrors",
34+
"Udp.OutDatagrams": "udp.PacketsSent",
35+
"IpExt.InOctets": "ip.InOctets",
36+
"IpExt.OutOctets": "ip.OutOctets",
3737
}
3838

3939
type Net struct {
@@ -83,7 +83,7 @@ func (self *Net) collect2LineFile(c *MetricsCollection, name string) (e error) {
8383
}
8484
raw := string(b)
8585
lines := strings.Split(raw, "\n")
86-
for i := 0; i < len(lines) - 1; i+=2 {
86+
for i := 0; i < len(lines)-1; i += 2 {
8787
for k, v := range parse2lines(lines[i], lines[i+1]) {
8888
if mapped, ok := mapStatMapping[k]; ok {
8989
c.Add(mapped, v)
@@ -101,29 +101,3 @@ func (self *Net) Collect(c *MetricsCollection) error {
101101
}
102102
return nil
103103
}
104-
105-
func (self *Net) Keys() []string {
106-
return []string{
107-
"ip.TotalPacketsReceived",
108-
"ip.Forwarded",
109-
"ip.IncomingPacketsDiscarded",
110-
"ip.IncomingPacketsDelivered",
111-
"ip.RequestsSentOut",
112-
"tcp.ActiveConnectionsOpenings",
113-
"tcp.PassiveConnectionsOpenings",
114-
"tcp.FailedConnectionAttempts",
115-
"tcp.ConnectionResetsReceived",
116-
"tcp.ConnectionsEstablished",
117-
"tcp.SegmentsReceived",
118-
"tcp.SegmentsSendOut",
119-
"tcp.SegmentsTransmitted",
120-
"tcp.BadSegmentsReceived",
121-
"tcp.ResetsSent",
122-
"udp.PacketsReceived",
123-
"udp.PacketsToUnknownPortRecived",
124-
"udp.PacketReceiveErrors",
125-
"udp.PacketsSent",
126-
"ip.InOctets",
127-
"ip.OutOctets",
128-
}
129-
}

‎nginx.go

-12
Original file line numberDiff line numberDiff line change
@@ -104,18 +104,6 @@ func (self *Nginx) Prefix() string {
104104
return "nginx"
105105
}
106106

107-
func (self *Nginx) Keys() []string {
108-
return []string{
109-
"ActiveConnections",
110-
"Accepts",
111-
"Handled",
112-
"Requests",
113-
"Reading",
114-
"Writing",
115-
"Waiting",
116-
}
117-
}
118-
119107
func (nginx *Nginx) Collect(c *MetricsCollection) error {
120108
var e error
121109
if len(nginx.Raw) == 0 {

‎nginx_test.go

+6-8
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
package main
22

33
import (
4+
"sort"
45
"testing"
56

67
. "github.com/smartystreets/goconvey/convey"
@@ -13,19 +14,16 @@ func TestParseNginx(t *testing.T) {
1314
nginx := &Nginx{Raw: readFile("fixtures/nginx.status")}
1415

1516
all, e := mh.Collect(nginx)
17+
sort.Sort(all)
1618
So(e, ShouldBeNil)
1719

18-
for _, m := range all {
19-
t.Logf("%s: %v", m.Key, m.Value)
20-
}
21-
2220
So(len(all), ShouldEqual, 7)
2321

24-
So(all[0].Key, ShouldEqual, "nginx.ActiveConnections")
25-
So(all[0].Value, ShouldEqual, 10)
22+
So(all[1].Key, ShouldEqual, "nginx.ActiveConnections")
23+
So(all[1].Value, ShouldEqual, 10)
2624

27-
So(all[6].Key, ShouldEqual, "nginx.Waiting")
28-
So(all[6].Value, ShouldEqual, 70)
25+
So(all[5].Key, ShouldEqual, "nginx.Waiting")
26+
So(all[5].Value, ShouldEqual, 70)
2927

3028
})
3129
}

‎pgbouncer.go

-33
Original file line numberDiff line numberDiff line change
@@ -59,39 +59,6 @@ func (self *PgBouncer) Collect(c *MetricsCollection) (e error) {
5959
return
6060
}
6161

62-
func (self *PgBouncer) Keys() []string {
63-
return []string{
64-
"connections.Total",
65-
"memory.Free",
66-
"memory.MemTotal",
67-
"memory.Size",
68-
"memory.Used",
69-
"pools.ClientsActive",
70-
"pools.ClientsWaiting",
71-
"pools.MaxWait",
72-
"pools.ServersActive",
73-
"pools.ServersIdle",
74-
"pools.ServersLogin",
75-
"pools.ServersTested",
76-
"pools.ServersUsed",
77-
"sockets.PktAvail",
78-
"sockets.PktPos",
79-
"sockets.PktRemain",
80-
"sockets.RecvPos",
81-
"sockets.SendAvail",
82-
"sockets.SendPos",
83-
"sockets.SendRemain",
84-
"stats.AvgQuery",
85-
"stats.AvgRecv",
86-
"stats.AvgReq",
87-
"stats.AvgSent",
88-
"stats.TotalQueryTime",
89-
"stats.TotalReceived",
90-
"stats.TotalRequests",
91-
"stats.TotalSent",
92-
}
93-
}
94-
9562
func (self *PgBouncer) Prefix() string {
9663
return "pgbouncer"
9764
}

‎postgres.go

+2-12
Original file line numberDiff line numberDiff line change
@@ -4,11 +4,12 @@ import (
44
"database/sql"
55
"errors"
66
"fmt"
7-
_ "github.com/lib/pq"
87
"net/url"
98
"strconv"
109
"strings"
1110
"time"
11+
12+
_ "github.com/lib/pq"
1213
)
1314

1415
const POSTGRES = "postgres"
@@ -73,17 +74,6 @@ type PostgreSQLStats struct {
7374
*PostgresURL
7475
}
7576

76-
func (self *PostgreSQLStats) Keys() []string {
77-
return []string{
78-
"StatActivity", "tables.SeqScan", "tables.SeqTupRead", "tables.IdxScan", "tables.IdxTupFetch", "tables.NTupIns", "tables.NTupUpd", "tables.NTupDel",
79-
"tables.NTupHotUpd", "tables.NLiveTup", "tables.NDeadTup", "tables.VacuumCount", "tables.AutoVacuumAcount", "tables.AnalyzeCount",
80-
"tables.AutoAnalyzeCount", "databases.NumBackends", "databases.XactCommit", "databases.XactRollback", "databases.BlksRead", "databases.BlksHit",
81-
"databases.TupReturned", "databases.TupFetched", "databases.TupInserted", "databases.TupUpdated", "databases.TupDeleted", "databases.Conflicts",
82-
"databases.TempFiles", "databases.TempBytes", "databases.Deadlocks", "databases.BlkReadTime", "databases.BlkWriteTime", "indexes.IdxScan",
83-
"indexes.IdxTupRead", "indexes.IdxTupFetch",
84-
}
85-
}
86-
8777
func (self *PostgreSQLStats) Prefix() string {
8878
return "postgres"
8979
}

‎processes.go

+1-34
Original file line numberDiff line numberDiff line change
@@ -39,39 +39,6 @@ func (self *Processes) Prefix() string {
3939
return "processes"
4040
}
4141

42-
func (self *Processes) Keys() []string {
43-
return []string{
44-
"Pid",
45-
"Ppid",
46-
"Pgrp",
47-
"Session",
48-
"TtyNr",
49-
"Tpgid",
50-
"Flags",
51-
"Minflt",
52-
"Cminflt",
53-
"Majflt",
54-
"Cmajflt",
55-
"Utime",
56-
"Stime",
57-
"Cutime",
58-
"Sctime",
59-
"Priority",
60-
"Nice",
61-
"NumThreads",
62-
"Itrealvalue",
63-
"Starttime",
64-
"Vsize",
65-
"RSS",
66-
"RSSlim",
67-
"Startcode",
68-
"Endcode",
69-
"Startstac",
70-
"GuestTime",
71-
"CguestTime",
72-
}
73-
}
74-
7542
var matchBrackets = regexp.MustCompile("(^\\(|\\)$)")
7643

7744
func NormalizeProcessName(comm string) string {
@@ -82,7 +49,7 @@ func NormalizeProcessName(comm string) string {
8249
var matchNums = regexp.MustCompile("[0-9]+")
8350

8451
func generateProcfiles() (matches chan string, e error) {
85-
procmount := ProcRoot() + "/proc"
52+
procmount := ProcRoot() + "/proc"
8653
d, e := os.Open(procmount)
8754
if e != nil {
8855
return nil, e

‎redis.go

-28
Original file line numberDiff line numberDiff line change
@@ -21,34 +21,6 @@ func (self *Redis) Prefix() string {
2121
return "redis"
2222
}
2323

24-
func (self *Redis) Keys() []string {
25-
return []string{
26-
"UptimeInSeconds",
27-
"memory.UsedMemory",
28-
"memory.UsedMemoryRSS",
29-
"memory.UsedMemoryPeak",
30-
"memory.UsedMemoryLua",
31-
"clients.ConnectedClients",
32-
"clients.ClientLongestOutputList",
33-
"clients.ClientBiggestInputBuf",
34-
"clients.BlockedClients",
35-
"stats.TotalConnectionsReceived",
36-
"stats.TotalCommandsProcessed",
37-
"stats.InstantaneousOpsPerSec",
38-
"stats.RejectedConnections",
39-
"stats.ExpiredKeys",
40-
"stats.EvictedKeys",
41-
"stats.KeyspaceHits",
42-
"stats.KeyspaceMisses",
43-
"stats.PubsubChannels",
44-
"stats.PubsubPatterns",
45-
"stats.LatestForkUsec",
46-
"replication.ConnectedSlaves",
47-
"db.Keys",
48-
"db.Expires",
49-
}
50-
}
51-
5224
var logger = &Logger{Prefix: "redis"}
5325

5426
func (self *Redis) Collect(c *MetricsCollection) (e error) {

‎riak.go

-25
Original file line numberDiff line numberDiff line change
@@ -140,31 +140,6 @@ type RiakStatus struct {
140140
RingMembers []string `json:"ring_members"`
141141
}
142142

143-
func (self *Riak) Keys() []string {
144-
return []string{
145-
"VNodeGets", "VNodeGets", "VNodeGetsTotal", "VNodePuts", "VNodePutsTotal", "VNodeIndexReads", "VNodeIndexReadsTotal", "VNodeIndexWrites",
146-
"VNodeIndexWritesTotal", "VNodeIndexWritesPostings", "VNodeIndexWritesPostings_total", "VNodeIndexDeletes", "VNodeIndexDeletes_total",
147-
"VNodeIndexDeletes_postings", "VNodeIndexDeletes_postings_total", "NodeGets", "NodeGetsTotal", "NodeGet_fsm_siblings_mean", "NodegetFsmSiblingsMedian",
148-
"NodegetFsmSiblings95", "NodegetFsmSiblings99", "NodegetFsmSiblings100", "NodegetFsmObjsizeMean", "NodegetFsmObjsizeMedian", "NodegetFsmObjsize95",
149-
"NodegetFsmObjsize99", "NodegetFsmObjsize100", "NodegetFsmTimeMean", "NodegetFsmTimeMedian", "NodegetFsmTime95", "NodegetFsmTime99",
150-
"NodegetFsmTime100", "NodePuts", "NodePutsTotal", "NodePutFsmTimeMean", "NodePutFsmTimeMedian", "Node_put_fsm_time_95", "Node_put_fsm_time_99",
151-
"Node_put_fsm_time_100", "ReadRepairs", "ReadRepairsTotal", "CoordRedirsTotal", "ExecutingMappers", "PrecommitFail", "PostcommitFail", "PbcActive",
152-
"PbcConnects", "PbcConnectsTotal", "NodeGetFsmActive", "NodeGetFsmActive60s", "NodeGetFsmInRate", "NodeGetFsmOutRate", "NodeGetFsmRejected",
153-
"NodeGetFsmRejected60s", "NodeGetFsmRejectedTotal", "NodePutFsmActive", "NodePutFsmActive60s", "NodePutFsmInRate", "NodePutFsmOutRate",
154-
"NodePutFsmRejected", "NodePutFsmRejected60s", "NodePutFsmRejectedTotal", "ReadRepairsPrimaryOutofdateOne", "ReadRepairsPrimaryOutofdateCount",
155-
"ReadRepairsPrimaryNotfoundOne", "ReadRepairsPrimaryNotfoundCount", "ReadRepairsFallbackOutofdateOne", "ReadRepairsFallbackOutofdateCount",
156-
"ReadRepairsFallbackNotfoundOne", "ReadRepairsFallbackNotfoundCount", "PipelineActive", "PipelineCreateCount", "PipelineCreateOne",
157-
"PipelineCreateErrorCount", "PipelineCreateErrorOne", "CpuNprocs", "CpuAvg1", "CpuAvg5", "CpuAvg15", "MemTotal", "MemAllocated", "SysGlobalHeapsSize",
158-
"SysProcessCount", "SysThreadPoolSize", "SysWordsize", "RingNumPartitions", "RingCreationSize", "MemoryTotal", "MemoryProcesses",
159-
"MemoryProcessesUsed", "MemorySystem", "MemoryAtom", "MemoryAtomUsed", "MemoryBinary", "MemoryCode", "MemoryEts", "RiakCoreStatTs",
160-
"IgnoredGossipTotal", "RingsReconciledTotal", "RingsReconciled", "GossipReceived", "RejectedHandoffs", "HandoffTimeouts", "DroppedVnodeRequestsTotal",
161-
"ConvergeDelayMin", "ConvergeDelayMax", "ConvergeDelayMean", "ConvergeDelayLast", "RebalanceDelayMin", "RebalanceDelayMax", "RebalanceDelayMean",
162-
"RebalanceDelayLast", "RiakKvVnodesRunning", "RiakKvVnodeqMin", "RiakKvVnodeqMedian", "RiakKvVnodeqMean", "RiakKvVnodeqMax", "RiakKvVnodeqTotal",
163-
"RiakPipeVnodesRunning", "RiakPipeVnodeqMin", "RiakPipeVnodeqMedian", "RiakPipeVnodeqMean", "RiakPipeVnodeqMax", "RiakPipeVnodeqTotal",
164-
"ConnectedNodesCount", "RingMembersCount",
165-
}
166-
}
167-
168143
func (self *Riak) Prefix() string {
169144
return "riak"
170145
}

0 commit comments

Comments
 (0)
Please sign in to comment.