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

Method JobUpdateFull

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

Source from the content-addressed store, hash-verified

232 JobSetStateIfRunningMany(ctx context.Context, params *JobSetStateIfRunningManyParams) ([]*rivertype.JobRow, error)
233 JobUpdate(ctx context.Context, params *JobUpdateParams) (*rivertype.JobRow, error)
234 JobUpdateFull(ctx context.Context, params *JobUpdateFullParams) (*rivertype.JobRow, error)
235 LeaderAttemptElect(ctx context.Context, params *LeaderElectParams) (*Leader, error)
236 LeaderAttemptReelect(ctx context.Context, params *LeaderReelectParams) (*Leader, error)
237 LeaderDeleteExpired(ctx context.Context, params *LeaderDeleteExpiredParams) (int, error)

Callers 10

Test_Client_RetryPolicyFunction · 0.65
Test_Client_JobCompletionFunction · 0.65
TestMiddlewareFunction · 0.65
JobUpdateFullMethod · 0.65
JobUpdateFullMethod · 0.65
JobUpdateFullMethod · 0.65
exerciseJobUpdateFunction · 0.65
exerciseJobInsertFunction · 0.65
TestJobExecutor_ExecuteFunction · 0.65
workJobMethod · 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 4

Test_Client_RetryPolicyFunction · 0.52
Test_Client_JobCompletionFunction · 0.52
TestMiddlewareFunction · 0.52
TestJobExecutor_ExecuteFunction · 0.52