mudhorn/prometheus
1
0
Fork 0
mirror of https://github.com/prometheus/prometheus.git synced 2025-03-05 20:59:13 -08:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

remove some comented code

Browse source 
Signed-off-by: Nicolás Pazos <npazosmendez@gmail.com>
This commit is contained in:
Nicolás Pazos 2023-09-29 12:35:52 -03:00
parent 5f5272e69d
commit 12de4c4a62
3 changed files with 1 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
documentation/examples/remote_storage/example_write_adapter/server.go
View file

@ -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) req, err := remote.DecodeReducedWriteRequest(r.Body)
if err != nil { if err != nil {
http.Error(w, err.Error(), http.StatusBadRequest) http.Error(w, err.Error(), http.StatusBadRequest)
return return
} }
// req.StringSymbolTable
// fmt.Println("symbol table: ", req.StringSymbolTable)
for _, ts := range req.Timeseries { for _, ts := range req.Timeseries {
m := make(model.Metric, len(ts.Labels)) m := make(model.Metric, len(ts.Labels))

1
storage/remote/queue_manager.go
View file

@ -775,7 +775,6 @@ outer:
// Start the queue manager sending samples to the remote storage. // Start the queue manager sending samples to the remote storage.
// Does not block. // Does not block.
func (t *QueueManager) Start() { func (t *QueueManager) Start() {
// panic(1)
// Register and initialise some metrics. // Register and initialise some metrics.
t.metrics.register() t.metrics.register()
t.metrics.shardCapacity.Set(float64(t.cfg.Capacity)) t.metrics.shardCapacity.Set(float64(t.cfg.Capacity))

1
storage/remote/queue_manager_test.go
View file

@ -132,7 +132,6 @@ func TestSampleDelivery(t *testing.T) {
hash, err := toHash(writeConfig) hash, err := toHash(writeConfig)
require.NoError(t, err) require.NoError(t, err)
qm := s.rws.queues[hash] qm := s.rws.queues[hash]
// time.Sleep(1 * time.Second)
c := NewTestWriteClient() c := NewTestWriteClient()
qm.SetClient(c) qm.SetClient(c)