17.173. Class Pollster
Namespace: ArmoniK.Core.Common.Pollster
Assembly: ArmoniK.Core.Common.dll
public class Pollster : IInitializable, IHealthCheckProvider
17.173.1. Inheritance
17.173.2. Implements
IInitializable, IHealthCheckProvider
17.173.3. Inherited Members
object.Equals(object?), object.Equals(object?, object?), object.GetHashCode(), object.GetType(), object.MemberwiseClone(), object.ReferenceEquals(object?, object?), object.ToString()
17.173.4. Constructors
17.173.4.1. Pollster(IPullQueueStorage, DataPrefetcher, ComputePlane, Pollster, ExceptionManager, ActivitySource, ILogger<Pollster>, ILoggerFactory, IObjectStorage, IResultTable, ISubmitter, ISessionTable, ITaskTable, ITaskProcessingChecker, IWorkerStreamHandler, IAgentHandler, RunningTaskQueue, AgentIdentifier, MeterHolder)
public Pollster(IPullQueueStorage pullQueueStorage, DataPrefetcher dataPrefetcher, ComputePlane options, Pollster pollsterOptions, ExceptionManager exceptionManager, ActivitySource activitySource, ILogger<Pollster> logger, ILoggerFactory loggerFactory, IObjectStorage objectStorage, IResultTable resultTable, ISubmitter submitter, ISessionTable sessionTable, ITaskTable taskTable, ITaskProcessingChecker taskProcessingChecker, IWorkerStreamHandler workerStreamHandler, IAgentHandler agentHandler, RunningTaskQueue runningTaskQueue, AgentIdentifier identifier, MeterHolder meterHolder)
17.173.4.1.1. Parameters
pullQueueStorage IPullQueueStorage
dataPrefetcher DataPrefetcher
options ComputePlane
pollsterOptions Pollster
exceptionManager ExceptionManager
activitySource ActivitySource
loggerFactory ILoggerFactory
objectStorage IObjectStorage
resultTable IResultTable
submitter ISubmitter
sessionTable ISessionTable
taskTable ITaskTable
taskProcessingChecker ITaskProcessingChecker
workerStreamHandler IWorkerStreamHandler
agentHandler IAgentHandler
runningTaskQueue RunningTaskQueue
identifier AgentIdentifier
meterHolder MeterHolder
17.173.5. Properties
17.173.5.1. TaskProcessing
public ICollection<string> TaskProcessing { get; }
17.173.5.1.1. Property Value
17.173.6. Methods
17.173.6.1. Check(HealthCheckTag)
Checks the status of a class for the given health check type.
public Task<HealthCheckResult> Check(HealthCheckTag tag)
17.173.6.1.1. Parameters
tag HealthCheckTag
Health check for which the class has to answer.
17.173.6.1.2. Returns
The result of the check containing the status of the class for the health check type.
17.173.6.2. Init(CancellationToken)
Executes an initialization process for the class
public Task Init(CancellationToken cancellationToken)
17.173.6.2.1. Parameters
cancellationToken CancellationToken
Token used to cancel the execution of the method
17.173.6.2.2. Returns
Task representing the asynchronous execution of the method
17.173.6.3. MainLoop()
public Task MainLoop()
17.173.6.3.1. Returns
17.173.6.4. StopCancelledTask()
public Task StopCancelledTask()