21.290. Interface ISubmitter
Namespace: ArmoniK.Core.Common.gRPC.Services
Assembly: ArmoniK.Core.Common.dll
public interface ISubmitter
21.290.1. Methods
21.290.1.1. CancelSession(string, CancellationToken)
Task CancelSession(string sessionId, CancellationToken cancellationToken)
21.290.1.1.1. Parameters
sessionId string
cancellationToken CancellationToken
21.290.1.1.2. Returns
21.290.1.2. CompleteTaskAsync(TaskData, SessionData, bool, Output, CancellationToken)
Task CompleteTaskAsync(TaskData taskData, SessionData sessionData, bool resubmit, Output output, CancellationToken cancellationToken = default)
21.290.1.2.1. Parameters
taskData TaskData
sessionData SessionData
resubmit bool
output Output
cancellationToken CancellationToken
21.290.1.2.2. Returns
21.290.1.3. CreateSession(IList<string>, TaskOptions, CancellationToken)
Task<CreateSessionReply> CreateSession(IList<string> partitionIds, TaskOptions defaultTaskOptions, CancellationToken cancellationToken)
21.290.1.3.1. Parameters
defaultTaskOptions TaskOptions
cancellationToken CancellationToken
21.290.1.3.2. Returns
Task<CreateSessionReply>
21.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)
21.290.1.4.1. Parameters
sessionId string
parentTaskId string
options TaskOptions?
taskRequests IAsyncEnumerable<TaskRequest>
cancellationToken CancellationToken
21.290.1.4.2. Returns
21.290.1.5. FinalizeTaskCreation(IEnumerable<TaskCreationRequest>, SessionData, string, CancellationToken)
Task FinalizeTaskCreation(IEnumerable<TaskCreationRequest> requests, SessionData sessionData, string parentTaskId, CancellationToken cancellationToken)
21.290.1.5.1. Parameters
requests IEnumerable<TaskCreationRequest>
sessionData SessionData
parentTaskId string
cancellationToken CancellationToken
21.290.1.5.2. Returns
21.290.1.6. GetServiceConfiguration(Empty, CancellationToken)
Task<Configuration> GetServiceConfiguration(Empty request, CancellationToken cancellationToken)
21.290.1.6.1. Parameters
request Empty
cancellationToken CancellationToken
21.290.1.6.2. Returns
Task<Configuration>
21.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)
21.290.1.7.1. Parameters
sessionId string
ownerTaskId string
key string
chunks IAsyncEnumerable<ReadOnlyMemory<byte>>
cancellationToken CancellationToken
21.290.1.7.2. Returns
21.290.1.8. TryGetResult(ResultRequest, IServerStreamWriter<ResultReply>, CancellationToken)
Task TryGetResult(ResultRequest request, IServerStreamWriter<ResultReply> responseStream, CancellationToken cancellationToken)
21.290.1.8.1. Parameters
request ResultRequest
responseStream IServerStreamWriter<ResultReply>
cancellationToken CancellationToken
21.290.1.8.2. Returns
21.290.1.9. WaitForAvailabilityAsync(ResultRequest, CancellationToken)
Task<AvailabilityReply> WaitForAvailabilityAsync(ResultRequest request, CancellationToken contextCancellationToken)
21.290.1.9.1. Parameters
request ResultRequest
contextCancellationToken CancellationToken
21.290.1.9.2. Returns
Task<AvailabilityReply>
21.290.1.10. WaitForCompletion(WaitRequest, CancellationToken)
Task<Count> WaitForCompletion(WaitRequest request, CancellationToken cancellationToken)
21.290.1.10.1. Parameters
request WaitRequest
cancellationToken CancellationToken
21.290.1.10.2. Returns
Task<Count>