Class EventStoreBasedLastEventProcessedStore
Indicates the position in store where the stream has been read up to.
Inheritance
System.Object
EventStoreBasedLastEventProcessedStore
Inherited Members
System.Object.ToString()
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
Namespace: Cqrs.EventStore.Bus
Assembly: Cqrs.EventStore.dll
Syntax
public class EventStoreBasedLastEventProcessedStore : IStoreLastEventProcessed
Constructors
EventStoreBasedLastEventProcessedStore(IEventStoreConnection)
Instantiates a new instance of EventStoreBasedLastEventProcessedStore.
Declaration
public EventStoreBasedLastEventProcessedStore(IEventStoreConnection eventStoreConnection)
Parameters
Type | Name | Description |
---|---|---|
EventStore.ClientAPI.IEventStoreConnection | eventStoreConnection | The EventStore.ClientAPI.IEventStoreConnection used to read streams. |
Fields
EventsProcessedStreamName
The name of the event stream use to store the position/location information.
Declaration
public const string EventsProcessedStreamName = "EventsProcessed"
Field Value
Type | Description |
---|---|
System.String |
EventType
The name of the event type we use in the event stream to store the position/location information.
Declaration
public const string EventType = "ProcessedEvent"
Field Value
Type | Description |
---|---|
System.String |
Properties
EventLocation
The location within the store where the stream has been read up to.
Declaration
public string EventLocation { get; set; }
Property Value
Type | Description |
---|---|
System.String |
Implements
EventStoreConnection
The EventStore.ClientAPI.IEventStoreConnection used to read and write streams in the Greg Young Event Store.
Declaration
protected IEventStoreConnection EventStoreConnection { get; }
Property Value
Type | Description |
---|---|
EventStore.ClientAPI.IEventStoreConnection |