From 12de4c4a6239b7780d12217ceaf11c5b6c6ecbd6 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Nicol=C3=A1s=20Pazos?= Date: Fri, 29 Sep 2023 12:35:52 -0300 Subject: [PATCH] remove some comented code MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Nicolás Pazos --- .../examples/remote_storage/example_write_adapter/server.go | 4 +--- storage/remote/queue_manager.go | 1 - storage/remote/queue_manager_test.go | 1 - 3 files changed, 1 insertion(+), 5 deletions(-) diff --git a/documentation/examples/remote_storage/example_write_adapter/server.go b/documentation/examples/remote_storage/example_write_adapter/server.go index 5c1fae90c0..a502505fa7 100644 --- a/documentation/examples/remote_storage/example_write_adapter/server.go +++ b/documentation/examples/remote_storage/example_write_adapter/server.go @@ -57,14 +57,12 @@ func main() { } }) - http.HandleFunc("/receiveNew", func(w http.ResponseWriter, r *http.Request) { + http.HandleFunc("/receiveReduced", func(w http.ResponseWriter, r *http.Request) { req, err := remote.DecodeReducedWriteRequest(r.Body) if err != nil { http.Error(w, err.Error(), http.StatusBadRequest) return } - // req.StringSymbolTable - // fmt.Println("symbol table: ", req.StringSymbolTable) for _, ts := range req.Timeseries { m := make(model.Metric, len(ts.Labels)) diff --git a/storage/remote/queue_manager.go b/storage/remote/queue_manager.go index 57cd6927ad..6319bb31c8 100644 --- a/storage/remote/queue_manager.go +++ b/storage/remote/queue_manager.go @@ -775,7 +775,6 @@ outer: // Start the queue manager sending samples to the remote storage. // Does not block. func (t *QueueManager) Start() { - // panic(1) // Register and initialise some metrics. t.metrics.register() t.metrics.shardCapacity.Set(float64(t.cfg.Capacity)) diff --git a/storage/remote/queue_manager_test.go b/storage/remote/queue_manager_test.go index 7de769d6c0..7321ce4712 100644 --- a/storage/remote/queue_manager_test.go +++ b/storage/remote/queue_manager_test.go @@ -132,7 +132,6 @@ func TestSampleDelivery(t *testing.T) { hash, err := toHash(writeConfig) require.NoError(t, err) qm := s.rws.queues[hash] - // time.Sleep(1 * time.Second) c := NewTestWriteClient() qm.SetClient(c)