23.195. Interface ITaskWatcher
Namespace: ArmoniK.Core.Common.Storage.Events
Assembly: ArmoniK.Core.Common.dll
Interface used to receive events when Tasks are modified
public interface ITaskWatcher : IInitializable, IHealthCheckProvider
23.195.1. Implements
IInitializable, IHealthCheckProvider
23.195.2. Methods
23.195.2.1. GetNewTasks(Expression<Func<TaskData, bool>>, CancellationToken)
Receive a
Task<IAsyncEnumerable<NewTask>> GetNewTasks(Expression<Func<TaskData, bool>> filter, CancellationToken cancellationToken = default)
23.195.2.1.1. Parameters
filter Expression<Func<TaskData, bool>>
Filter expression describing the tasks events to be returned
cancellationToken CancellationToken
Token used to cancel the execution of the method
23.195.2.1.2. Returns
Task<IAsyncEnumerable<NewTask>>
A
23.195.2.2. GetTaskStatusUpdates(Expression<Func<TaskData, bool>>, CancellationToken)
Receive a
Task<IAsyncEnumerable<TaskStatusUpdate>> GetTaskStatusUpdates(Expression<Func<TaskData, bool>> filter, CancellationToken cancellationToken = default)
23.195.2.2.1. Parameters
filter Expression<Func<TaskData, bool>>
Filter expression describing the tasks events to be returned
cancellationToken CancellationToken
Token used to cancel the execution of the method
23.195.2.2.2. Returns
Task<IAsyncEnumerable<TaskStatusUpdate>>
A