17.290. Interface ISubmitter
Namespace: ArmoniK.Core.Common.gRPC.Services
Assembly: ArmoniK.Core.Common.dll
public interface ISubmitter
17.290.1. Methods
17.290.1.1. CancelSession(string, CancellationToken)
Task CancelSession(string sessionId, CancellationToken cancellationToken)
17.290.1.1.1. Parameters
sessionId string
cancellationToken CancellationToken
17.290.1.1.2. Returns
17.290.1.2. CompleteTaskAsync(TaskData, SessionData, bool, Output, CancellationToken)
Task CompleteTaskAsync(TaskData taskData, SessionData sessionData, bool resubmit, Output output, CancellationToken cancellationToken = default)
17.290.1.2.1. Parameters
taskData TaskData
sessionData SessionData
resubmit bool
output Output
cancellationToken CancellationToken
17.290.1.2.2. Returns
17.290.1.3. CreateSession(IList<string>, TaskOptions, CancellationToken)
Task<CreateSessionReply> CreateSession(IList<string> partitionIds, TaskOptions defaultTaskOptions, CancellationToken cancellationToken)
17.290.1.3.1. Parameters
defaultTaskOptions TaskOptions
cancellationToken CancellationToken
17.290.1.3.2. Returns
Task<CreateSessionReply>
17.290.1.4. CreateTasks(string, string, TaskOptions?, IAsyncEnumerable<TaskRequest>, CancellationToken)
Task<ICollection<TaskCreationRequest>> CreateTasks(string sessionId, string parentTaskId, TaskOptions? options, IAsyncEnumerable<TaskRequest> taskRequests, CancellationToken cancellationToken)
17.290.1.4.1. Parameters
sessionId string
parentTaskId string
options TaskOptions?
taskRequests IAsyncEnumerable<TaskRequest>
cancellationToken CancellationToken
17.290.1.4.2. Returns
17.290.1.5. FinalizeTaskCreation(IEnumerable<TaskCreationRequest>, SessionData, string, CancellationToken)
Task FinalizeTaskCreation(IEnumerable<TaskCreationRequest> requests, SessionData sessionData, string parentTaskId, CancellationToken cancellationToken)
17.290.1.5.1. Parameters
requests IEnumerable<TaskCreationRequest>
sessionData SessionData
parentTaskId string
cancellationToken CancellationToken
17.290.1.5.2. Returns
17.290.1.6. GetServiceConfiguration(Empty, CancellationToken)
Task<Configuration> GetServiceConfiguration(Empty request, CancellationToken cancellationToken)
17.290.1.6.1. Parameters
request Empty
cancellationToken CancellationToken
17.290.1.6.2. Returns
Task<Configuration>
17.290.1.7. SetResult(string, string, string, IAsyncEnumerable<ReadOnlyMemory<byte>>, CancellationToken)
Task SetResult(string sessionId, string ownerTaskId, string key, IAsyncEnumerable<ReadOnlyMemory<byte>> chunks, CancellationToken cancellationToken)
17.290.1.7.1. Parameters
sessionId string
ownerTaskId string
key string
chunks IAsyncEnumerable<ReadOnlyMemory<byte>>
cancellationToken CancellationToken
17.290.1.7.2. Returns
17.290.1.8. TryGetResult(ResultRequest, IServerStreamWriter<ResultReply>, CancellationToken)
Task TryGetResult(ResultRequest request, IServerStreamWriter<ResultReply> responseStream, CancellationToken cancellationToken)
17.290.1.8.1. Parameters
request ResultRequest
responseStream IServerStreamWriter<ResultReply>
cancellationToken CancellationToken
17.290.1.8.2. Returns
17.290.1.9. WaitForAvailabilityAsync(ResultRequest, CancellationToken)
Task<AvailabilityReply> WaitForAvailabilityAsync(ResultRequest request, CancellationToken contextCancellationToken)
17.290.1.9.1. Parameters
request ResultRequest
contextCancellationToken CancellationToken
17.290.1.9.2. Returns
Task<AvailabilityReply>
17.290.1.10. WaitForCompletion(WaitRequest, CancellationToken)
Task<Count> WaitForCompletion(WaitRequest request, CancellationToken cancellationToken)
17.290.1.10.1. Parameters
request WaitRequest
cancellationToken CancellationToken
17.290.1.10.2. Returns
Task<Count>