riverclient

Apr 2, 2024

Changes in this version

+ func NewRiverClient(pool *pgxpool.Pool, logger *zap.Logger, client *http.Client, numWorkers int) (*river.Client[pgx.Tx], error)

+ func RunMigration(pool *pgxpool.Pool) error