hub / github.com/riverqueue/river

github.com/riverqueue/river @v0.40.0 sqlite

repository ↗ · DeepWiki ↗ · release v0.40.0 ↗

2,951 symbols 13,991 edges 288 files 779 documented · 26%

Extension points exported contracts — how you extend this code

ClientRetryPolicy is an interface that can be implemented to provide a retry policy for how River deals with failed jobs [8 …

retry_policy.go

JobArgs (Interface)

JobArgs is an interface that represents the arguments for a job of type T. These arguments are serialized into JSON and [54 …

job.go

PeriodicSchedule (Interface)

PeriodicSchedule is a schedule for a periodic job. Periodic jobs should generally have an interval of at least 1 minute, [6 …

periodic_job.go

ExecutorTx (Interface)

ExecutorTx is an executor which is a transaction. In addition to standard Executor operations, it may be committed or ro [7 …

riverdriver/river_driver_interface.go

JobArgs (Interface)

JobArgs is an interface that should be implemented by the arguments to a job. This definition duplicates the JobArgs int [54 …

rivertype/river_type.go

BenchmarkerInterface (Interface)

BenchmarkerInterface is an interface to a Benchmarker. Its reason for existence is to wrap a benchmarker to strip it of [8 …

cmd/river/rivercli/driver_procurer.go

ErrorHandler (Interface)

ErrorHandler provides an interface that will be invoked in case of an error or panic occurring in the job. This is often [5 …

error_handler.go

ErrorHandler (Interface)

ErrorHandler provides an interface that will be invoked in case of an error or panic occurring in the job. This is often [5 …

internal/jobexecutor/job_executor.go

Core symbols most depended-on inside this repo

Run

called by 1151

cmd/river/rivercli/command.go

Ptr

called by 620

rivershared/util/ptrutil/ptr_util.go

Job

called by 404

rivershared/testfactory/test_factory.go

rivertype/time_generator.go

Helper

called by 267

rivertest/rivertest.go

WaitOrTimeout

called by 229

rivershared/riversharedtest/riversharedtest.go

New

called by 206

riverdriver/riverpgxv5/river_pgx_v5_driver.go

Shape

Method 1,413

Struct 738

Function 701

Interface 57

TypeAlias 23

FuncType 19

Languages

Go100%

Modules by API surface

riverdriver/river_driver_interface.go168 symbols

client_test.go133 symbols

riverdriver/riverpgxv5/river_pgx_v5_driver.go107 symbols

riverdriver/riversqlite/river_sqlite_driver.go104 symbols

riverdriver/riverdatabasesql/river_database_sql_driver.go102 symbols

client.go91 symbols

riverdriver/riversqlite/internal/dbsqlc/river_job.sql.go49 symbols

internal/leadership/elector.go45 symbols

riverdriver/riverpgxv5/internal/dbsqlc/river_job.sql.go43 symbols

riverdriver/riverdatabasesql/internal/dbsqlc/river_job.sql.go43 symbols

producer.go42 symbols

internal/riverinternaltest/sharedtx/shared_tx.go41 symbols

Used by 1 indexed graphs manifest dependencies, hub-wide

github.com/zitadel/zitadel

Dependencies from manifests, versioned

github.com/antlr4-go/antlr/v4v4.13.0 · 1×

github.com/coder/websocketv1.8.12 · 1×

github.com/davecgh/go-spewv1.1.1 · 1×

github.com/dustin/go-humanizev1.0.1 · 1×

github.com/google/uuidv1.6.0 · 1×

github.com/inconshreveable/mousetrapv1.1.0 · 1×

github.com/jackc/pgerrcodev0.0.0-2024031614390 · 1×

github.com/jackc/pgpassfilev1.0.0 · 1×

github.com/jackc/pgservicefilev0.0.0-2024060612052 · 1×

github.com/jackc/pgx/v5v5.10.0 · 1×

github.com/jackc/puddle/v2v2.2.2 · 1×

github.com/kr/prettyv0.3.0 · 1×

Datastores touched

river_devDatabase · 1 repos

river_testDatabase · 1 repos

For agents

$ claude mcp add river \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact