Interface IEventSourceOperations

Namespace

Cratis.Chronicle.EventSequences.Operations

Assembly

Cratis.Chronicle.dll

Defines operations related to a specific event source within an event sequence.

public interface IEventSourceOperations

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[])

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>)

Properties

ConcurrencyScope

Gets the concurrency scope for the operations.

ConcurrencyScope ConcurrencyScope { get; }

Property Value

ConcurrencyScope

Operations

Gets the operations associated with the event source.

IEnumerable<IEventSequenceOperation> Operations { get; }

Property Value

IEnumerable<IEventSequenceOperation>

Methods

Append(object, Causation?, EventStreamType?, EventStreamId?, EventSourceType?, IEnumerable<string>?, DateTimeOffset?, Subject?)

Appends an event to the operation.

EventSourceOperations Append(object @event, Causation? causation = null, EventStreamType? eventStreamType = null, EventStreamId? eventStreamId = null, EventSourceType? eventSourceType = null, IEnumerable<string>? tags = null, DateTimeOffset? occurred = null, Subject? subject = null)

Parameters

event object

The event to append.

causation Causation

Optional causation for the event.

eventStreamType EventStreamType

Optional The type of event stream.

eventStreamId EventStreamId

Optional The identifier for the event stream.

eventSourceType EventSourceType

Optional The type of event source.

tags IEnumerable<string>

Optional dynamic tags to associate with the event.

occurred DateTimeOffset?

Optional timestamp for when the event occurred.

subject Subject

Optional subject identifying what the event is about.

Returns

EventSourceOperations

The current instance of EventSourceOperations.

GetAppendedEvents()

Gets the events that have been appended in the operation builders.

IEnumerable<object> GetAppendedEvents()

Returns

IEnumerable<object>

Collection of events.

GetOperationsOfType<T>()

Gets the operations of a specific type.

IEnumerable<T> GetOperationsOfType<T>() where T : IEventSequenceOperation

Returns

IEnumerable<T>

Collection of operations of the specified type.

Type Parameters

T

The type of operations to retrieve.

WithConcurrencyScope(ConcurrencyScope)

Configures the concurrency scope for the operations with a specific scope.

EventSourceOperations WithConcurrencyScope(ConcurrencyScope concurrencyScope)

Parameters

concurrencyScope ConcurrencyScope

The concurrency scope to set.

Returns

EventSourceOperations

The current instance of EventSourceOperations.

Remarks

A NotSet value does not override a scope that has already been set for the event source, so that a later event added without a scope cannot silently disable the concurrency check. A non-NotSet value overrides any previously set scope.

WithConcurrencyScope(Action<ConcurrencyScopeBuilder>)

Configures the concurrency scope for the operations.

EventSourceOperations WithConcurrencyScope(Action<ConcurrencyScopeBuilder> configure)

Parameters

configure Action<ConcurrencyScopeBuilder>

Action to configure the concurrency scope.

Returns

EventSourceOperations

The current instance of EventSourceOperations.