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")
- }
-}
|