summaryrefslogtreecommitdiff
path: root/vendor/google.golang.org/grpc/internal/backoff/backoff.go
diff options
context:
space:
mode:
authorLibravatar Terin Stock <terinjokes@gmail.com>2025-03-09 17:47:56 +0100
committerLibravatar Terin Stock <terinjokes@gmail.com>2025-03-10 01:59:49 +0100
commit3ac1ee16f377d31a0fb80c8dae28b6239ac4229e (patch)
treef61faa581feaaeaba2542b9f2b8234a590684413 /vendor/google.golang.org/grpc/internal/backoff/backoff.go
parent[chore] update URLs to forked source (diff)
downloadgotosocial-3ac1ee16f377d31a0fb80c8dae28b6239ac4229e.tar.xz
[chore] remove vendor
Diffstat (limited to 'vendor/google.golang.org/grpc/internal/backoff/backoff.go')
-rw-r--r--vendor/google.golang.org/grpc/internal/backoff/backoff.go109
1 files changed, 0 insertions, 109 deletions
diff --git a/vendor/google.golang.org/grpc/internal/backoff/backoff.go b/vendor/google.golang.org/grpc/internal/backoff/backoff.go
deleted file mode 100644
index b6ae7f258..000000000
--- a/vendor/google.golang.org/grpc/internal/backoff/backoff.go
+++ /dev/null
@@ -1,109 +0,0 @@
-/*
- *
- * Copyright 2017 gRPC authors.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
- */
-
-// Package backoff implement the backoff strategy for gRPC.
-//
-// This is kept in internal until the gRPC project decides whether or not to
-// allow alternative backoff strategies.
-package backoff
-
-import (
- "context"
- "errors"
- rand "math/rand/v2"
- "time"
-
- grpcbackoff "google.golang.org/grpc/backoff"
-)
-
-// Strategy defines the methodology for backing off after a grpc connection
-// failure.
-type Strategy interface {
- // Backoff returns the amount of time to wait before the next retry given
- // the number of consecutive failures.
- Backoff(retries int) time.Duration
-}
-
-// DefaultExponential is an exponential backoff implementation using the
-// default values for all the configurable knobs defined in
-// https://github.com/grpc/grpc/blob/master/doc/connection-backoff.md.
-var DefaultExponential = Exponential{Config: grpcbackoff.DefaultConfig}
-
-// Exponential implements exponential backoff algorithm as defined in
-// https://github.com/grpc/grpc/blob/master/doc/connection-backoff.md.
-type Exponential struct {
- // Config contains all options to configure the backoff algorithm.
- Config grpcbackoff.Config
-}
-
-// Backoff returns the amount of time to wait before the next retry given the
-// number of retries.
-func (bc Exponential) Backoff(retries int) time.Duration {
- if retries == 0 {
- return bc.Config.BaseDelay
- }
- backoff, max := float64(bc.Config.BaseDelay), float64(bc.Config.MaxDelay)
- for backoff < max && retries > 0 {
- backoff *= bc.Config.Multiplier
- retries--
- }
- if backoff > max {
- backoff = max
- }
- // Randomize backoff delays so that if a cluster of requests start at
- // the same time, they won't operate in lockstep.
- backoff *= 1 + bc.Config.Jitter*(rand.Float64()*2-1)
- if backoff < 0 {
- return 0
- }
- return time.Duration(backoff)
-}
-
-// ErrResetBackoff is the error to be returned by the function executed by RunF,
-// to instruct the latter to reset its backoff state.
-var ErrResetBackoff = errors.New("reset backoff state")
-
-// RunF provides a convenient way to run a function f repeatedly until the
-// context expires or f returns a non-nil error that is not ErrResetBackoff.
-// When f returns ErrResetBackoff, RunF continues to run f, but resets its
-// backoff state before doing so. backoff accepts an integer representing the
-// number of retries, and returns the amount of time to backoff.
-func RunF(ctx context.Context, f func() error, backoff func(int) time.Duration) {
- attempt := 0
- timer := time.NewTimer(0)
- for ctx.Err() == nil {
- select {
- case <-timer.C:
- case <-ctx.Done():
- timer.Stop()
- return
- }
-
- err := f()
- if errors.Is(err, ErrResetBackoff) {
- timer.Reset(0)
- attempt = 0
- continue
- }
- if err != nil {
- return
- }
- timer.Reset(backoff(attempt))
- attempt++
- }
-}