Versions in this module Expand all Collapse all v0 v0.9.1 Aug 13, 2024 Changes in this version + func NewClient(pool *pgxpool.Pool, opts ...ClientCfgOpts) *river.Client[pgx.Tx] + type ClientCfgOpts func(cfg *clientCfg) + func WithErrorHandler(handler river.ErrorHandler) ClientCfgOpts + func WithFetchCooldown(cooldown time.Duration) ClientCfgOpts + func WithFetchPollInterval(interval time.Duration) ClientCfgOpts + func WithJobTimeout(timeout time.Duration) ClientCfgOpts + func WithLogger(logger *slog.Logger) ClientCfgOpts + func WithPeriodicJobs(jobs []*river.PeriodicJob) ClientCfgOpts + func WithQueues(queues map[string]river.QueueConfig) ClientCfgOpts + func WithWorkers(workers *river.Workers) ClientCfgOpts
Go to main page