17.287. Class GrpcSubmitterService
Namespace: ArmoniK.Core.Common.gRPC.Services
Assembly: ArmoniK.Core.Common.dll
[Authorize(AuthenticationSchemes = "ArmoniKAuthenticationScheme")]
public class GrpcSubmitterService : Submitter.SubmitterBase
17.287.1. Inheritance
object ← Submitter.SubmitterBase ← GrpcSubmitterService
17.287.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()
17.287.3. Constructors
17.287.3.1. GrpcSubmitterService(ISubmitter, ITaskTable, ISessionTable, IResultTable, ILogger<GrpcSubmitterService>)
public GrpcSubmitterService(ISubmitter submitter, ITaskTable taskTable, ISessionTable sessionTable, IResultTable resultTable, ILogger<GrpcSubmitterService> logger)
17.287.3.1.1. Parameters
submitter ISubmitter
taskTable ITaskTable
sessionTable ISessionTable
resultTable IResultTable
logger ILogger<GrpcSubmitterService>
17.287.4. Methods
17.287.4.1. CancelSession(Session, ServerCallContext)
[RequiresPermission(typeof(GrpcSubmitterService), "CancelSession")]
[Obsolete]
public override Task<Empty> CancelSession(Session request, ServerCallContext context)
17.287.4.1.1. Parameters
request Session
context ServerCallContext
17.287.4.1.2. Returns
Task<Empty>
17.287.4.2. CancelTasks(TaskFilter, ServerCallContext)
[RequiresPermission(typeof(GrpcSubmitterService), "CancelTasks")]
[Obsolete]
public override Task<Empty> CancelTasks(TaskFilter request, ServerCallContext context)
17.287.4.2.1. Parameters
request TaskFilter
context ServerCallContext
17.287.4.2.2. Returns
Task<Empty>
17.287.4.3. CountTasks(TaskFilter, ServerCallContext)
[RequiresPermission(typeof(GrpcSubmitterService), "CountTasks")]
[Obsolete]
public override Task<Count> CountTasks(TaskFilter request, ServerCallContext context)
17.287.4.3.1. Parameters
request TaskFilter
context ServerCallContext
17.287.4.3.2. Returns
Task<Count>
17.287.4.4. CreateLargeTasks(IAsyncStreamReader<CreateLargeTaskRequest>, ServerCallContext)
[RequiresPermission(typeof(GrpcSubmitterService), "CreateLargeTasks")]
[Obsolete]
public override Task<CreateTaskReply> CreateLargeTasks(IAsyncStreamReader<CreateLargeTaskRequest> requestStream, ServerCallContext context)
17.287.4.4.1. Parameters
requestStream IAsyncStreamReader<CreateLargeTaskRequest>
context ServerCallContext
17.287.4.4.2. Returns
Task<CreateTaskReply>
17.287.4.5. CreateSession(CreateSessionRequest, ServerCallContext)
[RequiresPermission(typeof(GrpcSubmitterService), "CreateSession")]
[Obsolete]
public override Task<CreateSessionReply> CreateSession(CreateSessionRequest request, ServerCallContext context)
17.287.4.5.1. Parameters
request CreateSessionRequest
context ServerCallContext
17.287.4.5.2. Returns
Task<CreateSessionReply>
17.287.4.6. CreateSmallTasks(CreateSmallTaskRequest, ServerCallContext)
[RequiresPermission(typeof(GrpcSubmitterService), "CreateSmallTasks")]
[Obsolete]
public override Task<CreateTaskReply> CreateSmallTasks(CreateSmallTaskRequest request, ServerCallContext context)
17.287.4.6.1. Parameters
request CreateSmallTaskRequest
context ServerCallContext
17.287.4.6.2. Returns
Task<CreateTaskReply>
17.287.4.7. GetResultStatus(GetResultStatusRequest, ServerCallContext)
[RequiresPermission(typeof(GrpcSubmitterService), "GetResultStatus")]
[Obsolete("GetResultStatus is obsolete")]
public override Task<GetResultStatusReply> GetResultStatus(GetResultStatusRequest request, ServerCallContext context)
17.287.4.7.1. Parameters
request GetResultStatusRequest
context ServerCallContext
17.287.4.7.2. Returns
Task<GetResultStatusReply>
17.287.4.8. GetServiceConfiguration(Empty, ServerCallContext)
[RequiresPermission(typeof(GrpcSubmitterService), "GetServiceConfiguration")]
[Obsolete]
public override Task<Configuration> GetServiceConfiguration(Empty request, ServerCallContext context)
17.287.4.8.1. Parameters
request Empty
context ServerCallContext
17.287.4.8.2. Returns
Task<Configuration>
17.287.4.9. GetTaskStatus(GetTaskStatusRequest, ServerCallContext)
[RequiresPermission(typeof(GrpcSubmitterService), "GetTaskStatus")]
[Obsolete]
public override Task<GetTaskStatusReply> GetTaskStatus(GetTaskStatusRequest request, ServerCallContext context)
17.287.4.9.1. Parameters
request GetTaskStatusRequest
context ServerCallContext
17.287.4.9.2. Returns
Task<GetTaskStatusReply>
17.287.4.10. ListSessions(SessionFilter, ServerCallContext)
[RequiresPermission(typeof(GrpcSubmitterService), "ListSessions")]
[Obsolete]
public override Task<SessionIdList> ListSessions(SessionFilter request, ServerCallContext context)
17.287.4.10.1. Parameters
request SessionFilter
context ServerCallContext
17.287.4.10.2. Returns
Task<SessionIdList>
17.287.4.11. ListTasks(TaskFilter, ServerCallContext)
[RequiresPermission(typeof(GrpcSubmitterService), "ListTasks")]
[Obsolete]
public override Task<TaskIdList> ListTasks(TaskFilter request, ServerCallContext context)
17.287.4.11.1. Parameters
request TaskFilter
context ServerCallContext
17.287.4.11.2. Returns
Task<TaskIdList>
17.287.4.12. TryGetResultStream(ResultRequest, IServerStreamWriter<ResultReply>, ServerCallContext)
[RequiresPermission(typeof(GrpcSubmitterService), "TryGetResultStream")]
[Obsolete]
public override Task TryGetResultStream(ResultRequest request, IServerStreamWriter<ResultReply> responseStream, ServerCallContext context)
17.287.4.12.1. Parameters
request ResultRequest
responseStream IServerStreamWriter<ResultReply>
context ServerCallContext
17.287.4.12.2. Returns
17.287.4.13. TryGetTaskOutput(TaskOutputRequest, ServerCallContext)
[RequiresPermission(typeof(GrpcSubmitterService), "TryGetTaskOutput")]
[Obsolete]
public override Task<Output> TryGetTaskOutput(TaskOutputRequest request, ServerCallContext context)
17.287.4.13.1. Parameters
request TaskOutputRequest
context ServerCallContext
17.287.4.13.2. Returns
Task<Output>
17.287.4.14. WaitForAvailability(ResultRequest, ServerCallContext)
[RequiresPermission(typeof(GrpcSubmitterService), "WaitForAvailability")]
[Obsolete("WaitForAvailabilityAsync is obsolete")]
public override Task<AvailabilityReply> WaitForAvailability(ResultRequest request, ServerCallContext context)
17.287.4.14.1. Parameters
request ResultRequest
context ServerCallContext
17.287.4.14.2. Returns
Task<AvailabilityReply>
17.287.4.15. WaitForCompletion(WaitRequest, ServerCallContext)
[RequiresPermission(typeof(GrpcSubmitterService), "WaitForCompletion")]
[Obsolete]
public override Task<Count> WaitForCompletion(WaitRequest request, ServerCallContext context)
17.287.4.15.1. Parameters
request WaitRequest
context ServerCallContext
17.287.4.15.2. Returns
Task<Count>