Struct PendingRecordSearchParams<TStorageRecord>

a dto representing search parameters for pending event storage record retrieval

Inherited Members

ValueType.Equals(object)

ValueType.GetHashCode()

ValueType.ToString()

object.Equals(object, object)

object.GetType()

object.ReferenceEquals(object, object)

Namespace: FastEndpoints

Assembly: FastEndpoints.Messaging.Remote.Core.dll

Syntax

public struct PendingRecordSearchParams<TStorageRecord> where TStorageRecord : IEventStorageRecord

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.SubscriberID == "xxx" &&
     !r.IsComplete &&
     DateTime.UtcNow <= r.ExpireOn

Declaration

public readonly Expression<Func<TStorageRecord, bool>> Match { get; }

Property Value

Type	Description
Expression<Func<TStorageRecord, bool>>

SubscriberID

the subscriber ID for fetching the next batch of records

Declaration

public readonly string SubscriberID { get; }

Property Value

Type	Description
string