Class EventLog

Namespace

Cratis.Chronicle.EventSequences

Assembly

Cratis.Chronicle.dll

Represents an implementation of IEventLog.

public class EventLog : EventSequence, IEventLog, IEventSequence

Inheritance

object

EventSequence

EventLog

Implements

IEventLog

IEventSequence

Inherited Members

EventSequence.Prepare(object)

EventSequence.AppendPrepared(EventSourceId, PreparedEvent, EventStreamType, EventStreamId, EventSourceType, CorrelationId, IEnumerable<string>, ConcurrencyScope, DateTimeOffset?, Subject)

EventSequence.AppendPreparedThroughEventSource(Type, EventSourceId, PreparedEvent, string, EventStreamId, CorrelationId, IEnumerable<string>, ConcurrencyScope, DateTimeOffset?, Subject)

EventSequence.VerifyContent(EventSequenceNumber, PreparedEvent, EventSourceId)

EventSequence.Append(EventSourceId, object, EventStreamType, EventStreamId, EventSourceType, CorrelationId, IEnumerable<string>, ConcurrencyScope, DateTimeOffset?, Subject)

EventSequence.AppendThroughEventSource(Type, EventSourceId, object, string, EventStreamId, CorrelationId, IEnumerable<string>, ConcurrencyScope, DateTimeOffset?, Subject)

EventSequence.AppendManyThroughEventSource(Type, EventSourceId, IEnumerable<object>, string, EventStreamId, CorrelationId, IEnumerable<string>, ConcurrencyScope, DateTimeOffset?, Subject)

EventSequence.AppendWithNamedTags(EventSourceId, object, IEnumerable<NamedTag>, EventStreamType, EventStreamId, EventSourceType, CorrelationId, IEnumerable<string>, ConcurrencyScope, DateTimeOffset?, Subject)

EventSequence.AppendOnce(EventSourceId, object, IdempotencyKey, EventStreamType, EventStreamId, EventSourceType, CorrelationId, IEnumerable<string>, ConcurrencyScope, DateTimeOffset?, Subject)

EventSequence.AppendOnceWithNamedTags(EventSourceId, object, IdempotencyKey, IEnumerable<NamedTag>, EventStreamType, EventStreamId, EventSourceType, CorrelationId, IEnumerable<string>, ConcurrencyScope, DateTimeOffset?, Subject)

EventSequence.AppendManyOnce(EventSourceId, IEnumerable<object>, IdempotencyKey, EventStreamType, EventStreamId, EventSourceType, CorrelationId, IEnumerable<string>, ConcurrencyScope, DateTimeOffset?, Subject)

EventSequence.AppendManyOnceWithNamedTags(EventSourceId, IEnumerable<object>, IdempotencyKey, IEnumerable<NamedTag>, EventStreamType, EventStreamId, EventSourceType, CorrelationId, IEnumerable<string>, ConcurrencyScope, DateTimeOffset?, Subject)

EventSequence.AppendMany(EventSourceId, IEnumerable<object>, EventStreamType, EventStreamId, EventSourceType, CorrelationId, IEnumerable<string>, ConcurrencyScope, DateTimeOffset?, Subject)

EventSequence.AppendManyWithNamedTags(EventSourceId, IEnumerable<object>, IEnumerable<NamedTag>, EventStreamType, EventStreamId, EventSourceType, CorrelationId, IEnumerable<string>, ConcurrencyScope, DateTimeOffset?, Subject)

EventSequence.AppendMany(IEnumerable<EventForEventSourceId>, CorrelationId, IEnumerable<string>, IDictionary<EventSourceId, ConcurrencyScope>)

EventSequence.AppendManyWithNamedTags(IEnumerable<EventForEventSourceId>, IEnumerable<NamedTag>, CorrelationId, IEnumerable<string>, IDictionary<EventSourceId, ConcurrencyScope>)

EventSequence.AppendMany(IEnumerable<EventForEventSourceId>, CorrelationId, IEnumerable<string>, IEnumerable<KeyValuePair<EventSourceId, ConcurrencyScope>>)

EventSequence.AppendManyWithNamedTags(IEnumerable<EventForEventSourceId>, IEnumerable<NamedTag>, CorrelationId, IEnumerable<string>, IEnumerable<KeyValuePair<EventSourceId, ConcurrencyScope>>)

EventSequence.HasEventsFor(EventSourceId)

EventSequence.GetMetadataAt(EventSequenceNumber, CancellationToken)

EventSequence.GetMetadataAt(IEnumerable<EventSequenceNumber>, CancellationToken)

EventSequence.GetFromSequenceNumber(EventSequenceNumber, EventSourceId, IEnumerable<EventType>)

EventSequence.GetForEventSourceIdAndEventTypes(EventSourceId, IEnumerable<EventType>, EventStreamType, EventStreamId, EventSourceType)

EventSequence.GetNextSequenceNumber()

EventSequence.GetTailSequenceNumber(EventSourceId, EventSourceType, EventStreamType, EventStreamId, IEnumerable<EventType>)

EventSequence.GetTailSequenceNumberForObserver(Type)

EventSequence.Revise(EventSequenceNumber, object)

EventSequence.Redact(EventSequenceNumber, RedactionReason)

EventSequence.Redact(EventSourceId, RedactionReason, params Type[])

EventSequence.CompleteStream(EventStreamType, EventStreamId)

EventSequence.CompleteStream(ClosedStreamScope, EventSequenceNumber)

EventSequence.IsStreamCompleted(ClosedStreamScope)

EventSequence.IsStreamCompleted(EventStreamType, EventStreamId)

EventSequence.GetClosedStreams(ClosedStreamScope)

EventSequence.Id

EventSequence.AppendOperations

EventSequence.Transactional

EventSequence.SupportsIdempotentAppends

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Extension Methods

MethodCalls.CallGenericMethod<TOut, T>(T, Expression<Func<T, Func<TOut>>>, params Type[])

MethodCalls.CallGenericMethod<TOut, T, T1>(T, Expression<Func<T, Func<T1, TOut>>>, T1, params Type[])

MethodCalls.CallGenericMethod<TOut, T, T1, T2>(T, Expression<Func<T, Func<T1, T2, TOut>>>, T1, T2, params Type[])

MethodCalls.CallGenericMethod<TOut, T, T1, T2, T3>(T, Expression<Func<T, Func<T1, T2, T3, TOut>>>, T1, T2, T3, params Type[])

EventSequenceEventSourceExtensions.Append(IEventSequence, Type, EventSourceId, object, string?, EventStreamId?, CorrelationId?, IEnumerable<string>?, ConcurrencyScope?, DateTimeOffset?, Subject?)

EventSequenceEventSourceExtensions.AppendMany(IEventSequence, Type, EventSourceId, IEnumerable<object>, string?, EventStreamId?, CorrelationId?, IEnumerable<string>?, ConcurrencyScope?, DateTimeOffset?, Subject?)

EventSequenceEventSourceExtensions.AppendMany<TSource>(IEventSequence, EventSourceId, IEnumerable<object>, string?, EventStreamId?, CorrelationId?, IEnumerable<string>?, ConcurrencyScope?, DateTimeOffset?, Subject?)

EventSequenceEventSourceExtensions.AppendPrepared<TSource>(IEventSequence, EventSourceId, PreparedEvent, string?, EventStreamId?, CorrelationId?, IEnumerable<string>?, ConcurrencyScope?, DateTimeOffset?, Subject?)

EventSequenceEventSourceExtensions.Append<TSource>(IEventSequence, EventSourceId, object, string?, EventStreamId?, CorrelationId?, IEnumerable<string>?, ConcurrencyScope?, DateTimeOffset?, Subject?)

EventSequenceOperationExtensions.ForEventSourceId(IEventSequence, EventSourceId, Action<EventSourceOperations>)

DecisionReadExtensions.AppendMany(IEventSequence, IEnumerable<EventForEventSourceId>, IEnumerable<IDecisionRead>)

ConverterExtensions.ConvertTo(object, Type)

ConceptExtensions.GetConceptValue(object)

ConceptExtensions.IsConcept(object)

JsonValueExtensions.ToJsonValue(object?)

ObservableExtensions.InvokeAndWrapWithSubject<TResult>(object, Func<CancellationToken, IObservable<TResult>>)

ObservableExtensions.InvokeAndWrapWithTransformSubject<TResult, TSource>(object, Func<CancellationToken, IObservable<TSource>>, Func<TSource, TResult>)

Remarks

Initializes a new instance of the EventLog class.

Constructors

EventLog(EventStoreName, EventStoreNamespaceName, IChronicleConnection, IEventTypes, IConstraints, IEventSerializer, ICorrelationIdAccessor, IConcurrencyScopeStrategies, ICausationManager, IUnitOfWorkManager, IIdentityProvider, JsonSerializerOptions, IReactorSideEffectHandlers?, IEventSources?)

Represents an implementation of IEventLog.

public EventLog(EventStoreName eventStoreName, EventStoreNamespaceName @namespace, IChronicleConnection connection, IEventTypes eventTypes, IConstraints constraints, IEventSerializer eventSerializer, ICorrelationIdAccessor correlationIdAccessor, IConcurrencyScopeStrategies concurrencyScopeStrategies, ICausationManager causationManager, IUnitOfWorkManager unitOfWorkManager, IIdentityProvider identityProvider, JsonSerializerOptions jsonSerializerOptions, IReactorSideEffectHandlers? sideEffectHandlers = null, IEventSources? eventSources = null)

Parameters

eventStoreName EventStoreName

Name of the event store.

namespace EventStoreNamespaceName

EventStoreNamespaceName the sequence is for.

connection IChronicleConnection

IChronicleConnection for getting connections.

eventTypes IEventTypes

Known IEventTypes.

constraints IConstraints

Known IConstraints.

eventSerializer IEventSerializer

The IEventSerializer for serializing events.

correlationIdAccessor ICorrelationIdAccessor

ICorrelationIdAccessor for getting correlation.

concurrencyScopeStrategies IConcurrencyScopeStrategies

IConcurrencyScopeStrategies for managing concurrency scopes.

causationManager ICausationManager

ICausationManager for getting causation.

unitOfWorkManager IUnitOfWorkManager

IUnitOfWorkManager for working with the unit of work.

identityProvider IIdentityProvider

IIdentityProvider for resolving identity for operations.

jsonSerializerOptions JsonSerializerOptions

JSON serializer options to use.

sideEffectHandlers IReactorSideEffectHandlers

Optional handlers used to recognize synchronous reactor return types.

eventSources IEventSources

Optional IEventSources for appending through event source definitions.

Remarks

Initializes a new instance of the EventLog class.