Struct PendingJobSearchParams<TStorageRecord>
a dto representing search parameters for pending job storage record retrieval
Inherited Members
Namespace: FastEndpoints
Assembly: FastEndpoints.dll
Syntax
public struct PendingJobSearchParams<TStorageRecord> where TStorageRecord : IJobStorageRecord
Type Parameters
Name | Description |
---|---|
TStorageRecord | the type of storage record |
Properties
CancellationToken
cancellation token
Declaration
public readonly CancellationToken CancellationToken { get; }
Property Value
Type | Description |
---|---|
CancellationToken |
Limit
the number of pending records to fetch
Declaration
public readonly int Limit { get; }
Property Value
Type | Description |
---|---|
int |
Match
a boolean lambda expression to match the next batch of records
r => r.QueueID == "xxx" &&
!r.IsComplete &&
DateTime.UtcNow >= r.ExecuteAfter &&
DateTime.UtcNow <= r.ExpireOn
Declaration
public readonly Expression<Func<TStorageRecord, bool>> Match { get; }
Property Value
Type | Description |
---|---|
Expression<Func<TStorageRecord, bool>> |
QueueID
the ID of the job queue for fetching the next batch of records for.
Declaration
public readonly string QueueID { get; }
Property Value
Type | Description |
---|---|
string |