Class UnitOfWorkManager

Namespace

Cratis.Chronicle.Transactions

Assembly

Cratis.Chronicle.dll

Represents an implementation of IUnitOfWorkManager.

public class UnitOfWorkManager : IUnitOfWorkManager

Inheritance

object

UnitOfWorkManager

Implements

IUnitOfWorkManager

Inherited Members

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

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

Constructors

UnitOfWorkManager(IEventStore, IActivitySource<UnitOfWork>?)

Initializes a manager with compatibility staging behavior.

public UnitOfWorkManager(IEventStore eventStore, IActivitySource<UnitOfWork>? activitySource = null)

Parameters

eventStore IEventStore

The event store.

activitySource IActivitySource<UnitOfWork>

Optional activity source.

UnitOfWorkManager(IEventStore, IActivitySource<UnitOfWork>?, UnitOfWorkLifecyclePolicy, ILogger<UnitOfWork>?)

Initializes a new instance of the UnitOfWorkManager class.

public UnitOfWorkManager(IEventStore eventStore, IActivitySource<UnitOfWork>? activitySource, UnitOfWorkLifecyclePolicy lifecyclePolicy, ILogger<UnitOfWork>? logger = null)

Parameters

eventStore IEventStore

The event store.

activitySource IActivitySource<UnitOfWork>

Optional activity source.

lifecyclePolicy UnitOfWorkLifecyclePolicy

The policy for staging after completion begins.

logger ILogger<UnitOfWork>

Optional logger for late staging diagnostics.

Properties

Current

Gets the current IUnitOfWork, scoped to the current async context.

public IUnitOfWork Current { get; }

Property Value

IUnitOfWork

Exceptions

NoUnitOfWorkHasBeenStarted

If no unit of work has been started.

HasCurrent

Gets a value indicating whether or not there is a current IUnitOfWork.

public bool HasCurrent { get; }

Property Value

bool

Methods

Begin(CorrelationId)

Begin a new IUnitOfWork with a specific CorrelationId for the current async context.

public IUnitOfWork Begin(CorrelationId correlationId)

Parameters

correlationId CorrelationId

The CorrelationId to use for the IUnitOfWork.

Returns

IUnitOfWork

A new IUnitOfWork.

SetCurrent(IUnitOfWork)

Set the current IUnitOfWork.

public void SetCurrent(IUnitOfWork unitOfWork)

Parameters

unitOfWork IUnitOfWork

The IUnitOfWork to set as current.

TryGetFor(CorrelationId, out IUnitOfWork)

Try to get the IUnitOfWork for a specific CorrelationId.

public bool TryGetFor(CorrelationId correlationId, out IUnitOfWork unitOfWork)

Parameters

correlationId CorrelationId

The CorrelationId to get the IUnitOfWork for.

unitOfWork IUnitOfWork

The IUnitOfWork if it was found, otherwise null.

Returns

bool

True if it was found, false if not.