17.291. Class Submitter
Namespace: ArmoniK.Core.Common.gRPC.Services
Assembly: ArmoniK.Core.Common.dll
public class Submitter : ISubmitter
17.291.1. Inheritance
17.291.2. Implements
17.291.3. Inherited Members
object.Equals(object?), object.Equals(object?, object?), object.GetHashCode(), object.GetType(), object.MemberwiseClone(), object.ReferenceEquals(object?, object?), object.ToString()
17.291.4. Constructors
17.291.4.1. Submitter(IPushQueueStorage, IObjectStorage, ILogger<Submitter>, ISessionTable, ITaskTable, IResultTable, IPartitionTable, Submitter, ActivitySource)
[UsedImplicitly]
public Submitter(IPushQueueStorage pushQueueStorage, IObjectStorage objectStorage, ILogger<Submitter> logger, ISessionTable sessionTable, ITaskTable taskTable, IResultTable resultTable, IPartitionTable partitionTable, Submitter submitterOptions, ActivitySource activitySource)
17.291.4.1.1. Parameters
pushQueueStorage IPushQueueStorage
objectStorage IObjectStorage
sessionTable ISessionTable
taskTable ITaskTable
resultTable IResultTable
partitionTable IPartitionTable
submitterOptions Submitter
activitySource ActivitySource
17.291.5. Methods
17.291.5.1. CancelSession(string, CancellationToken)
public Task CancelSession(string sessionId, CancellationToken cancellationToken)
17.291.5.1.1. Parameters
sessionId string
cancellationToken CancellationToken
17.291.5.1.2. Returns
17.291.5.2. CompleteTaskAsync(TaskData, SessionData, bool, Output, CancellationToken)
public Task CompleteTaskAsync(TaskData taskData, SessionData sessionData, bool resubmit, Output output, CancellationToken cancellationToken = default)
17.291.5.2.1. Parameters
taskData TaskData
sessionData SessionData
resubmit bool
output Output
cancellationToken CancellationToken
17.291.5.2.2. Returns
17.291.5.3. CreateSession(IList<string>, TaskOptions, CancellationToken)
public Task<CreateSessionReply> CreateSession(IList<string> partitionIds, TaskOptions defaultTaskOptions, CancellationToken cancellationToken)
17.291.5.3.1. Parameters
defaultTaskOptions TaskOptions
cancellationToken CancellationToken
17.291.5.3.2. Returns
Task<CreateSessionReply>
17.291.5.4. CreateTasks(string, string, TaskOptions?, IAsyncEnumerable<TaskRequest>, CancellationToken)
public Task<ICollection<TaskCreationRequest>> CreateTasks(string sessionId, string parentTaskId, TaskOptions? options, IAsyncEnumerable<TaskRequest> taskRequests, CancellationToken cancellationToken)
17.291.5.4.1. Parameters
sessionId string
parentTaskId string
options TaskOptions?
taskRequests IAsyncEnumerable<TaskRequest>
cancellationToken CancellationToken
17.291.5.4.2. Returns
17.291.5.5. FinalizeTaskCreation(IEnumerable<TaskCreationRequest>, SessionData, string, CancellationToken)
public Task FinalizeTaskCreation(IEnumerable<TaskCreationRequest> requests, SessionData sessionData, string parentTaskId, CancellationToken cancellationToken)
17.291.5.5.1. Parameters
requests IEnumerable<TaskCreationRequest>
sessionData SessionData
parentTaskId string
cancellationToken CancellationToken
17.291.5.5.2. Returns
17.291.5.6. GetServiceConfiguration(Empty, CancellationToken)
public Task<Configuration> GetServiceConfiguration(Empty request, CancellationToken cancellationToken)
17.291.5.6.1. Parameters
request Empty
cancellationToken CancellationToken
17.291.5.6.2. Returns
Task<Configuration>
17.291.5.7. SetResult(string, string, string, IAsyncEnumerable<ReadOnlyMemory<byte>>, CancellationToken)
public Task SetResult(string sessionId, string ownerTaskId, string key, IAsyncEnumerable<ReadOnlyMemory<byte>> chunks, CancellationToken cancellationToken)
17.291.5.7.1. Parameters
sessionId string
ownerTaskId string
key string
chunks IAsyncEnumerable<ReadOnlyMemory<byte>>
cancellationToken CancellationToken
17.291.5.7.2. Returns
17.291.5.8. TryGetResult(ResultRequest, IServerStreamWriter<ResultReply>, CancellationToken)
public Task TryGetResult(ResultRequest request, IServerStreamWriter<ResultReply> responseStream, CancellationToken cancellationToken)
17.291.5.8.1. Parameters
request ResultRequest
responseStream IServerStreamWriter<ResultReply>
cancellationToken CancellationToken
17.291.5.8.2. Returns
17.291.5.9. WaitForAvailabilityAsync(ResultRequest, CancellationToken)
public Task<AvailabilityReply> WaitForAvailabilityAsync(ResultRequest request, CancellationToken contextCancellationToken)
17.291.5.9.1. Parameters
request ResultRequest
contextCancellationToken CancellationToken
17.291.5.9.2. Returns
Task<AvailabilityReply>
17.291.5.10. WaitForCompletion(WaitRequest, CancellationToken)
public Task<Count> WaitForCompletion(WaitRequest request, CancellationToken cancellationToken)
17.291.5.10.1. Parameters
request WaitRequest
cancellationToken CancellationToken
17.291.5.10.2. Returns
Task<Count>