21.168. Namespace ArmoniK.Core.Common.Pollster

21.168.1. Namespaces

ArmoniK.Core.Common.Pollster.TaskProcessingChecker

21.168.2. Classes

Agent

Represents the internal processing requests received by the agent. Provides methods to process those requests

AgentHandler

Represents the handler that will provide servers to process requests from worker

AgentIdentifier

Represents an identifier for an agent, including the owner’s pod ID and pod name.

DataPrefetcher

Prefetch data needed to execute a task

Pollster

Controls the polling and processing of tasks from the queue, manages task execution lifecycle, and provides health check capabilities.

PostProcessingTaskQueue

PostProcessor

RunningTaskProcessor

A background service that processes running tasks from a queue. It reads task handlers from the running task queue, executes them, and forwards completed tasks to the post-processing queue.

RunningTaskQueue

TaskHandler

TaskQueueBase

Queue to send from a single producer to a consumer.

21.168.3. Interfaces

IAgent

Interface for implementing methods for the agent gRPC service that receives requests from the worker

IAgentHandler

Interface to create classes that will populate when worker sends requests

21.168.4. Enums

AcquisitionStatus