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
|
Index: golang-github-armon-go-metrics/statsite_test.go
===================================================================
--- golang-github-armon-go-metrics.orig/statsite_test.go
+++ golang-github-armon-go-metrics/statsite_test.go
@@ -1,10 +1,8 @@
package metrics
import (
- "bufio"
"net"
"testing"
- "time"
)
func acceptConn(addr string) net.Conn {
@@ -39,63 +37,3 @@ func TestStatsite_PushFullQueue(t *testi
default:
}
}
-
-func TestStatsite_Conn(t *testing.T) {
- addr := "localhost:7523"
- done := make(chan bool)
- go func() {
- conn := acceptConn(addr)
- reader := bufio.NewReader(conn)
-
- line, err := reader.ReadString('\n')
- if err != nil {
- t.Fatalf("unexpected err %s", err)
- }
- if line != "gauge.val:1.000000|g\n" {
- t.Fatalf("bad line %s", line)
- }
-
- line, err = reader.ReadString('\n')
- if err != nil {
- t.Fatalf("unexpected err %s", err)
- }
- if line != "key.other:2.000000|kv\n" {
- t.Fatalf("bad line %s", line)
- }
-
- line, err = reader.ReadString('\n')
- if err != nil {
- t.Fatalf("unexpected err %s", err)
- }
- if line != "counter.me:3.000000|c\n" {
- t.Fatalf("bad line %s", line)
- }
-
- line, err = reader.ReadString('\n')
- if err != nil {
- t.Fatalf("unexpected err %s", err)
- }
- if line != "sample.slow_thingy:4.000000|ms\n" {
- t.Fatalf("bad line %s", line)
- }
-
- conn.Close()
- done <- true
- }()
- s, err := NewStatsiteSink(addr)
- if err != nil {
- t.Fatalf("bad error")
- }
-
- s.SetGauge([]string{"gauge", "val"}, float32(1))
- s.EmitKey([]string{"key", "other"}, float32(2))
- s.IncrCounter([]string{"counter", "me"}, float32(3))
- s.AddSample([]string{"sample", "slow thingy"}, float32(4))
-
- select {
- case <-done:
- s.Shutdown()
- case <-time.After(3 * time.Second):
- t.Fatalf("timeout")
- }
-}
|
