fixup! fixup! fixup! Add retries functionality.

This commit is contained in:
2022-06-08 15:42:28 +01:00
parent 3cda8e267b
commit 3232498e94
+7 -9
View File
@@ -107,18 +107,16 @@ func NewConnection() *GraphQL {
panic("Invalid value for RETRIES_ENABLE") panic("Invalid value for RETRIES_ENABLE")
} }
retriesNumber, retriesNumberExists := os.LookupEnv("RETRIES_NUMBER") retriesNumber, retriesNumberExists := os.LookupEnv("RETRIES_NUMBER")
if !retriesNumberExists { if retriesNumberExists {
panic("RETRIES_NUMBER environment variable is not set but RETRIES_ENABLE is") g.RetriesNumber, err = strconv.Atoi(retriesNumber)
} if err != nil {
g.RetriesNumber, err = strconv.Atoi(retriesNumber) panic("Invalid value for RETRIES_NUMBER")
if err != nil { }
panic("Invalid value for RETRIES_NUMBER")
} }
retriesDelay, retriesDelayExists := os.LookupEnv("RETRIES_DELAY") retriesDelay, retriesDelayExists := os.LookupEnv("RETRIES_DELAY")
if !retriesDelayExists { if retriesDelayExists {
panic("RETRIES_DELAY environment variable is not set but RETRIES_ENABLE is") g.RetriesDelay, err = strconv.Atoi(retriesDelay)
} }
g.RetriesDelay, err = strconv.Atoi(retriesDelay)
} }
return &g return &g
} }