From b27d36bbf36c467d4235870aff6862b43cba1c7f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?J=C3=B6rg=20Thalheim?= Date: Tue, 19 Apr 2016 17:18:03 +0200 Subject: [PATCH] rename project --- README.md | 4 ++++ handler/lib.go | 2 +- handler/lib_test.go | 10 ++++++---- main.go | 8 ++++---- scaling/agent.go | 2 +- 5 files changed, 16 insertions(+), 10 deletions(-) diff --git a/README.md b/README.md index 50e1b21..b19edbf 100644 --- a/README.md +++ b/README.md @@ -1,3 +1,7 @@ +## Tests + +$ go test ./handler + ## TODO - start cooldown timer, when service was actually scaled up diff --git a/handler/lib.go b/handler/lib.go index 84673a2..0bdb300 100644 --- a/handler/lib.go +++ b/handler/lib.go @@ -1,7 +1,7 @@ package handler import ( - "acos.alcatel-lucent.com/scmrepos/git/micro-analytics/kapacitor-scaling/scaling" + "acos.alcatel-lucent.com/scmrepos/git/micro-analytics/kapacitor-scale/scaling" "errors" "fmt" "github.com/influxdata/kapacitor/udf" diff --git a/handler/lib_test.go b/handler/lib_test.go index 46ac0f9..69fad42 100644 --- a/handler/lib_test.go +++ b/handler/lib_test.go @@ -1,9 +1,9 @@ package handler_test import ( - "acos.alcatel-lucent.com/scmrepos/git/micro-analytics/kapacitor-scaling/handler" - "acos.alcatel-lucent.com/scmrepos/git/micro-analytics/kapacitor-scaling/rancher" - "acos.alcatel-lucent.com/scmrepos/git/micro-analytics/kapacitor-scaling/scaling" + "acos.alcatel-lucent.com/scmrepos/git/micro-analytics/kapacitor-scale/handler" + "acos.alcatel-lucent.com/scmrepos/git/micro-analytics/kapacitor-scale/rancher" + "acos.alcatel-lucent.com/scmrepos/git/micro-analytics/kapacitor-scale/scaling" "bufio" "flag" "fmt" @@ -188,6 +188,8 @@ func TestHandler(t *testing.T) { t.Fatalf("expected scale to be 2, got %d", val) } server.writePoint(udfPoint) - go t.Fatalf("it should not scale up because of cooldown, got '%v'", server.ReadResponse()) + go func() { + t.Fatalf("it should not scale up because of cooldown, got '%v'", server.ReadResponse()) + }() time.Sleep(time.Millisecond * 10) // no response, good! } diff --git a/main.go b/main.go index d94c78f..d28ff7e 100644 --- a/main.go +++ b/main.go @@ -9,14 +9,14 @@ import ( "os" "syscall" - "acos.alcatel-lucent.com/scmrepos/git/micro-analytics/kapacitor-scaling/handler" - "acos.alcatel-lucent.com/scmrepos/git/micro-analytics/kapacitor-scaling/rancher" - "acos.alcatel-lucent.com/scmrepos/git/micro-analytics/kapacitor-scaling/scaling" + "acos.alcatel-lucent.com/scmrepos/git/micro-analytics/kapacitor-scale/handler" + "acos.alcatel-lucent.com/scmrepos/git/micro-analytics/kapacitor-scale/rancher" + "acos.alcatel-lucent.com/scmrepos/git/micro-analytics/kapacitor-scale/scaling" "github.com/influxdata/kapacitor/udf/agent" ) var ( - socketPath = flag.String("socket", "/tmp/kapacitor-scaling.sock", "Where to create the unix socket") + socketPath = flag.String("socket", "/tmp/kapacitor-scale.sock", "Where to create the unix socket") ) type acceptor struct { diff --git a/scaling/agent.go b/scaling/agent.go index 1182bf6..81aedcf 100644 --- a/scaling/agent.go +++ b/scaling/agent.go @@ -1,7 +1,7 @@ package scaling import ( - "acos.alcatel-lucent.com/scmrepos/git/micro-analytics/kapacitor-scaling/rancher" + "acos.alcatel-lucent.com/scmrepos/git/micro-analytics/kapacitor-scale/rancher" "fmt" "sync" "time"