21.291. Class Submitter
Namespace: ArmoniK.Core.Common.gRPC.Services
Assembly: ArmoniK.Core.Common.dll
public class Submitter : ISubmitter
21.291.1. Inheritance
21.291.2. Implements
21.291.3. Inherited Members
object.Equals(object?), object.Equals(object?, object?), object.GetHashCode(), object.GetType(), object.MemberwiseClone(), object.ReferenceEquals(object?, object?), object.ToString()
21.291.4. Constructors
21.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)
21.291.4.1.1. Parameters
pushQueueStorage IPushQueueStorage
objectStorage IObjectStorage
sessionTable ISessionTable
taskTable ITaskTable
resultTable IResultTable
partitionTable IPartitionTable
submitterOptions Submitter
activitySource ActivitySource
21.291.5. Methods
21.291.5.1. CancelSession(string, CancellationToken)
public Task CancelSession(string sessionId, CancellationToken cancellationToken)
21.291.5.1.1. Parameters
sessionId string
cancellationToken CancellationToken
21.291.5.1.2. Returns
21.291.5.2. CompleteTaskAsync(TaskData, SessionData, bool, Output, CancellationToken)
public Task CompleteTaskAsync(TaskData taskData, SessionData sessionData, bool resubmit, Output output, CancellationToken cancellationToken = default)
21.291.5.2.1. Parameters
taskData TaskData
sessionData SessionData
resubmit bool
output Output
cancellationToken CancellationToken
21.291.5.2.2. Returns
21.291.5.3. CreateSession(IList<string>, TaskOptions, CancellationToken)
public Task<CreateSessionReply> CreateSession(IList<string> partitionIds, TaskOptions defaultTaskOptions, CancellationToken cancellationToken)
21.291.5.3.1. Parameters
defaultTaskOptions TaskOptions
cancellationToken CancellationToken
21.291.5.3.2. Returns
Task<CreateSessionReply>
21.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)
21.291.5.4.1. Parameters
sessionId string
parentTaskId string
options TaskOptions?
taskRequests IAsyncEnumerable<TaskRequest>
cancellationToken CancellationToken
21.291.5.4.2. Returns
21.291.5.5. FinalizeTaskCreation(IEnumerable<TaskCreationRequest>, SessionData, string, CancellationToken)
public Task FinalizeTaskCreation(IEnumerable<TaskCreationRequest> requests, SessionData sessionData, string parentTaskId, CancellationToken cancellationToken)
21.291.5.5.1. Parameters
requests IEnumerable<TaskCreationRequest>
sessionData SessionData
parentTaskId string
cancellationToken CancellationToken
21.291.5.5.2. Returns
21.291.5.6. GetServiceConfiguration(Empty, CancellationToken)
public Task<Configuration> GetServiceConfiguration(Empty request, CancellationToken cancellationToken)
21.291.5.6.1. Parameters
request Empty
cancellationToken CancellationToken
21.291.5.6.2. Returns
Task<Configuration>
21.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)
21.291.5.7.1. Parameters
sessionId string
ownerTaskId string
key string
chunks IAsyncEnumerable<ReadOnlyMemory<byte>>
cancellationToken CancellationToken
21.291.5.7.2. Returns
21.291.5.8. TryGetResult(ResultRequest, IServerStreamWriter<ResultReply>, CancellationToken)
public Task TryGetResult(ResultRequest request, IServerStreamWriter<ResultReply> responseStream, CancellationToken cancellationToken)
21.291.5.8.1. Parameters
request ResultRequest
responseStream IServerStreamWriter<ResultReply>
cancellationToken CancellationToken
21.291.5.8.2. Returns
21.291.5.9. WaitForAvailabilityAsync(ResultRequest, CancellationToken)
public Task<AvailabilityReply> WaitForAvailabilityAsync(ResultRequest request, CancellationToken contextCancellationToken)
21.291.5.9.1. Parameters
request ResultRequest
contextCancellationToken CancellationToken
21.291.5.9.2. Returns
Task<AvailabilityReply>
21.291.5.10. WaitForCompletion(WaitRequest, CancellationToken)
public Task<Count> WaitForCompletion(WaitRequest request, CancellationToken cancellationToken)
21.291.5.10.1. Parameters
request WaitRequest
cancellationToken CancellationToken
21.291.5.10.2. Returns
Task<Count>