30.190. Class TaskProcessingCheckerClient

Namespace: ArmoniK.Core.Common.Pollster.TaskProcessingChecker
Assembly: ArmoniK.Core.Common.dll

Implements the interface to check if a task is being processed by a specific pod. Uses HTTP requests to communicate with other pods and determine task processing status, with retry and timeout logic.

public class TaskProcessingCheckerClient : ITaskProcessingChecker

30.190.1. Inheritance

object ← TaskProcessingCheckerClient

30.190.2. Implements

ITaskProcessingChecker

30.190.3. Inherited Members

object.Equals(object?), object.Equals(object?, object?), object.GetHashCode(), object.GetType(), object.MemberwiseClone(), object.ReferenceEquals(object?, object?), object.ToString()

30.190.4. Constructors

30.190.4.1. TaskProcessingCheckerClient(IHttpClientFactory, ILogger<TaskProcessingCheckerClient>)

Initializes a new instance of the class.

public TaskProcessingCheckerClient(IHttpClientFactory httpClientFactory, ILogger<TaskProcessingCheckerClient> logger)

30.190.4.1.1. Parameters

httpClientFactory IHttpClientFactory

The HTTP client factory used to create HTTP clients for communication with other pods.

logger ILogger<TaskProcessingCheckerClient>

The logger used for diagnostic and trace logging.

30.190.5. Methods

30.190.5.1. Check(string, string, CancellationToken)

Check if the task is running on the given pod

public Task<bool> Check(string taskId, string ownerPodId, CancellationToken cancellationToken)

30.190.5.1.1. Parameters

taskId string

id of the task to check

ownerPodId string

Id of the pod which should execute the task

cancellationToken CancellationToken

Token used to cancel the execution of the method

30.190.5.1.2. Returns

Task<bool>

A bool representing whether or not the task is running on the pod