21.294. Class GrpcSubmitterService
Namespace: ArmoniK.Core.Common.gRPC.Services
Assembly: ArmoniK.Core.Common.dll
[Authorize(AuthenticationSchemes = "ArmoniKAuthenticationScheme")]
public class GrpcSubmitterService : Submitter.SubmitterBase
21.294.1. Inheritance
object ← Submitter.SubmitterBase ← GrpcSubmitterService
21.294.2. Inherited Members
Submitter.SubmitterBase.GetServiceConfiguration(Empty, ServerCallContext), Submitter.SubmitterBase.CreateSession(CreateSessionRequest, ServerCallContext), Submitter.SubmitterBase.CancelSession(Session, ServerCallContext), Submitter.SubmitterBase.CreateSmallTasks(CreateSmallTaskRequest, ServerCallContext), Submitter.SubmitterBase.CreateLargeTasks(IAsyncStreamReader<CreateLargeTaskRequest>, ServerCallContext), Submitter.SubmitterBase.ListTasks(TaskFilter, ServerCallContext), Submitter.SubmitterBase.ListSessions(SessionFilter, ServerCallContext), Submitter.SubmitterBase.CountTasks(TaskFilter, ServerCallContext), Submitter.SubmitterBase.TryGetResultStream(ResultRequest, IServerStreamWriter<ResultReply>, ServerCallContext), Submitter.SubmitterBase.TryGetTaskOutput(TaskOutputRequest, ServerCallContext), Submitter.SubmitterBase.WaitForAvailability(ResultRequest, ServerCallContext), Submitter.SubmitterBase.WaitForCompletion(WaitRequest, ServerCallContext), Submitter.SubmitterBase.CancelTasks(TaskFilter, ServerCallContext), Submitter.SubmitterBase.GetTaskStatus(GetTaskStatusRequest, ServerCallContext), Submitter.SubmitterBase.GetResultStatus(GetResultStatusRequest, ServerCallContext), Submitter.SubmitterBase.WatchResults(IAsyncStreamReader<WatchResultRequest>, IServerStreamWriter<WatchResultStream>, ServerCallContext), object.Equals(object?), object.Equals(object?, object?), object.GetHashCode(), object.GetType(), object.MemberwiseClone(), object.ReferenceEquals(object?, object?), object.ToString()
21.294.3. Constructors
21.294.3.1. GrpcSubmitterService(ISubmitter, ITaskTable, ISessionTable, IResultTable, ILogger<GrpcSubmitterService>)
Initializes a new instance of the
public GrpcSubmitterService(ISubmitter submitter, ITaskTable taskTable, ISessionTable sessionTable, IResultTable resultTable, ILogger<GrpcSubmitterService> logger)
21.294.3.1.1. Parameters
submitter ISubmitter
The submitter instance for handling task submissions.
taskTable ITaskTable
The task table for managing tasks.
sessionTable ISessionTable
The session table for managing sessions.
resultTable IResultTable
The result table for managing task inputs and outputs.
logger ILogger<GrpcSubmitterService>
The logger instance for logging information.
21.294.4. Methods
21.294.4.1. CancelSession(Session, ServerCallContext)
[RequiresPermission(typeof(GrpcSubmitterService), "CancelSession")]
[Obsolete]
public override Task<Empty> CancelSession(Session request, ServerCallContext context)
21.294.4.1.1. Parameters
request Session
context ServerCallContext
21.294.4.1.2. Returns
Task<Empty>
21.294.4.2. CancelTasks(TaskFilter, ServerCallContext)
[RequiresPermission(typeof(GrpcSubmitterService), "CancelTasks")]
[Obsolete]
public override Task<Empty> CancelTasks(TaskFilter request, ServerCallContext context)
21.294.4.2.1. Parameters
request TaskFilter
context ServerCallContext
21.294.4.2.2. Returns
Task<Empty>
21.294.4.3. CountTasks(TaskFilter, ServerCallContext)
[RequiresPermission(typeof(GrpcSubmitterService), "CountTasks")]
[Obsolete]
public override Task<Count> CountTasks(TaskFilter request, ServerCallContext context)
21.294.4.3.1. Parameters
request TaskFilter
context ServerCallContext
21.294.4.3.2. Returns
Task<Count>
21.294.4.4. CreateLargeTasks(IAsyncStreamReader<CreateLargeTaskRequest>, ServerCallContext)
[RequiresPermission(typeof(GrpcSubmitterService), "CreateLargeTasks")]
[Obsolete]
public override Task<CreateTaskReply> CreateLargeTasks(IAsyncStreamReader<CreateLargeTaskRequest> requestStream, ServerCallContext context)
21.294.4.4.1. Parameters
requestStream IAsyncStreamReader<CreateLargeTaskRequest>
context ServerCallContext
21.294.4.4.2. Returns
Task<CreateTaskReply>
21.294.4.5. CreateSession(CreateSessionRequest, ServerCallContext)
[RequiresPermission(typeof(GrpcSubmitterService), "CreateSession")]
[Obsolete]
public override Task<CreateSessionReply> CreateSession(CreateSessionRequest request, ServerCallContext context)
21.294.4.5.1. Parameters
request CreateSessionRequest
context ServerCallContext
21.294.4.5.2. Returns
Task<CreateSessionReply>
21.294.4.6. CreateSmallTasks(CreateSmallTaskRequest, ServerCallContext)
[RequiresPermission(typeof(GrpcSubmitterService), "CreateSmallTasks")]
[Obsolete]
public override Task<CreateTaskReply> CreateSmallTasks(CreateSmallTaskRequest request, ServerCallContext context)
21.294.4.6.1. Parameters
request CreateSmallTaskRequest
context ServerCallContext
21.294.4.6.2. Returns
Task<CreateTaskReply>
21.294.4.7. GetResultStatus(GetResultStatusRequest, ServerCallContext)
[RequiresPermission(typeof(GrpcSubmitterService), "GetResultStatus")]
[Obsolete("GetResultStatus is obsolete")]
public override Task<GetResultStatusReply> GetResultStatus(GetResultStatusRequest request, ServerCallContext context)
21.294.4.7.1. Parameters
request GetResultStatusRequest
context ServerCallContext
21.294.4.7.2. Returns
Task<GetResultStatusReply>
21.294.4.8. GetServiceConfiguration(Empty, ServerCallContext)
[RequiresPermission(typeof(GrpcSubmitterService), "GetServiceConfiguration")]
[Obsolete]
public override Task<Configuration> GetServiceConfiguration(Empty request, ServerCallContext context)
21.294.4.8.1. Parameters
request Empty
context ServerCallContext
21.294.4.8.2. Returns
Task<Configuration>
21.294.4.9. GetTaskStatus(GetTaskStatusRequest, ServerCallContext)
[RequiresPermission(typeof(GrpcSubmitterService), "GetTaskStatus")]
[Obsolete]
public override Task<GetTaskStatusReply> GetTaskStatus(GetTaskStatusRequest request, ServerCallContext context)
21.294.4.9.1. Parameters
request GetTaskStatusRequest
context ServerCallContext
21.294.4.9.2. Returns
Task<GetTaskStatusReply>
21.294.4.10. ListSessions(SessionFilter, ServerCallContext)
[RequiresPermission(typeof(GrpcSubmitterService), "ListSessions")]
[Obsolete]
public override Task<SessionIdList> ListSessions(SessionFilter request, ServerCallContext context)
21.294.4.10.1. Parameters
request SessionFilter
context ServerCallContext
21.294.4.10.2. Returns
Task<SessionIdList>
21.294.4.11. ListTasks(TaskFilter, ServerCallContext)
[RequiresPermission(typeof(GrpcSubmitterService), "ListTasks")]
[Obsolete]
public override Task<TaskIdList> ListTasks(TaskFilter request, ServerCallContext context)
21.294.4.11.1. Parameters
request TaskFilter
context ServerCallContext
21.294.4.11.2. Returns
Task<TaskIdList>
21.294.4.12. TryGetResultStream(ResultRequest, IServerStreamWriter<ResultReply>, ServerCallContext)
[RequiresPermission(typeof(GrpcSubmitterService), "TryGetResultStream")]
[Obsolete]
public override Task TryGetResultStream(ResultRequest request, IServerStreamWriter<ResultReply> responseStream, ServerCallContext context)
21.294.4.12.1. Parameters
request ResultRequest
responseStream IServerStreamWriter<ResultReply>
context ServerCallContext
21.294.4.12.2. Returns
21.294.4.13. TryGetTaskOutput(TaskOutputRequest, ServerCallContext)
[RequiresPermission(typeof(GrpcSubmitterService), "TryGetTaskOutput")]
[Obsolete]
public override Task<Output> TryGetTaskOutput(TaskOutputRequest request, ServerCallContext context)
21.294.4.13.1. Parameters
request TaskOutputRequest
context ServerCallContext
21.294.4.13.2. Returns
Task<Output>
21.294.4.14. WaitForAvailability(ResultRequest, ServerCallContext)
[RequiresPermission(typeof(GrpcSubmitterService), "WaitForAvailability")]
[Obsolete("WaitForAvailabilityAsync is obsolete")]
public override Task<AvailabilityReply> WaitForAvailability(ResultRequest request, ServerCallContext context)
21.294.4.14.1. Parameters
request ResultRequest
context ServerCallContext
21.294.4.14.2. Returns
Task<AvailabilityReply>
21.294.4.15. WaitForCompletion(WaitRequest, ServerCallContext)
[RequiresPermission(typeof(GrpcSubmitterService), "WaitForCompletion")]
[Obsolete]
public override Task<Count> WaitForCompletion(WaitRequest request, ServerCallContext context)
21.294.4.15.1. Parameters
request WaitRequest
context ServerCallContext
21.294.4.15.2. Returns
Task<Count>