22.173. Class Agent
Namespace: ArmoniK.Core.Common.Pollster
Assembly: ArmoniK.Core.Common.dll
Represents the internal processing requests received by the agent. Provides methods to process those requests
public sealed class Agent : IAgent, IDisposable
22.173.1. Inheritance
22.173.2. Implements
22.173.3. Inherited Members
object.Equals(object?), object.Equals(object?, object?), object.GetHashCode(), object.GetType(), object.ReferenceEquals(object?, object?), object.ToString()
22.173.4. Constructors
22.173.4.1. Agent(ISubmitter, IObjectStorage, IPushQueueStorage, IResultTable, ITaskTable, SessionData, TaskData, string, string, ILogger)
Initializes a new instance of the
public Agent(ISubmitter submitter, IObjectStorage objectStorage, IPushQueueStorage pushQueueStorage, IResultTable resultTable, ITaskTable taskTable, SessionData sessionData, TaskData taskData, string folder, string token, ILogger logger)
22.173.4.1.1. Parameters
submitter ISubmitter
Interface to manage tasks
objectStorage IObjectStorage
Interface class to manage tasks data
pushQueueStorage IPushQueueStorage
Interface to put tasks in the queue
resultTable IResultTable
Interface to manage result states
taskTable ITaskTable
Interface to manage task states
sessionData SessionData
OpaqueId of the session
taskData TaskData
OpaqueId of the task
folder string
Shared folder between Agent and Worker
token string
Token send to the worker to identify the running task
logger ILogger
Logger used to produce logs for this class
22.173.5. Properties
22.173.5.1. Folder
Folder in which data are sent between agent and worker
public string Folder { get; }
22.173.5.1.1. Property Value
22.173.5.2. SessionId
Id of the session from the task associated to the agent
public string SessionId { get; }
22.173.5.2.1. Property Value
22.173.5.3. Token
Unique token to identify agent and requests it should process
public string Token { get; }
22.173.5.3.1. Property Value
22.173.6. Methods
22.173.6.1. CreateResults(string, IEnumerable<(ResultCreationRequest request, ReadOnlyMemory<byte> data)>, CancellationToken)
Create a result (with data and metadata)
public Task<ICollection<Result>> CreateResults(string token, IEnumerable<(ResultCreationRequest request, ReadOnlyMemory<byte> data)> requests, CancellationToken cancellationToken)
22.173.6.1.1. Parameters
token string
Worker token for request validation
requests IEnumerable<(ResultCreationRequest request, ReadOnlyMemory<byte> data)>
Requests containing the result to create and their data
cancellationToken CancellationToken
Token used to cancel the execution of the method
22.173.6.1.2. Returns
Reply sent to the worker with the id of the created result
22.173.6.2. CreateResultsAndSubmitChildTasksAsync(CancellationToken)
Create and populate results and submit child tasks after the parent task succeeds
public Task CreateResultsAndSubmitChildTasksAsync(CancellationToken cancellationToken)
22.173.6.2.1. Parameters
cancellationToken CancellationToken
Token used to cancel the execution of the method
22.173.6.2.2. Returns
Task representing the asynchronous execution of the method
22.173.6.2.3. Exceptions
ArmoniKException
22.173.6.3. CreateResultsMetaData(string, IEnumerable<ResultCreationRequest>, CancellationToken)
Create results metadata
public Task<ICollection<Result>> CreateResultsMetaData(string token, IEnumerable<ResultCreationRequest> requests, CancellationToken cancellationToken)
22.173.6.3.1. Parameters
token string
Worker token for request validation
requests IEnumerable<ResultCreationRequest>
Requests containing the results to create
cancellationToken CancellationToken
Token used to cancel the execution of the method
22.173.6.3.2. Returns
Reply sent to the worker with the created results
22.173.6.4. Dispose()
Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.
public void Dispose()
22.173.6.5. GetCommonData(string, string, CancellationToken)
Get Common data from data storage as file in shared folder
public Task<string> GetCommonData(string token, string resultId, CancellationToken cancellationToken)
22.173.6.5.1. Parameters
token string
Worker token for request validation
resultId string
Result id to retrieve
cancellationToken CancellationToken
Token used to cancel the execution of the method
22.173.6.5.2. Returns
Id of the result sent to the worker
22.173.6.6. GetDirectData(string, string, CancellationToken)
Get Direct data from user as file in shared folder
public Task<string> GetDirectData(string token, string resultId, CancellationToken cancellationToken)
22.173.6.6.1. Parameters
token string
Worker token for request validation
resultId string
Result id to retrieve
cancellationToken CancellationToken
Token used to cancel the execution of the method
22.173.6.6.2. Returns
Id of the result sent to the worker
22.173.6.7. GetResourceData(string, string, CancellationToken)
Get Resource data from data storage as file in shared folder
public Task<string> GetResourceData(string token, string resultId, CancellationToken cancellationToken)
22.173.6.7.1. Parameters
token string
Worker token for request validation
resultId string
Result id to retrieve
cancellationToken CancellationToken
Token used to cancel the execution of the method
22.173.6.7.2. Returns
Id of the result sent to the worker
22.173.6.8. NotifyResultData(string, ICollection<string>, CancellationToken)
Put the results created as a file in the task into object storage
public Task<ICollection<string>> NotifyResultData(string token, ICollection<string> resultIds, CancellationToken cancellationToken)
22.173.6.8.1. Parameters
token string
Worker token for request validation
resultIds ICollection<string>
Results to put in the object storage
cancellationToken CancellationToken
Token used to cancel the execution of the method
22.173.6.8.2. Returns
Results which notification is successful
22.173.6.9. SubmitTasks(ICollection<TaskSubmissionRequest>, TaskOptions?, string, string, CancellationToken)
Submit tasks with payload already existing
public Task<ICollection<TaskCreationRequest>> SubmitTasks(ICollection<TaskSubmissionRequest> requests, TaskOptions? taskOptions, string sessionId, string token, CancellationToken cancellationToken)
22.173.6.9.1. Parameters
requests ICollection<TaskSubmissionRequest>
Requests containing the tasks to submit
taskOptions TaskOptions?
Options to apply to the tasks
sessionId string
Session id to which the tasks belong
token string
Worker token for request validation
cancellationToken CancellationToken
Token used to cancel the execution of the method
22.173.6.9.2. Returns
Task<ICollection<TaskCreationRequest>>
Submitted tasks to send to the worker