MCPcopy Create free account
hub / github.com/riverqueue/river / LeaderInsert

Method LeaderInsert

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

Source from the content-addressed store, hash-verified

237 LeaderDeleteExpired(ctx context.Context, params *LeaderDeleteExpiredParams) (int, error)
238 LeaderGetElectedLeader(ctx context.Context, params *LeaderGetElectedLeaderParams) (*Leader, error)
239 LeaderInsert(ctx context.Context, params *LeaderInsertParams) (*Leader, error)
240 LeaderResign(ctx context.Context, params *LeaderResignParams) (bool, error)
241
242 // MigrationDeleteAssumingMainMany deletes many migrations assuming

Callers 6

LeaderFunction · 0.65
LeaderInsertMethod · 0.65
LeaderInsertMethod · 0.65
LeaderInsertMethod · 0.65
exerciseLeaderFunction · 0.65
testElectorFunction · 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 1

testElectorFunction · 0.52