Skip to content

fix: keep postgres connections alive with heartbeat #797

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
harshsingh1002 merged 4 commits into from
Sep 19, 2025
Merged

fix: keep postgres connections alive with heartbeat #797

Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
42a916f
Update postgres.go
kant777 Sep 19, 2025
4155d7d
formatting
kant777 Sep 19, 2025
36fde9c
setting the timeout to 30 seconds since 5 seconds is not enought to a…
kant777 Sep 19, 2025
0968fe5
removing the ping logic
kant777 Sep 19, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
15 changes: 8 additions & 7 deletions cl/singlenode/payloadstore/postgres.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -27,9 +27,10 @@ func NewPostgresRepository(ctx context.Context, dsn string, logger *slog.Logger)
return nil, fmt.Errorf("failed to open postgres connection: %w", err)
}

db.SetMaxOpenConns(10)
db.SetMaxIdleConns(5)
db.SetConnMaxLifetime(5 * time.Minute)
db.SetMaxOpenConns(25)
db.SetMaxIdleConns(20)
db.SetConnMaxLifetime(0)
db.SetConnMaxIdleTime(0)

pingCtx, cancel := context.WithTimeout(ctx, 5*time.Second)
defer cancel()
Expand Down Expand Up @@ -101,7 +102,7 @@ func (r *PostgresRepository) SavePayload(ctx context.Context, info *types.Payloa
inserted_at = NOW();
`

insertCtx, cancel := context.WithTimeout(ctx, 5*time.Second)
insertCtx, cancel := context.WithTimeout(ctx, 30*time.Second)
defer cancel()

result, err := r.db.ExecContext(insertCtx, query, info.PayloadID, info.ExecutionPayload, info.BlockHeight)
Expand Down Expand Up @@ -205,7 +206,7 @@ func (r *PostgresRepository) GetPayloadByHeight(ctx context.Context, height uint
WHERE block_height = $1;
`

queryCtx, cancel := context.WithTimeout(ctx, 5*time.Second)
queryCtx, cancel := context.WithTimeout(ctx, 30*time.Second)
defer cancel()

var payload types.PayloadInfo
Expand Down Expand Up @@ -247,7 +248,7 @@ func (r *PostgresRepository) GetLatestPayload(ctx context.Context) (*types.Paylo
LIMIT 1;
`

queryCtx, cancel := context.WithTimeout(ctx, 5*time.Second)
queryCtx, cancel := context.WithTimeout(ctx, 30*time.Second)
defer cancel()

var payload types.PayloadInfo
Expand Down Expand Up @@ -286,7 +287,7 @@ func (r *PostgresRepository) GetLatestHeight(ctx context.Context) (uint64, error
ORDER BY block_height DESC
LIMIT 1;
`
queryCtx, cancel := context.WithTimeout(ctx, 5*time.Second)
queryCtx, cancel := context.WithTimeout(ctx, 30*time.Second)
defer cancel()

var h int64
Expand Down
Loading