From 2d507a8757887c017f7f545faf1322eadae76325 Mon Sep 17 00:00:00 2001 From: Dmytro Kozlov Date: Mon, 31 Jul 2023 16:53:32 +0200 Subject: [PATCH] app/vmctl: remove ping from remote read protocol (#4749) Ping method was never used, so we remove it. --- app/vmctl/remoteread/remoteread.go | 18 ------------------ 1 file changed, 18 deletions(-) diff --git a/app/vmctl/remoteread/remoteread.go b/app/vmctl/remoteread/remoteread.go index c27ed799a6..fe458f0184 100644 --- a/app/vmctl/remoteread/remoteread.go +++ b/app/vmctl/remoteread/remoteread.go @@ -23,7 +23,6 @@ import ( const ( defaultReadTimeout = 5 * time.Minute remoteReadPath = "/api/v1/read" - healthPath = "/-/healthy" ) // StreamCallback is a callback function for processing time series @@ -154,23 +153,6 @@ func (c *Client) do(req *http.Request) (*http.Response, error) { return c.c.Do(req) } -// Ping checks the health of the read source -func (c *Client) Ping() error { - url := c.addr + healthPath - req, err := http.NewRequest(http.MethodGet, url, nil) - if err != nil { - return fmt.Errorf("cannot create request to %q: %s", url, err) - } - resp, err := c.do(req) - if err != nil { - return err - } - if resp.StatusCode != http.StatusOK { - return fmt.Errorf("bad status code: %d", resp.StatusCode) - } - return nil -} - func (c *Client) fetch(ctx context.Context, data []byte, streamCb StreamCallback) error { r := bytes.NewReader(data) url := c.addr + remoteReadPath