From ba517f56611fd3947ae1bd8c6ec1556e18164235 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Toma=C5=BE=20Jerman?= Date: Wed, 15 Jun 2022 15:09:55 +0200 Subject: [PATCH] Change default reconnect attempts for PGSQL and SQLITE --- store/adapters/rdbms/drivers/postgres/dal.go | 5 +++++ store/adapters/rdbms/drivers/sqlite/dal.go | 5 +++++ 2 files changed, 10 insertions(+) diff --git a/store/adapters/rdbms/drivers/postgres/dal.go b/store/adapters/rdbms/drivers/postgres/dal.go index 2066aeb4e..adf5548a1 100644 --- a/store/adapters/rdbms/drivers/postgres/dal.go +++ b/store/adapters/rdbms/drivers/postgres/dal.go @@ -25,6 +25,11 @@ func dalConnector(ctx context.Context, dsn string, cc ...capabilities.Capability return } + // @todo rework the config building a bit; this will do for now + if cfg.ConnTryMax >= 99 { + cfg.ConnTryMax = 2 + } + if db, err = rdbms.Connect(ctx, logger.Default(), cfg); err != nil { return } diff --git a/store/adapters/rdbms/drivers/sqlite/dal.go b/store/adapters/rdbms/drivers/sqlite/dal.go index 3c608e872..4ecacb4bf 100644 --- a/store/adapters/rdbms/drivers/sqlite/dal.go +++ b/store/adapters/rdbms/drivers/sqlite/dal.go @@ -25,6 +25,11 @@ func dalConnector(ctx context.Context, dsn string, cc ...capabilities.Capability return } + // @todo rework the config building a bit; this will do for now + if cfg.ConnTryMax >= 99 { + cfg.ConnTryMax = 2 + } + if db, err = rdbms.Connect(ctx, logger.Default(), cfg); err != nil { return }