mirror of
https://github.com/logos-messaging/logos-messaging-nim.git
synced 2026-01-03 22:43:09 +00:00
postgres_driver: remove duplicated const MaxNumConns. (#2106)
This commit is contained in:
parent
d5999fec4e
commit
a05c352f58
@ -81,8 +81,7 @@ proc new*(T: type ArchiveDriver,
|
||||
|
||||
of "postgres":
|
||||
when defined(postgres):
|
||||
const MaxNumConns = 5 #TODO: we may need to set that from app args (maybe?)
|
||||
let res = PostgresDriver.new(url, MaxNumConns, onErrAction)
|
||||
let res = PostgresDriver.new(dbUrl = url, onErrAction = onErrAction)
|
||||
if res.isErr():
|
||||
return err("failed to init postgres archive driver: " & res.error)
|
||||
|
||||
|
||||
@ -40,11 +40,11 @@ proc insertRow(): string =
|
||||
"""INSERT INTO messages (id, storedAt, contentTopic, payload, pubsubTopic,
|
||||
version, timestamp) VALUES ($1, $2, $3, $4, $5, $6, $7);"""
|
||||
|
||||
const DefaultMaxConnections = 5
|
||||
const MaxNumConns = 5 #TODO: we may need to set that from app args (maybe?)
|
||||
|
||||
proc new*(T: type PostgresDriver,
|
||||
dbUrl: string,
|
||||
maxConnections: int = DefaultMaxConnections,
|
||||
maxConnections: int = MaxNumConns,
|
||||
onErrAction: OnErrHandler = nil):
|
||||
ArchiveDriverResult[T] =
|
||||
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user