Method JobSetStateIfRunningMany

client_pilot_test.go:87–90

(ctx context.Context, exec riverdriver.Executor, params *riverdriver.JobSetStateIfRunningManyParams)

}

func (p *pilotSpy) JobSetStateIfRunningMany(ctx context.Context, exec riverdriver.Executor, params *riverdriver.JobSetStateIfRunningManyParams) ([]*rivertype.JobRow, error) {
	p.testSignals.JobSetStateIfRunningMany.Signal(struct{}{})
	return p.StandardPilot.JobSetStateIfRunningMany(ctx, exec, params)
}

func (p *pilotSpy) PeriodicJobGetAll(ctx context.Context, exec riverdriver.Executor, params *riverpilot.PeriodicJobGetAllParams) ([]*riverpilot.PeriodicJob, error) {
	p.testSignals.PeriodicJobGetAll.Signal(struct{}{})