Method GetDueRecurringAsync

Namespace

Millrace.Storage.PostgreSql

Assembly

Millrace.Storage.PostgreSql.dll

GetDueRecurringAsync(DateTimeOffset, int, CancellationToken)

Plain read of records with NextFireTime <= now, ordered NextFireTime ASC (most overdue first, so a backlog cannot starve old definitions), up to batchSize.

public ValueTask<IReadOnlyList<RecurringJobRecord>> GetDueRecurringAsync(DateTimeOffset now, int batchSize, CancellationToken ct)

Parameters

now DateTimeOffset

batchSize int

ct CancellationToken

Returns

ValueTask<IReadOnlyList<RecurringJobRecord>>