23.169. Namespace ArmoniK.Core.Common.Pollster
23.169.1. Namespaces
23.169.2. Classes
Represents the internal processing requests received by the agent. Provides methods to process those requests
Represents the handler that will provide servers to process requests from worker
Represents an identifier for an agent, including the owner’s pod ID and pod name.
Prefetch data needed to execute a task
Controls the polling and processing of tasks from the queue, manages task execution lifecycle, and provides health check capabilities.
Represents a queue for managing tasks that are in the post-processing stage in the ArmoniK Pollster.
Inherits from
A background service that handles post-processing of completed tasks. It reads task handlers from the post-processing queue and finalizes them by performing result uploading, task submissions, message acknowledgment and recording the success.
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.
Represents a queue for managing running tasks in the
Handles the lifecycle and execution of a single task in the ArmoniK Pollster, including acquisition, preprocessing, execution, postprocessing, and error handling. Manages task and session metadata, agent communication, health checks, and resource cleanup for robust distributed task processing.
Queue to send
23.169.3. Interfaces
Interface for implementing methods for the agent gRPC service that receives requests from the worker
Interface to create classes that will populate
23.169.4. Enums
Represents the possible outcomes and reasons for attempting to acquire a task for processing in the ArmoniK system. Enumerates all acquisition results, including success, cancellation, task and session states, and various failure scenarios.