Class ConsumerCheckpoint

Namespace

Trellis.EntityFrameworkCore

Assembly

Trellis.EntityFrameworkCore.Inbox.dll

A persisted resume cursor: the last Position a pull consumer (ConsumerId) has advanced past in its source feed.

public sealed class ConsumerCheckpoint

Inheritance

object

ConsumerCheckpoint

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Extension Methods

MaybeExtensions.AsMaybe<T>(T)

AggregateTestMutator.ClearMaybeField<TEntity, TValue>(TEntity, Expression<Func<TEntity, Maybe<TValue>>>)

AggregateTestMutator.SetMaybeField<TEntity, TValue>(TEntity, Expression<Func<TEntity, Maybe<TValue>>>, TValue?)

Remarks

Performance state, not a domain aggregate. Losing or resetting it only forces a wider rescan — the inbox anti-join still guarantees once-effective processing — never incorrect processing.

Properties

ConsumerId

The stable subscriber identifier; the primary key.

public string ConsumerId { get; }

Property Value

string

Position

The opaque resume cursor into the source feed (the consumer's own encoding).

public string Position { get; }

Property Value

string

UpdatedAt

When this checkpoint was last advanced.

public DateTimeOffset UpdatedAt { get; }

Property Value

DateTimeOffset