Class TestOrchestrationEntityFeature

Namespace: XBullet.EasyTesting.AzureFunctions

Assembly: XBullet.EasyTesting.AzureFunctions.dll

Records orchestrator entity interactions and supplies explicitly configured call results.

public sealed class TestOrchestrationEntityFeature : TaskOrchestrationEntityFeature, ITestScenarioResource

Inheritance: object

TaskOrchestrationEntityFeature

TestOrchestrationEntityFeature

Implements: ITestScenarioResource

Inherited Members: TaskOrchestrationEntityFeature.CallEntityAsync<TResult>(EntityInstanceId, string, CallEntityOptions)

TaskOrchestrationEntityFeature.CallEntityAsync(EntityInstanceId, string, CallEntityOptions)

TaskOrchestrationEntityFeature.SignalEntityAsync(EntityInstanceId, string, SignalEntityOptions)

TaskOrchestrationEntityFeature.LockEntitiesAsync(params EntityInstanceId[])

TaskOrchestrationEntityFeature.InCriticalSection()

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Extension Methods: SnapshotAssertionExtensions.ShouldMatchSnapshot(object?, Action<SnapshotSettings>, CancellationToken, string, string)

SnapshotAssertionExtensions.ShouldMatchSnapshot(object?, string, CancellationToken, string, string)

SnapshotAssertionExtensions.ShouldMatchSnapshot(object?, SnapshotSettings?, CancellationToken, string, string)

Remarks

Attach with WithEntities(TaskOrchestrationEntityFeature). Signals record submissions only. Lock scopes mark local critical sections; they do not simulate distributed mutual exclusion. Configure handlers before use and await all operations before resetting.

Properties

CallHandler

Gets or sets entity call behavior.

public Func<RecordedEntityOperation, Task<object?>>? CallHandler { get; set; }

Property Value

Func<RecordedEntityOperation, Task<object>>: A required callback for calls, including void calls. Typed results use assignment compatibility.

Operations

Gets entity call attempts in invocation order.

public IReadOnlyList<RecordedEntityOperation> Operations { get; }

Property Value

IReadOnlyList<RecordedEntityOperation>: A detached list retaining original input and options references.

SignalHandler

Gets or sets signal submission behavior.

public Func<RecordedEntityOperation, Task>? SignalHandler { get; set; }

Property Value

Func<RecordedEntityOperation, Task>: An optional callback; null accepts and records the submission without delivery.

Methods

CallEntityAsync(EntityInstanceId, string, object?, CallEntityOptions?)

Calls an operation on an entity and waits for it to complete.

public override Task CallEntityAsync(EntityInstanceId id, string operationName, object? input = null, CallEntityOptions? options = null)

Parameters

id EntityInstanceId: The target entity.
operationName string: The name of the operation.
input object: The operation input.
options CallEntityOptions: The call options.

Returns

Task: A task that completes when the operation has been completed.

CallEntityAsync<TResult>(EntityInstanceId, string, object?, CallEntityOptions?)

Calls an operation on an entity and waits for it to complete.

public override Task<TResult> CallEntityAsync<TResult>(EntityInstanceId id, string operationName, object? input = null, CallEntityOptions? options = null)

Parameters

id EntityInstanceId: The target entity.
operationName string: The name of the operation.
input object: The operation input.
options CallEntityOptions: The call options.

Returns

Task<TResult>: The result of the entity operation.

Type Parameters

TResult: The result type of the entity operation.

CaptureDiagnosticsAsync(CancellationToken)

Captures entity IDs, operation names, kinds, and sequence numbers.

public ValueTask<object?> CaptureDiagnosticsAsync(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken: Cancels before capture.

Returns

ValueTask<object>: A detached snapshot excluding inputs, results, options, and failures.

InCriticalSection(out IReadOnlyList<EntityInstanceId>)

Gets a value indicating whether this orchestration is in a critical section, and if true, any entity locks are owned by this instance.

public override bool InCriticalSection(out IReadOnlyList<EntityInstanceId> entityIds)

Parameters

entityIds IReadOnlyList<EntityInstanceId>: The list of locked entities.

Returns

bool: True if any locks are owned, false otherwise.

LockEntitiesAsync(IEnumerable<EntityInstanceId>)

Acquires one or more entity locks.

public override Task<IAsyncDisposable> LockEntitiesAsync(IEnumerable<EntityInstanceId> entityIds)

Parameters

entityIds IEnumerable<EntityInstanceId>: The entity IDs to lock.

Returns

Task<IAsyncDisposable>: An async-disposable which can be disposed to release the lock.

ResetAsync(CancellationToken)

Clears recordings and active local scope markers, retaining configured handlers.

public ValueTask ResetAsync(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken: Cancels before any state changes.

Returns

ValueTask: A completed task after reset.

SignalEntityAsync(EntityInstanceId, string, object?, SignalEntityOptions?)

Calls an operation on an entity, but does not wait for completion.

public override Task SignalEntityAsync(EntityInstanceId id, string operationName, object? input = null, SignalEntityOptions? options = null)

Parameters

id EntityInstanceId: The target entity.
operationName string: The name of the operation.
input object: The operation input.
options SignalEntityOptions: The signal options.

Returns

Task: A task that represents scheduling of the signal operation. Dependening on implementation, this may complete either when the operation has been signalled, or when the signal action has been enqueued by the context.