From 0c32306947f0ace127f47d5aacbb049fd1ed2795 Mon Sep 17 00:00:00 2001 From: netsi Date: Thu, 9 Feb 2023 16:24:50 +0100 Subject: [PATCH] conc: ddb-lock use backoff settings provided; --- pkg/conc/ddb/ddb_lock_provider.go | 15 ++++++++++++++- 1 file changed, 14 insertions(+), 1 deletion(-) diff --git a/pkg/conc/ddb/ddb_lock_provider.go b/pkg/conc/ddb/ddb_lock_provider.go index 57d7555dc..cd95b1992 100644 --- a/pkg/conc/ddb/ddb_lock_provider.go +++ b/pkg/conc/ddb/ddb_lock_provider.go @@ -64,10 +64,23 @@ func NewDdbLockProvider(ctx context.Context, config cfg.Config, logger log.Logge return nil, fmt.Errorf("can not create ddb repository: %w", err) } + backoffConfig := backoff.NewExponentialBackOff() + if settings.Backoff.InitialInterval > 0 { + backoffConfig.InitialInterval = settings.Backoff.InitialInterval + } + + if settings.Backoff.MaxInterval > 0 { + backoffConfig.MaxInterval = settings.Backoff.MaxInterval + } + + if settings.Backoff.MaxElapsedTime > 0 { + backoffConfig.MaxElapsedTime = settings.Backoff.MaxElapsedTime + } + return NewDdbLockProviderWithInterfaces( logger, repo, - backoff.NewExponentialBackOff(), + backoffConfig, clock.NewRealClock(), uuid.New(), settings,