21.200. Interface IResultWatcher

Namespace: ArmoniK.Core.Common.Storage.Events
Assembly: ArmoniK.Core.Common.dll

Interface used to receive events when Results are modified

public interface IResultWatcher : IInitializable, IHealthCheckProvider

21.200.1. Implements

IInitializable, IHealthCheckProvider

21.200.2. Methods

21.200.2.1. GetNewResults(Expression<Func<Result, bool>>, CancellationToken)

Receive a event when a new result is added in the given session

Task<IAsyncEnumerable<NewResult>> GetNewResults(Expression<Func<Result, bool>> filter, CancellationToken cancellationToken = default)

21.200.2.1.1. Parameters

filter Expression<Func<Result, bool>>

Filter expression describing the results events to be returned

cancellationToken CancellationToken

Token used to cancel the execution of the method

21.200.2.1.2. Returns

Task<IAsyncEnumerable<NewResult>>

A that holds the updates when they are available

21.200.2.2. GetResultOwnerUpdates(Expression<Func<Result, bool>>, CancellationToken)

Receive a event when the OwnerId of a result changes in the given session

Task<IAsyncEnumerable<ResultOwnerUpdate>> GetResultOwnerUpdates(Expression<Func<Result, bool>> filter, CancellationToken cancellationToken = default)

21.200.2.2.1. Parameters

filter Expression<Func<Result, bool>>

Filter expression describing the results events to be returned

cancellationToken CancellationToken

Token used to cancel the execution of the method

21.200.2.2.2. Returns

Task<IAsyncEnumerable<ResultOwnerUpdate>>

A that holds the updates when they are available

21.200.2.3. GetResultStatusUpdates(Expression<Func<Result, bool>>, CancellationToken)

Receive a event when the Status of a result changes in the given session

Task<IAsyncEnumerable<ResultStatusUpdate>> GetResultStatusUpdates(Expression<Func<Result, bool>> filter, CancellationToken cancellationToken = default)

21.200.2.3.1. Parameters

filter Expression<Func<Result, bool>>

Filter expression describing the results events to be returned

cancellationToken CancellationToken

Token used to cancel the execution of the method

21.200.2.3.2. Returns

Task<IAsyncEnumerable<ResultStatusUpdate>>

A that holds the updates when they are available