21.294. Class WatchToGrpc
Namespace: ArmoniK.Core.Common.gRPC.Services
Assembly: ArmoniK.Core.Common.dll
Convert the events from the different watchers and the data from the database to gRPC objects
public class WatchToGrpc
21.294.1. Inheritance
21.294.2. Inherited Members
object.Equals(object?), object.Equals(object?, object?), object.GetHashCode(), object.GetType(), object.MemberwiseClone(), object.ReferenceEquals(object?, object?), object.ToString()
21.294.3. Constructors
21.294.3.1. WatchToGrpc(ITaskTable, ITaskWatcher, IResultTable, IResultWatcher, ILogger)
Initializes the class from the given parameters
public WatchToGrpc(ITaskTable taskTable, ITaskWatcher taskWatcher, IResultTable resultTable, IResultWatcher resultWatcher, ILogger logger)
21.294.3.1.1. Parameters
taskTable ITaskTable
Interface to access task data
taskWatcher ITaskWatcher
Watcher to receive events when tasks are modified
resultTable IResultTable
Interface to access result data
resultWatcher IResultWatcher
Watcher to receive events when results are modified
logger ILogger
Logger used to produce logs for this class
21.294.4. Methods
21.294.4.1. GetEvents(string, ICollection<EventsEnum>, Filters?, Filters?, CancellationToken)
Get the task and result update events from the given session
public IAsyncEnumerable<EventSubscriptionResponse> GetEvents(string sessionId, ICollection<EventsEnum> events, Filters? tasksFilters, Filters? resultsFilters, CancellationToken cancellationToken)
21.294.4.1.1. Parameters
sessionId string
The id of the session
events ICollection<EventsEnum>
Events that should be returned
tasksFilters Filters?
Filter for results related events
resultsFilters Filters?
Filter for results related events
cancellationToken CancellationToken
Token used to cancel the execution of the method
21.294.4.1.2. Returns
IAsyncEnumerable<EventSubscriptionResponse>
An