Method JobGetAvailable

rivershared/riverpilot/pilot.go:31–31 · view source on GitHub ↗

(
		ctx context.Context,
		exec riverdriver.Executor,
		state ProducerState,
		params *riverdriver.JobGetAvailableParams,
	)

Source from the content-addressed store, hash-verified

29	JobCleanerQueuesExcluded() []string
30
31	JobGetAvailable(
32	ctx context.Context,
33	exec riverdriver.Executor,
34	state ProducerState,

dispatchWorkMethod · 0.65

JobGetAvailableMethod · 0.65

TestStandardPilot_JobGetAvailableFunction · 0.65

TestJobExecutor_ExecuteFunction · 0.65

pilotSpyclient_pilot_test.go

StandardPilotrivershared/riverpilot/standard_pilot.

no outgoing calls

JobGetAvailableMethod · 0.52

TestStandardPilot_JobGetAvailableFunction · 0.52

TestJobExecutor_ExecuteFunction · 0.52