receiver split WORK IN PROGRESS

Signed-off-by: Chans321 <[email protected]> fixes in e2e test for new receieve architecture - more fixes pending fixes in receive and e2e test of receive Signed-off-by: Chans321 <[email protected]> fixed connection reset by peer error in receive e2e tests. all e2e tests pass Signed-off-by: Chans321 <[email protected]> pkg/route: Fix unit tests route: Make hashring only work on labels route: Incorporate thanos-io#2899 fixed import issues and changed the query test signature Signed-off-by: Yash Sharma <[email protected]> made some corrections while rebasing receiver changes Signed-off-by: Yash Sharma <[email protected]> Added a method Error() to implement golang error interface Signed-off-by: Yash Sharma <[email protected]> linting Signed-off-by: Yash Sharma <[email protected]> use the new promauto package Signed-off-by: Yash Sharma <[email protected]> removed unused params Signed-off-by: Yash Sharma <[email protected]> rename method and add comments Signed-off-by: Yash Sharma <[email protected]> removed unused flags in receiver service in e2e tests Signed-off-by: Yash Sharma <[email protected]> replaced promauto with prometheus, as earlier was causing unnecessary panic Signed-off-by: Yash Sharma <[email protected]> changes for debug Signed-off-by: Yash Sharma <[email protected]> removed entry for receive test for e2e Signed-off-by: Yash Sharma <[email protected]> added a readiness probe Signed-off-by: Yash Sharma <[email protected]> fix E2E tests for receive router Signed-off-by: yeya24 <[email protected]>
yashrsharma44 · Mar 10, 2021 · c34eac8 · c34eac8
1 parent 84c73dc
commit c34eac8
Show file tree

Hide file tree

Showing 22 changed files with 1,441 additions and 1,400 deletions.
diff --git a/Dockerfile.multi-stage b/Dockerfile.multi-stage
@@ -22,3 +22,4 @@ LABEL maintainer="The Thanos Authors"
 COPY --from=builder /go/bin/thanos /bin/thanos
 
 ENTRYPOINT [ "/bin/thanos" ]
+
diff --git a/Makefile b/Makefile
@@ -401,4 +401,3 @@ $(PROTOC):
 	@echo ">> installing protoc@${PROTOC_VERSION}"
 	@mv -- "$(TMP_GOPATH)/bin/protoc" "$(GOBIN)/protoc-$(PROTOC_VERSION)"
 	@echo ">> produced $(GOBIN)/protoc-$(PROTOC_VERSION)"
-
diff --git a/cmd/thanos/main.go b/cmd/thanos/main.go
@@ -11,7 +11,6 @@ import (
 	"os/signal"
 	"path/filepath"
 	"runtime"
-	"runtime/debug"
 	"syscall"
 
 	"github.com/go-kit/kit/log"
@@ -29,10 +28,6 @@ import (
 )
 
 func main() {
-	// We use mmaped resources in most of the components so hardcode PanicOnFault to true. This allows us to recover (if we can e.g if queries
-	// are temporarily accessing unmapped memory).
-	debug.SetPanicOnFault(true)
-
 	if os.Getenv("DEBUG") != "" {
 		runtime.SetMutexProfileFraction(10)
 		runtime.SetBlockProfileRate(10)
@@ -53,6 +48,7 @@ func main() {
 	registerCompact(app)
 	registerTools(app)
 	registerReceive(app)
+	registerReceiveRoute(app)
 	registerQueryFrontend(app)
 
 	cmd, setup := app.Parse()
Original file line number	Diff line number	Diff line change
Expand Up		@@ -22,3 +22,4 @@ LABEL maintainer="The Thanos Authors"
		COPY --from=builder /go/bin/thanos /bin/thanos

		ENTRYPOINT [ "/bin/thanos" ]
Original file line number	Diff line number	Diff line change
Expand Up		@@ -401,4 +401,3 @@ $(PROTOC):
		@echo ">> installing protoc@${PROTOC_VERSION}"
		@mv -- "$(TMP_GOPATH)/bin/protoc" "$(GOBIN)/protoc-$(PROTOC_VERSION)"
		@echo ">> produced $(GOBIN)/protoc-$(PROTOC_VERSION)"