From d843238d46245c65e77253c946d251ed54a6ad3d Mon Sep 17 00:00:00 2001 From: Lukasz Raczylo Date: Sat, 8 Apr 2023 01:59:28 +0100 Subject: [PATCH] Add missing retry mechanism. I have no idea how this was missed, but ho hum. --- request.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/request.go b/request.go index e5166a2..43dd852 100644 --- a/request.go +++ b/request.go @@ -5,6 +5,7 @@ import ( "fmt" "io/ioutil" "net/http" + "time" "github.com/avast/retry-go/v4" ) @@ -50,6 +51,13 @@ func (c *BaseClient) executeQuery(query []byte, headers any) (result any, err er return nil }, + retry.OnRetry(func(n uint, err error) { + c.Logger.Error(c, "Retrying query", "error", err.Error()) + }), + retry.Attempts(uint(c.retries.max)), + retry.DelayType(retry.BackOffDelay), + retry.Delay(time.Duration(c.retries.delay)*time.Second), + retry.LastErrorOnly(true), ) if len(queryResult.Errors) > 0 {