From 08663d45ad627054d897622977ce310b71c115d3 Mon Sep 17 00:00:00 2001 From: Jackson Newhouse Date: Thu, 7 Feb 2019 17:25:15 -0800 Subject: [PATCH] switch ssmccoy to quantcast. --- chart/g2/.helmignore | 2 +- client/client.go | 2 +- client/client_test.go | 2 +- client/request.go | 2 +- client/response.go | 2 +- cmd/gearmand/run.go | 2 +- doc.go | 8 ++++---- example/client/client.go | 4 ++-- example/worker/worker.go | 2 +- gearadmin/doc.go | 2 +- go.mod | 2 +- hack/coverage.sh | 2 +- pkg/server/server.go | 8 ++++---- pkg/server/session.go | 2 +- pkg/server/util.go | 2 +- pkg/server/util_test.go | 2 +- pkg/server/worker.go | 2 +- pkg/storage/leveldb/leveldb.go | 2 +- pkg/storage/storage_test.go | 6 +++--- worker/agent.go | 2 +- worker/example_test.go | 4 ++-- worker/inpack.go | 2 +- worker/inpack_test.go | 2 +- worker/outpack.go | 2 +- worker/outpack_test.go | 2 +- worker/worker.go | 2 +- worker/worker_disconnect_test.go | 4 ++-- worker/worker_test.go | 2 +- 28 files changed, 39 insertions(+), 39 deletions(-) diff --git a/chart/g2/.helmignore b/chart/g2/.helmignore index c13e3c8..f0c1319 100644 --- a/chart/g2/.helmignore +++ b/chart/g2/.helmignore @@ -18,4 +18,4 @@ # Various IDEs .project .idea/ -*.tmproj \ No newline at end of file +*.tmproj diff --git a/client/client.go b/client/client.go index 08e0c56..5e0baaa 100644 --- a/client/client.go +++ b/client/client.go @@ -16,7 +16,7 @@ import ( "unsafe" "github.com/appscode/go/log" - rt "github.com/ssmccoy/g2/pkg/runtime" + rt "github.com/quantcast/g2/pkg/runtime" ) var ( diff --git a/client/client_test.go b/client/client_test.go index 4cb6d0f..fc18df8 100644 --- a/client/client_test.go +++ b/client/client_test.go @@ -13,7 +13,7 @@ import ( "strings" "testing" - rt "github.com/ssmccoy/g2/pkg/runtime" + rt "github.com/quantcast/g2/pkg/runtime" ) type snapshot struct { diff --git a/client/request.go b/client/request.go index 3b02205..9caee8b 100644 --- a/client/request.go +++ b/client/request.go @@ -1,7 +1,7 @@ package client import ( - rt "github.com/ssmccoy/g2/pkg/runtime" + rt "github.com/quantcast/g2/pkg/runtime" ) // Request from client diff --git a/client/response.go b/client/response.go index 68b2a42..6157e04 100644 --- a/client/response.go +++ b/client/response.go @@ -5,7 +5,7 @@ import ( "fmt" "strconv" - rt "github.com/ssmccoy/g2/pkg/runtime" + rt "github.com/quantcast/g2/pkg/runtime" ) // Response handler diff --git a/cmd/gearmand/run.go b/cmd/gearmand/run.go index 76f53ff..9e3bdb9 100644 --- a/cmd/gearmand/run.go +++ b/cmd/gearmand/run.go @@ -4,7 +4,7 @@ import ( _ "net/http/pprof" "os" - gearmand "github.com/ssmccoy/g2/pkg/server" + gearmand "github.com/quantcast/g2/pkg/server" "github.com/appscode/go/runtime" "github.com/spf13/cobra" ) diff --git a/doc.go b/doc.go index afcd97f..1eb073b 100644 --- a/doc.go +++ b/doc.go @@ -9,16 +9,16 @@ The protocols were written in pure Go. It contains two sub-packages: The client package is used for sending jobs to the Gearman job server, and getting responses from the server. - import "github.com/ssmccoy/g2/client" + import "github.com/quantcast/g2/client" The worker package will help developers to develop Gearman's worker in an easy way. - import "github.com/ssmccoy/g2/worker" + import "github.com/quantcast/g2/worker" */ package g2 import ( - _ "github.com/ssmccoy/g2/client" - _ "github.com/ssmccoy/g2/worker" + _ "github.com/quantcast/g2/client" + _ "github.com/quantcast/g2/worker" ) diff --git a/example/client/client.go b/example/client/client.go index 34f4df0..5bb27cd 100644 --- a/example/client/client.go +++ b/example/client/client.go @@ -5,8 +5,8 @@ import ( "os" "sync" - "github.com/ssmccoy/g2/client" - rt "github.com/ssmccoy/g2/pkg/runtime" + "github.com/quantcast/g2/client" + rt "github.com/quantcast/g2/pkg/runtime" ) func main() { diff --git a/example/worker/worker.go b/example/worker/worker.go index 8e2f2e5..fb0429d 100644 --- a/example/worker/worker.go +++ b/example/worker/worker.go @@ -7,7 +7,7 @@ import ( "strings" "time" - "github.com/ssmccoy/g2/worker" + "github.com/quantcast/g2/worker" "github.com/mikespook/golib/signal" ) diff --git a/gearadmin/doc.go b/gearadmin/doc.go index 7e0a32a..30c7508 100644 --- a/gearadmin/doc.go +++ b/gearadmin/doc.go @@ -9,7 +9,7 @@ // // import ( // "fmt" -// "github.com/ssmccoy/g2/gearadmin" +// "github.com/quantcast/g2/gearadmin" // "net" // ) // diff --git a/go.mod b/go.mod index 8a696bf..c6c03aa 100644 --- a/go.mod +++ b/go.mod @@ -1,4 +1,4 @@ -module github.com/ssmccoy/g2 +module github.com/quantcast/g2 require ( github.com/appscode/go v0.0.0-20180628092646-df3c57fca2be diff --git a/hack/coverage.sh b/hack/coverage.sh index 67c8219..7864f12 100755 --- a/hack/coverage.sh +++ b/hack/coverage.sh @@ -2,7 +2,7 @@ set -eou pipefail GOPATH=$(go env GOPATH) -REPO_ROOT="$GOPATH/src/github.com/ssmccoy/g2" +REPO_ROOT="$GOPATH/src/github.com/quantcast/g2" pushd $REPO_ROOT diff --git a/pkg/server/server.go b/pkg/server/server.go index a27c67a..c272239 100644 --- a/pkg/server/server.go +++ b/pkg/server/server.go @@ -14,10 +14,10 @@ import ( "sync/atomic" "time" - "github.com/ssmccoy/g2/pkg/metrics" - . "github.com/ssmccoy/g2/pkg/runtime" - "github.com/ssmccoy/g2/pkg/storage" - "github.com/ssmccoy/g2/pkg/storage/leveldb" + "github.com/quantcast/g2/pkg/metrics" + . "github.com/quantcast/g2/pkg/runtime" + "github.com/quantcast/g2/pkg/storage" + "github.com/quantcast/g2/pkg/storage/leveldb" "github.com/appscode/go/log" "github.com/prometheus/client_golang/prometheus" "github.com/prometheus/client_golang/prometheus/promhttp" diff --git a/pkg/server/session.go b/pkg/server/session.go index 27be661..8118086 100644 --- a/pkg/server/session.go +++ b/pkg/server/session.go @@ -7,7 +7,7 @@ import ( "strings" "time" - . "github.com/ssmccoy/g2/pkg/runtime" + . "github.com/quantcast/g2/pkg/runtime" "github.com/appscode/go/log" ) diff --git a/pkg/server/util.go b/pkg/server/util.go index 922214c..90bc567 100644 --- a/pkg/server/util.go +++ b/pkg/server/util.go @@ -13,7 +13,7 @@ import ( "strings" "time" - "github.com/ssmccoy/g2/pkg/runtime" + "github.com/quantcast/g2/pkg/runtime" "github.com/appscode/go/log" ) diff --git a/pkg/server/util_test.go b/pkg/server/util_test.go index a2832c0..f90339e 100644 --- a/pkg/server/util_test.go +++ b/pkg/server/util_test.go @@ -4,7 +4,7 @@ import ( "bytes" "testing" - . "github.com/ssmccoy/g2/pkg/runtime" + . "github.com/quantcast/g2/pkg/runtime" ) func TestDecodeArgs(t *testing.T) { diff --git a/pkg/server/worker.go b/pkg/server/worker.go index 0677c2e..0c9753a 100644 --- a/pkg/server/worker.go +++ b/pkg/server/worker.go @@ -5,7 +5,7 @@ import ( "encoding/json" "net" - . "github.com/ssmccoy/g2/pkg/runtime" + . "github.com/quantcast/g2/pkg/runtime" ) const ( diff --git a/pkg/storage/leveldb/leveldb.go b/pkg/storage/leveldb/leveldb.go index c56ed80..f64da1e 100644 --- a/pkg/storage/leveldb/leveldb.go +++ b/pkg/storage/leveldb/leveldb.go @@ -7,7 +7,7 @@ import ( "reflect" "strings" - "github.com/ssmccoy/g2/pkg/storage" + "github.com/quantcast/g2/pkg/storage" "github.com/syndtr/goleveldb/leveldb" "github.com/syndtr/goleveldb/leveldb/util" ) diff --git a/pkg/storage/storage_test.go b/pkg/storage/storage_test.go index f739551..f320787 100644 --- a/pkg/storage/storage_test.go +++ b/pkg/storage/storage_test.go @@ -9,9 +9,9 @@ import ( "testing" "time" - . "github.com/ssmccoy/g2/pkg/runtime" - . "github.com/ssmccoy/g2/pkg/storage" - . "github.com/ssmccoy/g2/pkg/storage/leveldb" + . "github.com/quantcast/g2/pkg/runtime" + . "github.com/quantcast/g2/pkg/storage" + . "github.com/quantcast/g2/pkg/storage/leveldb" "github.com/stretchr/testify/assert" ) diff --git a/worker/agent.go b/worker/agent.go index c158cd5..c26076a 100644 --- a/worker/agent.go +++ b/worker/agent.go @@ -8,7 +8,7 @@ import ( "net" "sync" - rt "github.com/ssmccoy/g2/pkg/runtime" + rt "github.com/quantcast/g2/pkg/runtime" ) // The agent of job server. diff --git a/worker/example_test.go b/worker/example_test.go index 9190de0..7f02942 100644 --- a/worker/example_test.go +++ b/worker/example_test.go @@ -6,8 +6,8 @@ import ( "testing" "time" - rt "github.com/ssmccoy/g2/pkg/runtime" - "github.com/ssmccoy/g2/worker" + rt "github.com/quantcast/g2/pkg/runtime" + "github.com/quantcast/g2/worker" ) func ExampleWorker() { diff --git a/worker/inpack.go b/worker/inpack.go index 7a7c2d0..0306253 100644 --- a/worker/inpack.go +++ b/worker/inpack.go @@ -6,7 +6,7 @@ import ( "fmt" "strconv" - rt "github.com/ssmccoy/g2/pkg/runtime" + rt "github.com/quantcast/g2/pkg/runtime" ) // Worker side job diff --git a/worker/inpack_test.go b/worker/inpack_test.go index 12fcba3..d009c5d 100644 --- a/worker/inpack_test.go +++ b/worker/inpack_test.go @@ -4,7 +4,7 @@ import ( "bytes" "testing" - rt "github.com/ssmccoy/g2/pkg/runtime" + rt "github.com/quantcast/g2/pkg/runtime" ) var ( diff --git a/worker/outpack.go b/worker/outpack.go index 6d093fc..caec501 100644 --- a/worker/outpack.go +++ b/worker/outpack.go @@ -3,7 +3,7 @@ package worker import ( "encoding/binary" - rt "github.com/ssmccoy/g2/pkg/runtime" + rt "github.com/quantcast/g2/pkg/runtime" ) // Worker side job diff --git a/worker/outpack_test.go b/worker/outpack_test.go index 7ece1ba..f76125f 100644 --- a/worker/outpack_test.go +++ b/worker/outpack_test.go @@ -4,7 +4,7 @@ import ( "bytes" "testing" - rt "github.com/ssmccoy/g2/pkg/runtime" + rt "github.com/quantcast/g2/pkg/runtime" ) var ( diff --git a/worker/worker.go b/worker/worker.go index 6073a22..e23ee4e 100644 --- a/worker/worker.go +++ b/worker/worker.go @@ -8,7 +8,7 @@ import ( "sync" "time" - rt "github.com/ssmccoy/g2/pkg/runtime" + rt "github.com/quantcast/g2/pkg/runtime" ) const ( diff --git a/worker/worker_disconnect_test.go b/worker/worker_disconnect_test.go index eed1b31..bb0f922 100644 --- a/worker/worker_disconnect_test.go +++ b/worker/worker_disconnect_test.go @@ -7,8 +7,8 @@ import ( "testing" "time" - "github.com/ssmccoy/g2/client" - rt "github.com/ssmccoy/g2/pkg/runtime" + "github.com/quantcast/g2/client" + rt "github.com/quantcast/g2/pkg/runtime" ) const port = `3700` diff --git a/worker/worker_test.go b/worker/worker_test.go index f2b3fce..66f93f6 100644 --- a/worker/worker_test.go +++ b/worker/worker_test.go @@ -8,7 +8,7 @@ import ( "testing" "time" - "github.com/ssmccoy/g2/pkg/runtime" + "github.com/quantcast/g2/pkg/runtime" ) var worker *Worker