MCPcopy Index your code
hub / github.com/riverqueue/river / JobInsertFastMany

Method JobInsertFastMany

riverdriver/river_driver_interface.go:223–223  ·  view source on GitHub ↗
(ctx context.Context, params *JobInsertFastManyParams)

Source from the content-addressed store, hash-verified

221 JobGetByKindMany(ctx context.Context, params *JobGetByKindManyParams) ([]*rivertype.JobRow, error)
222 JobGetStuck(ctx context.Context, params *JobGetStuckParams) ([]*rivertype.JobRow, error)
223 JobInsertFastMany(ctx context.Context, params *JobInsertFastManyParams) ([]*JobInsertFastResult, error)
224 JobInsertFastManyNoReturning(ctx context.Context, params *JobInsertFastManyParams) (int, error)
225 JobInsertFull(ctx context.Context, params *JobInsertFullParams) (*rivertype.JobRow, error)
226 JobInsertFullMany(ctx context.Context, jobs *JobInsertFullManyParams) ([]*rivertype.JobRow, error)

Callers 15

Test_Client_ErrorHandlerFunction · 0.65
Test_Client_SubscribeConfigFunction · 0.65
Test_Client_UnknownJobKindErrorsTheJobFunction · 0.65
Test_Producer_CanSafelyCompleteJobsWhileFetchingNewOnesFunction · 0.65
testProducerFunction · 0.65
JobInsertManyMethod · 0.65
JobInsertFastManyMethod · 0.65
JobInsertFastManyMethod · 0.65
JobInsertFastManyMethod · 0.65
exerciseSchemaNameFunction · 0.65
exerciseJobInsertFunction · 0.65
BenchmarkDriverRiverPgxV5_ExecutorFunction · 0.65

Implementers 3

Executorriverdriver/riverpgxv5/river_pgx_v5_dr
Executorriverdriver/riverdatabasesql/river_dat
Executorriverdriver/riversqlite/river_sqlite_d

Calls

no outgoing calls

Tested by 11

Test_Client_ErrorHandlerFunction · 0.52
Test_Client_SubscribeConfigFunction · 0.52
Test_Client_UnknownJobKindErrorsTheJobFunction · 0.52
Test_Producer_CanSafelyCompleteJobsWhileFetchingNewOnesFunction · 0.52
testProducerFunction · 0.52
BenchmarkDriverRiverPgxV5_ExecutorFunction · 0.52
BenchmarkDriverRiverPgxV5InsertFunction · 0.52
TestPeriodicJobEnqueuerFunction · 0.52
TestJobExecutor_ExecuteFunction · 0.52
testCompleterFunction · 0.52
benchmarkCompleterFunction · 0.52