Change coordinator to query and add m3query service

.codecov.yml

@@ -6,8 +6,8 @@ coverage:
   status:
     project:
       default: on
-      coordinator:
-        flags: coordinator
+      query:
+        flags: query
       dbnode:
         flags: dbnode
       m3ninx:
@@ -18,9 +18,9 @@ coverage:
       default: off
 
   flags:
-    coordinator:
+    query:
       paths:
-        - src/coordinator/
+        - src/query/
         - src/cmd/services/m3coordinator/
     dbnode:
       paths:

Makefile

@@ -36,11 +36,12 @@ SERVICES :=     \
 	m3coordinator \
 	m3nsch_server \
 	m3nsch_client \
+	m3query       \
 
 SUBDIRS :=    \
 	cmd         \
 	dbnode      \
-	coordinator \
+	query       \
 	m3nsch      \
 	m3ninx      \
 

docker/m3coordinator/Dockerfile

@@ -21,7 +21,7 @@ LABEL maintainer="The M3DB Authors <[email protected]>"
 EXPOSE 7201/tcp 7203/tcp
 
 COPY --from=builder /go/src/github.com/m3db/m3db/bin/m3coordinator /bin/
-COPY --from=builder /go/src/github.com/m3db/m3db/src/coordinator/config/m3coordinator-local-etcd.yml /etc/m3coordinator/m3coordinator.yml
+COPY --from=builder /go/src/github.com/m3db/m3db/src/query/config/m3coordinator-local-etcd.yml /etc/m3coordinator/m3coordinator.yml
 
 ENTRYPOINT [ "/bin/m3coordinator" ]
 CMD [ "-f", "/etc/m3coordinator/m3coordinator.yml" ]

scripts/process-cover.sh

@@ -8,11 +8,11 @@ fi
 COVERFILE=$1
 SUBMIT_COVER="$(dirname $0)/../.ci/codecov.sh"
 
-TARGETS=("dbnode" "coordinator" "m3ninx")
+TARGETS=("dbnode" "query" "m3ninx")
 target_patterns() {
     case $1 in
         'dbnode') echo "^mode|github.com/m3db/m3db/src/dbnode|github.com/m3db/m3db/src/cmd/services/m3dbnode";;
-        'coordinator') echo "^mode|github.com/m3db/m3db/src/coordinator|github.com/m3db/m3db/src/cmd/services/m3coordinator";;
+        'query') echo "^mode|github.com/m3db/m3db/src/query|github.com/m3db/m3db/src/cmd/services/m3coordinator";;
         'm3ninx') echo "^mode|github.com/m3db/m3db/src/m3ninx";;
         *)   echo "unknown key: $1"; exit 1;;
     esac

scripts/site-build.sh

@@ -2,7 +2,7 @@
 
 set -e
 
-ASSET_DIR=${1:-src/coordinator/generated/assets/openapi}
+ASSET_DIR=${1:-src/query/generated/assets/openapi}
 
 # Copy over OpenAPI doc.
 mkdir -p m3metrics.io/openapi

src/cmd/services/m3coordinator/main/main.go

@@ -25,7 +25,7 @@ import (
 	_ "net/http/pprof" // pprof: for debug listen server if configured
 	"os"
 
-	"github.com/m3db/m3db/src/coordinator/services/m3coordinator/server"
+	"github.com/m3db/m3db/src/query/services/m3coordinator/server"
 )
 
 var (

src/cmd/services/m3dbnode/config/config.go

@@ -29,7 +29,7 @@ import (
 	"strings"
 	"time"
 
-	coordinatorcfg "github.com/m3db/m3db/src/cmd/services/m3coordinator/config"
+	coordinatorcfg "github.com/m3db/m3db/src/cmd/services/m3query/config"
 	"github.com/m3db/m3db/src/dbnode/client"
 	"github.com/m3db/m3db/src/dbnode/environment"
 	"github.com/m3db/m3x/config/hostid"

src/cmd/services/m3dbnode/main/main.go

@@ -29,8 +29,8 @@ import (
 	clusterclient "github.com/m3db/m3cluster/client"
 	"github.com/m3db/m3db/src/cmd/services/m3dbnode/config"
 	dbserver "github.com/m3db/m3db/src/cmd/services/m3dbnode/server"
-	coordinatorserver "github.com/m3db/m3db/src/coordinator/services/m3coordinator/server"
 	"github.com/m3db/m3db/src/dbnode/client"
+	coordinatorserver "github.com/m3db/m3db/src/query/services/m3coordinator/server"
 	xconfig "github.com/m3db/m3x/config"
 )
 

src/cmd/services/m3coordinator/config/config.go → src/cmd/services/m3query/config/config.go

@@ -24,7 +24,7 @@ import (
 	"time"
 
 	etcdclient "github.com/m3db/m3cluster/client/etcd"
-	"github.com/m3db/m3db/src/coordinator/storage/local"
+	"github.com/m3db/m3db/src/query/storage/local"
 	"github.com/m3db/m3x/instrument"
 )
 

src/cmd/services/m3query/main/main.go

@@ -0,0 +1,46 @@
+// Copyright (c) 2018 Uber Technologies, Inc.
+//
+// Permission is hereby granted, free of charge, to any person obtaining a copy
+// of this software and associated documentation files (the "Software"), to deal
+// in the Software without restriction, including without limitation the rights
+// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+// copies of the Software, and to permit persons to whom the Software is
+// furnished to do so, subject to the following conditions:
+//
+// The above copyright notice and this permission notice shall be included in
+// all copies or substantial portions of the Software.
+//
+// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
+// THE SOFTWARE.
+
+package main
+
+import (
+	"flag"
+	_ "net/http/pprof" // pprof: for debug listen server if configured
+	"os"
+
+	"github.com/m3db/m3db/src/query/services/m3coordinator/server"
+)
+
+var (
+	configFile = flag.String("f", "", "configuration file")
+)
+
+func main() {
+	flag.Parse()
+
+	if len(*configFile) == 0 {
+		flag.Usage()
+		os.Exit(1)
+	}
+
+	server.Run(server.RunOptions{
+		ConfigFile: *configFile,
+	})
+}

src/coordinator/README.md → src/query/README.md

@@ -50,13 +50,13 @@ Run m3coordinator binary:
 
 Run Prometheus Docker image:
 
-    $ docker run -p 9090:9090 -v $GOPATH/src/github.com/m3db/m3db/src/coordinator/docker/prometheus-mac.yml:/etc/prometheus/prometheus.yml quay.io/prometheus/prometheus
+    $ docker run -p 9090:9090 -v $GOPATH/src/github.com/m3db/m3db/src/query/docker/prometheus-mac.yml:/etc/prometheus/prometheus.yml quay.io/prometheus/prometheus
 
 ### Running on GCP
 
 Setup GCP for [single m3db node](https://github.com/m3db/m3db/pull/452/files?short_path=20bfc3f#diff-20bfc3ff6a860483887b93bf9cf0d135)
 
-> For a multi-node cluster, [see here](https://github.com/m3db/m3db/src/coordinator/tree/master/benchmark)
+> For a multi-node cluster, [see here](https://github.com/m3db/m3db/src/query/tree/master/benchmark)
 
 Setup GCP for m3coordinator:
 
@@ -80,7 +80,7 @@ Setup and run Prometheus:
                 - url: http://10.142.0.8:7201/api/v1/prom/remote/write
             ```
     3. Run Prometheus
-        $ sudo docker run -p 9090:9090 -v $GOPATH/src/github.com/m3db/m3db/src/coordinator/docker/prometheus.yml:/etc/prometheus/prometheus.yml quay.io/prometheus/prometheus
+        $ sudo docker run -p 9090:9090 -v $GOPATH/src/github.com/m3db/m3db/src/query/docker/prometheus.yml:/etc/prometheus/prometheus.yml quay.io/prometheus/prometheus
 
-[doc-img]: https://godoc.org/github.com/m3db/m3db/src/coordinator?status.svg
-[doc]: https://godoc.org/github.com/m3db/m3db/src/coordinator
+[doc-img]: https://godoc.org/github.com/m3db/m3db/src/query?status.svg
+[doc]: https://godoc.org/github.com/m3db/m3db/src/query

src/coordinator/api/v1/handler/common.go → src/query/api/v1/handler/common.go

@@ -29,7 +29,7 @@ import (
 	"strings"
 	"time"
 
-	"github.com/m3db/m3db/src/coordinator/util/logging"
+	"github.com/m3db/m3db/src/query/util/logging"
 
 	"github.com/golang/protobuf/jsonpb"
 	"github.com/golang/protobuf/proto"

src/coordinator/api/v1/handler/database/common.go → src/query/api/v1/handler/database/common.go

@@ -22,9 +22,9 @@ package database
 
 import (
 	clusterclient "github.com/m3db/m3cluster/client"
-	"github.com/m3db/m3db/src/cmd/services/m3coordinator/config"
 	dbconfig "github.com/m3db/m3db/src/cmd/services/m3dbnode/config"
-	"github.com/m3db/m3db/src/coordinator/util/logging"
+	"github.com/m3db/m3db/src/cmd/services/m3query/config"
+	"github.com/m3db/m3db/src/query/util/logging"
 
 	"github.com/gorilla/mux"
 )

src/coordinator/api/v1/handler/database/create.go → src/query/api/v1/handler/database/create.go

@@ -32,15 +32,15 @@ import (
 
 	clusterclient "github.com/m3db/m3cluster/client"
 	"github.com/m3db/m3cluster/generated/proto/placementpb"
-	"github.com/m3db/m3db/src/cmd/services/m3coordinator/config"
 	dbconfig "github.com/m3db/m3db/src/cmd/services/m3dbnode/config"
-	"github.com/m3db/m3db/src/coordinator/api/v1/handler"
-	"github.com/m3db/m3db/src/coordinator/api/v1/handler/namespace"
-	"github.com/m3db/m3db/src/coordinator/api/v1/handler/placement"
-	"github.com/m3db/m3db/src/coordinator/generated/proto/admin"
-	"github.com/m3db/m3db/src/coordinator/util"
-	"github.com/m3db/m3db/src/coordinator/util/logging"
+	"github.com/m3db/m3db/src/cmd/services/m3query/config"
 	dbnamespace "github.com/m3db/m3db/src/dbnode/storage/namespace"
+	"github.com/m3db/m3db/src/query/api/v1/handler"
+	"github.com/m3db/m3db/src/query/api/v1/handler/namespace"
+	"github.com/m3db/m3db/src/query/api/v1/handler/placement"
+	"github.com/m3db/m3db/src/query/generated/proto/admin"
+	"github.com/m3db/m3db/src/query/util"
+	"github.com/m3db/m3db/src/query/util/logging"
 
 	"github.com/golang/protobuf/jsonpb"
 	"go.uber.org/zap"

src/coordinator/api/v1/handler/database/create_test.go → src/query/api/v1/handler/database/create_test.go

@@ -36,11 +36,11 @@ import (
 	"github.com/m3db/m3cluster/kv"
 	"github.com/m3db/m3cluster/placement"
 	"github.com/m3db/m3cluster/services"
-	"github.com/m3db/m3db/src/cmd/services/m3coordinator/config"
 	dbconfig "github.com/m3db/m3db/src/cmd/services/m3dbnode/config"
-	"github.com/m3db/m3db/src/coordinator/api/v1/handler/namespace"
-	"github.com/m3db/m3db/src/coordinator/util/logging"
+	"github.com/m3db/m3db/src/cmd/services/m3query/config"
 	xtest "github.com/m3db/m3db/src/dbnode/x/test"
+	"github.com/m3db/m3db/src/query/api/v1/handler/namespace"
+	"github.com/m3db/m3db/src/query/util/logging"
 
 	"github.com/golang/mock/gomock"
 	"github.com/stretchr/testify/assert"

src/coordinator/api/v1/handler/namespace/add.go → src/query/api/v1/handler/namespace/add.go

@@ -26,11 +26,11 @@ import (
 	"net/http"
 
 	clusterclient "github.com/m3db/m3cluster/client"
-	"github.com/m3db/m3db/src/coordinator/api/v1/handler"
-	"github.com/m3db/m3db/src/coordinator/generated/proto/admin"
-	"github.com/m3db/m3db/src/coordinator/util/logging"
 	nsproto "github.com/m3db/m3db/src/dbnode/generated/proto/namespace"
 	"github.com/m3db/m3db/src/dbnode/storage/namespace"
+	"github.com/m3db/m3db/src/query/api/v1/handler"
+	"github.com/m3db/m3db/src/query/generated/proto/admin"
+	"github.com/m3db/m3db/src/query/util/logging"
 
 	"github.com/gogo/protobuf/jsonpb"
 	"go.uber.org/zap"

src/coordinator/api/v1/handler/namespace/common.go → src/query/api/v1/handler/namespace/common.go

@@ -25,9 +25,9 @@ import (
 
 	clusterclient "github.com/m3db/m3cluster/client"
 	"github.com/m3db/m3cluster/kv"
-	"github.com/m3db/m3db/src/coordinator/util/logging"
 	nsproto "github.com/m3db/m3db/src/dbnode/generated/proto/namespace"
 	"github.com/m3db/m3db/src/dbnode/storage/namespace"
+	"github.com/m3db/m3db/src/query/util/logging"
 
 	"github.com/gorilla/mux"
 )

src/coordinator/api/v1/handler/namespace/common_test.go → src/query/api/v1/handler/namespace/common_test.go

@@ -25,8 +25,8 @@ import (
 	"testing"
 
 	"github.com/m3db/m3cluster/kv"
-	"github.com/m3db/m3db/src/coordinator/util/logging"
 	nsproto "github.com/m3db/m3db/src/dbnode/generated/proto/namespace"
+	"github.com/m3db/m3db/src/query/util/logging"
 
 	"github.com/golang/mock/gomock"
 	"github.com/stretchr/testify/assert"

src/coordinator/api/v1/handler/namespace/delete.go → src/query/api/v1/handler/namespace/delete.go

@@ -28,9 +28,9 @@ import (
 	"strings"
 
 	clusterclient "github.com/m3db/m3cluster/client"
-	"github.com/m3db/m3db/src/coordinator/api/v1/handler"
-	"github.com/m3db/m3db/src/coordinator/util/logging"
 	"github.com/m3db/m3db/src/dbnode/storage/namespace"
+	"github.com/m3db/m3db/src/query/api/v1/handler"
+	"github.com/m3db/m3db/src/query/util/logging"
 
 	"github.com/gorilla/mux"
 	"go.uber.org/zap"

src/coordinator/api/v1/handler/namespace/get.go → src/query/api/v1/handler/namespace/get.go

@@ -26,10 +26,10 @@ import (
 
 	clusterclient "github.com/m3db/m3cluster/client"
 	"github.com/m3db/m3cluster/kv"
-	"github.com/m3db/m3db/src/coordinator/api/v1/handler"
-	"github.com/m3db/m3db/src/coordinator/generated/proto/admin"
-	"github.com/m3db/m3db/src/coordinator/util/logging"
 	nsproto "github.com/m3db/m3db/src/dbnode/generated/proto/namespace"
+	"github.com/m3db/m3db/src/query/api/v1/handler"
+	"github.com/m3db/m3db/src/query/generated/proto/admin"
+	"github.com/m3db/m3db/src/query/util/logging"
 
 	"go.uber.org/zap"
 )

src/coordinator/api/v1/handler/namespace/get_test.go → src/query/api/v1/handler/namespace/get_test.go

@@ -28,8 +28,8 @@ import (
 
 	"github.com/m3db/m3cluster/client"
 	"github.com/m3db/m3cluster/kv"
-	"github.com/m3db/m3db/src/coordinator/util/logging"
 	nsproto "github.com/m3db/m3db/src/dbnode/generated/proto/namespace"
+	"github.com/m3db/m3db/src/query/util/logging"
 
 	"github.com/golang/mock/gomock"
 	"github.com/stretchr/testify/assert"

src/coordinator/api/v1/handler/openapi/openapi.go → src/query/api/v1/handler/openapi/openapi.go

@@ -23,9 +23,9 @@ package openapi
 import (
 	"net/http"
 
-	"github.com/m3db/m3db/src/coordinator/api/v1/handler"
-	assets "github.com/m3db/m3db/src/coordinator/generated/assets/openapi"
-	"github.com/m3db/m3db/src/coordinator/util/logging"
+	"github.com/m3db/m3db/src/query/api/v1/handler"
+	assets "github.com/m3db/m3db/src/query/generated/assets/openapi"
+	"github.com/m3db/m3db/src/query/util/logging"
 
 	"go.uber.org/zap"
 )

src/coordinator/api/v1/handler/placement/add.go → src/query/api/v1/handler/placement/add.go

@@ -25,10 +25,10 @@ import (
 
 	clusterclient "github.com/m3db/m3cluster/client"
 	"github.com/m3db/m3cluster/placement"
-	"github.com/m3db/m3db/src/cmd/services/m3coordinator/config"
-	"github.com/m3db/m3db/src/coordinator/api/v1/handler"
-	"github.com/m3db/m3db/src/coordinator/generated/proto/admin"
-	"github.com/m3db/m3db/src/coordinator/util/logging"
+	"github.com/m3db/m3db/src/cmd/services/m3query/config"
+	"github.com/m3db/m3db/src/query/api/v1/handler"
+	"github.com/m3db/m3db/src/query/generated/proto/admin"
+	"github.com/m3db/m3db/src/query/util/logging"
 
 	"github.com/gogo/protobuf/jsonpb"
 	"go.uber.org/zap"

src/coordinator/api/v1/handler/placement/add_test.go → src/query/api/v1/handler/placement/add_test.go

@@ -29,7 +29,7 @@ import (
 	"testing"
 
 	"github.com/m3db/m3cluster/placement"
-	"github.com/m3db/m3db/src/cmd/services/m3coordinator/config"
+	"github.com/m3db/m3db/src/cmd/services/m3query/config"
 
 	"github.com/golang/mock/gomock"
 	"github.com/stretchr/testify/assert"

src/coordinator/api/v1/handler/placement/common.go → src/query/api/v1/handler/placement/common.go

@@ -29,8 +29,8 @@ import (
 	"github.com/m3db/m3cluster/placement"
 	"github.com/m3db/m3cluster/services"
 	"github.com/m3db/m3cluster/shard"
-	"github.com/m3db/m3db/src/cmd/services/m3coordinator/config"
-	"github.com/m3db/m3db/src/coordinator/util/logging"
+	"github.com/m3db/m3db/src/cmd/services/m3query/config"
+	"github.com/m3db/m3db/src/query/util/logging"
 
 	"github.com/gorilla/mux"
 )

src/coordinator/api/v1/handler/placement/delete.go → src/query/api/v1/handler/placement/delete.go

@@ -26,10 +26,10 @@ import (
 	"net/http"
 
 	clusterclient "github.com/m3db/m3cluster/client"
-	"github.com/m3db/m3db/src/cmd/services/m3coordinator/config"
-	"github.com/m3db/m3db/src/coordinator/api/v1/handler"
-	"github.com/m3db/m3db/src/coordinator/generated/proto/admin"
-	"github.com/m3db/m3db/src/coordinator/util/logging"
+	"github.com/m3db/m3db/src/cmd/services/m3query/config"
+	"github.com/m3db/m3db/src/query/api/v1/handler"
+	"github.com/m3db/m3db/src/query/generated/proto/admin"
+	"github.com/m3db/m3db/src/query/util/logging"
 
 	"github.com/gorilla/mux"
 	"go.uber.org/zap"

src/coordinator/api/v1/handler/placement/delete_all.go → src/query/api/v1/handler/placement/delete_all.go

@@ -25,9 +25,9 @@ import (
 	"net/http"
 
 	clusterclient "github.com/m3db/m3cluster/client"
-	"github.com/m3db/m3db/src/cmd/services/m3coordinator/config"
-	"github.com/m3db/m3db/src/coordinator/api/v1/handler"
-	"github.com/m3db/m3db/src/coordinator/util/logging"
+	"github.com/m3db/m3db/src/cmd/services/m3query/config"
+	"github.com/m3db/m3db/src/query/api/v1/handler"
+	"github.com/m3db/m3db/src/query/util/logging"
 
 	"go.uber.org/zap"
 )

src/coordinator/api/v1/handler/placement/delete_all_test.go → src/query/api/v1/handler/placement/delete_all_test.go

@@ -26,7 +26,7 @@ import (
 	"net/http/httptest"
 	"testing"
 
-	"github.com/m3db/m3db/src/cmd/services/m3coordinator/config"
+	"github.com/m3db/m3db/src/cmd/services/m3query/config"
 
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"