add retry throttler

README.MD

@@ -159,6 +159,7 @@ thr := NewThrottlerAll( // throttles only if all children throttle
 | any | `func NewThrottlerAny(thrs ...Throttler) Throttler` | Throttles call if any of provided throttlers throttle. |
 | not | `func NewThrottlerNot(thr Throttler) Throttler` | Throttles call if provided throttler doesn't throttle. |
 | suppress | `func NewThrottlerSuppress(thr Throttler) Throttler` | Suppresses provided throttler to never throttle. |
+| retry | `func NewThrottlerRetry(thr Throttler, retries uint64) Throttler` | Retries provided throttler error up until the provided retries threshold.<br> Internally retry uses square throttler with `DefaultRetriedDuration` initial duration. |
 
 ## Integrations
 

throttlers.go

@@ -770,3 +770,26 @@ func (thr tsuppress) Release(ctx context.Context) error {
 	_ = thr.thr.Release(ctx)
 	return nil
 }
+
+type tretry struct {
+	thr     Throttler
+	retries uint64
+}
+
+// NewThrottlerRetry creates new throttler instance that
+// retries provided throttler error up until the provided retries threshold.
+// Internally retry uses square throttler with `DefaultRetriedDuration` initial duration.
+func NewThrottlerRetry(thr Throttler, retries uint64) Throttler {
+	return tretry{thr: thr, retries: retries}
+}
+
+func (thr tretry) Acquire(ctx context.Context) error {
+	return retried(thr.retries, func(ctx context.Context) error {
+		return thr.thr.Acquire(ctx)
+	})(ctx)
+}
+
+func (thr tretry) Release(ctx context.Context) error {
+	_ = thr.thr.Release(ctx)
+	return nil
+}

throttlers_test.go

@@ -102,6 +102,7 @@ func (t *tcase) result(index int) (dur time.Duration, err error) {
 }
 
 func TestThrottlers(t *testing.T) {
+	DefaultRetriedDuration = time.Millisecond
 	cctx, cancel := context.WithCancel(context.Background())
 	cancel()
 	table := map[string]tcase{
@@ -774,14 +775,32 @@ func TestThrottlers(t *testing.T) {
 				errors.New("throttler hasn't received any internal error"),
 			},
 		},
-		"Throttler suppress should not throttle on internal errors": {
+		"Throttler suppress should not throttle on internal error": {
 			tms: 3,
 			thr: NewThrottlerSuppress(NewThrottlerEcho(errors.New("test"))),
 		},
-		"Throttler suppress should throttle on non internal errors": {
+		"Throttler suppress should throttle on non internal error": {
 			tms: 3,
 			thr: NewThrottlerSuppress(NewThrottlerEcho(nil)),
 		},
+		"Throttler retry should throttle on recuring internal error": {
+			tms: 3,
+			thr: NewThrottlerRetry(NewThrottlerEcho(errors.New("test")), 2),
+			errs: []error{
+				errors.New("test"),
+				errors.New("test"),
+				errors.New("test"),
+			},
+		},
+		"Throttler retry should not throttle on retried recuring internal error": {
+			tms: 3,
+			thr: NewThrottlerRetry(NewThrottlerAfter(3), 2),
+			errs: []error{
+				errors.New("test"),
+				nil,
+				nil,
+			},
+		},
 	}
 	for tname, ptrtcase := range table {
 		t.Run(tname, func(t *testing.T) {