MCPcopy
hub / github.com/riverqueue/river / After

Method After

job_list_params.go:299–307  ·  view source on GitHub ↗

After returns an updated filter set that will only return jobs after the given cursor.

(cursor *JobListCursor)

Source from the content-addressed store, hash-verified

297// After returns an updated filter set that will only return jobs
298// after the given cursor.
299func (p *JobListParams) After(cursor *JobListCursor) *JobListParams {
300 paramsCopy := p.copy()
301 if cursor.job == nil {
302 paramsCopy.after = cursor
303 } else {
304 paramsCopy.after = jobListCursorFromJobAndParams(cursor.job, paramsCopy)
305 }
306 return paramsCopy
307}
308
309// First returns an updated filter set that will only return the first
310// count jobs.

Callers 15

Example_subscriptionFunction · 0.80
WorkMethod · 0.80
waitOrTimeoutFunction · 0.80
Test_Client_CommonFunction · 0.80
Test_Client_Stop_CommonFunction · 0.80
Test_Client_InsertManyFunction · 0.80
Test_Client_JobListFunction · 0.80

Calls 2

copyMethod · 0.95

Tested by 15

Example_subscriptionFunction · 0.64
WorkMethod · 0.64
waitOrTimeoutFunction · 0.64
Test_Client_CommonFunction · 0.64
Test_Client_Stop_CommonFunction · 0.64
Test_Client_InsertManyFunction · 0.64
Test_Client_JobListFunction · 0.64