Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

clientv3/integration: fix minor typos, consistent formatting

Browse Source
This commit is contained in:
Gyu-Ho Lee 2016-11-08 12:37:33 -08:00
parent 754daf918b
commit 2955d58776
No known key found for this signature in database
GPG Key ID: 1DDD39C7EB70C24C
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
clientv3/integration/metrics_test.go
View File

@ -52,7 +52,7 @@ func TestV3ClientMetrics(t *testing.T) {
ln, err = transport.NewUnixListener(addr) ln, err = transport.NewUnixListener(addr)
if err != nil { if err != nil {
t.Fatalf("Error : %v occured while listening on addr : %v", err, addr) t.Fatalf("Error: %v occurred while listening on addr: %v", err, addr)
} }
err = srv.Serve(ln) err = srv.Serve(ln)
@ -86,19 +86,19 @@ func TestV3ClientMetrics(t *testing.T) {
pAfter := sumCountersForMetricAndLabels(t, url, "grpc_client_started_total", "Put", "unary") pAfter := sumCountersForMetricAndLabels(t, url, "grpc_client_started_total", "Put", "unary")
if pBefore+1 != pAfter { if pBefore+1 != pAfter {
t.Errorf("grpc_client_started_total expected : %d, got : %d", 1, pAfter-pBefore) t.Errorf("grpc_client_started_total expected %d, got %d", 1, pAfter-pBefore)
} }
// consume watch response // consume watch response
select { select {
case <-wc: case <-wc:
case <-time.After(10 * time.Second): case <-time.After(10 * time.Second):
t.Error("Timeout occured for getting watch response") t.Error("Timeout occurred for getting watch response")
} }
wAfter := sumCountersForMetricAndLabels(t, url, "grpc_client_msg_received_total", "Watch", "bidi_stream") wAfter := sumCountersForMetricAndLabels(t, url, "grpc_client_msg_received_total", "Watch", "bidi_stream")
if wBefore+1 != wAfter { if wBefore+1 != wAfter {
t.Errorf("grpc_client_msg_received_total expected : %d, got %d", 1, wAfter-wBefore) t.Errorf("grpc_client_msg_received_total expected %d, got %d", 1, wAfter-wBefore)
} }
ln.Close() ln.Close()
@ -127,7 +127,7 @@ func sumCountersForMetricAndLabels(t *testing.T, url string, metricName string,
valueString := line[strings.LastIndex(line, " ")+1 : len(line)-1] valueString := line[strings.LastIndex(line, " ")+1 : len(line)-1]
valueFloat, err := strconv.ParseFloat(valueString, 32) valueFloat, err := strconv.ParseFloat(valueString, 32)
if err != nil { if err != nil {
t.Fatalf("failed parsing value for line: %v and matchingLabelValues : %v \n", line, matchingLabelValues) t.Fatalf("failed parsing value for line: %v and matchingLabelValues: %v", line, matchingLabelValues)
} }
count += int(valueFloat) count += int(valueFloat)
} }
@ -138,7 +138,7 @@ func getHTTPBodyAsLines(t *testing.T, url string) []string {
cfgtls := transport.TLSInfo{} cfgtls := transport.TLSInfo{}
tr, err := transport.NewTransport(cfgtls, time.Second) tr, err := transport.NewTransport(cfgtls, time.Second)
if err != nil { if err != nil {
t.Fatalf("Error getting transport : %v", err) t.Fatalf("Error getting transport: %v", err)
} }
tr.MaxIdleConns = -1 tr.MaxIdleConns = -1