21.289. Class GrpcSubmitterService

Namespace: ArmoniK.Core.Common.gRPC.Services
Assembly: ArmoniK.Core.Common.dll

[Authorize(AuthenticationSchemes = "ArmoniKAuthenticationScheme")]
public class GrpcSubmitterService : Submitter.SubmitterBase

21.289.1. Inheritance

object ← Submitter.SubmitterBase ← GrpcSubmitterService

21.289.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.289.3. Constructors

21.289.3.1. GrpcSubmitterService(ISubmitter, ITaskTable, ISessionTable, IResultTable, IObjectStorage, ILogger<GrpcSubmitterService>)

Initializes a new instance of the class.

public GrpcSubmitterService(ISubmitter submitter, ITaskTable taskTable, ISessionTable sessionTable, IResultTable resultTable, IObjectStorage objectStorage, ILogger<GrpcSubmitterService> logger)

21.289.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.

objectStorage IObjectStorage

Interface to manage data

logger ILogger<GrpcSubmitterService>

The logger instance for logging information.

21.289.4. Methods

21.289.4.1. CancelSession(Session, ServerCallContext)

[RequiresPermission(typeof(GrpcSubmitterService), "CancelSession")]
[Obsolete]
public override Task<Empty> CancelSession(Session request, ServerCallContext context)

21.289.4.1.1. Parameters

request Session

context ServerCallContext

21.289.4.1.2. Returns

Task<Empty>

21.289.4.2. CancelTasks(TaskFilter, ServerCallContext)

[RequiresPermission(typeof(GrpcSubmitterService), "CancelTasks")]
[Obsolete]
public override Task<Empty> CancelTasks(TaskFilter request, ServerCallContext context)

21.289.4.2.1. Parameters

request TaskFilter

context ServerCallContext

21.289.4.2.2. Returns

Task<Empty>

21.289.4.3. CountTasks(TaskFilter, ServerCallContext)

[RequiresPermission(typeof(GrpcSubmitterService), "CountTasks")]
[Obsolete]
public override Task<Count> CountTasks(TaskFilter request, ServerCallContext context)

21.289.4.3.1. Parameters

request TaskFilter

context ServerCallContext

21.289.4.3.2. Returns

Task<Count>

21.289.4.4. CreateLargeTasks(IAsyncStreamReader<CreateLargeTaskRequest>, ServerCallContext)

[RequiresPermission(typeof(GrpcSubmitterService), "CreateLargeTasks")]
[Obsolete]
public override Task<CreateTaskReply> CreateLargeTasks(IAsyncStreamReader<CreateLargeTaskRequest> requestStream, ServerCallContext context)

21.289.4.4.1. Parameters

requestStream IAsyncStreamReader<CreateLargeTaskRequest>

context ServerCallContext

21.289.4.4.2. Returns

Task<CreateTaskReply>

21.289.4.5. CreateSession(CreateSessionRequest, ServerCallContext)

[RequiresPermission(typeof(GrpcSubmitterService), "CreateSession")]
[Obsolete]
public override Task<CreateSessionReply> CreateSession(CreateSessionRequest request, ServerCallContext context)

21.289.4.5.1. Parameters

request CreateSessionRequest

context ServerCallContext

21.289.4.5.2. Returns

Task<CreateSessionReply>

21.289.4.6. CreateSmallTasks(CreateSmallTaskRequest, ServerCallContext)

[RequiresPermission(typeof(GrpcSubmitterService), "CreateSmallTasks")]
[Obsolete]
public override Task<CreateTaskReply> CreateSmallTasks(CreateSmallTaskRequest request, ServerCallContext context)

21.289.4.6.1. Parameters

request CreateSmallTaskRequest

context ServerCallContext

21.289.4.6.2. Returns

Task<CreateTaskReply>

21.289.4.7. GetResultStatus(GetResultStatusRequest, ServerCallContext)

[RequiresPermission(typeof(GrpcSubmitterService), "GetResultStatus")]
[Obsolete("GetResultStatus is obsolete")]
public override Task<GetResultStatusReply> GetResultStatus(GetResultStatusRequest request, ServerCallContext context)

21.289.4.7.1. Parameters

request GetResultStatusRequest

context ServerCallContext

21.289.4.7.2. Returns

Task<GetResultStatusReply>

21.289.4.8. GetServiceConfiguration(Empty, ServerCallContext)

[RequiresPermission(typeof(GrpcSubmitterService), "GetServiceConfiguration")]
[Obsolete]
public override Task<Configuration> GetServiceConfiguration(Empty request, ServerCallContext context)

21.289.4.8.1. Parameters

request Empty

context ServerCallContext

21.289.4.8.2. Returns

Task<Configuration>

21.289.4.9. GetTaskStatus(GetTaskStatusRequest, ServerCallContext)

[RequiresPermission(typeof(GrpcSubmitterService), "GetTaskStatus")]
[Obsolete]
public override Task<GetTaskStatusReply> GetTaskStatus(GetTaskStatusRequest request, ServerCallContext context)

21.289.4.9.1. Parameters

request GetTaskStatusRequest

context ServerCallContext

21.289.4.9.2. Returns

Task<GetTaskStatusReply>

21.289.4.10. ListSessions(SessionFilter, ServerCallContext)

[RequiresPermission(typeof(GrpcSubmitterService), "ListSessions")]
[Obsolete]
public override Task<SessionIdList> ListSessions(SessionFilter request, ServerCallContext context)

21.289.4.10.1. Parameters

request SessionFilter

context ServerCallContext

21.289.4.10.2. Returns

Task<SessionIdList>

21.289.4.11. ListTasks(TaskFilter, ServerCallContext)

[RequiresPermission(typeof(GrpcSubmitterService), "ListTasks")]
[Obsolete]
public override Task<TaskIdList> ListTasks(TaskFilter request, ServerCallContext context)

21.289.4.11.1. Parameters

request TaskFilter

context ServerCallContext

21.289.4.11.2. Returns

Task<TaskIdList>

21.289.4.12. TryGetResultStream(ResultRequest, IServerStreamWriter<ResultReply>, ServerCallContext)

[RequiresPermission(typeof(GrpcSubmitterService), "TryGetResultStream")]
[Obsolete]
public override Task TryGetResultStream(ResultRequest request, IServerStreamWriter<ResultReply> responseStream, ServerCallContext context)

21.289.4.12.1. Parameters

request ResultRequest

responseStream IServerStreamWriter<ResultReply>

context ServerCallContext

21.289.4.12.2. Returns

Task

21.289.4.13. TryGetTaskOutput(TaskOutputRequest, ServerCallContext)

[RequiresPermission(typeof(GrpcSubmitterService), "TryGetTaskOutput")]
[Obsolete]
public override Task<Output> TryGetTaskOutput(TaskOutputRequest request, ServerCallContext context)

21.289.4.13.1. Parameters

request TaskOutputRequest

context ServerCallContext

21.289.4.13.2. Returns

Task<Output>

21.289.4.14. WaitForAvailability(ResultRequest, ServerCallContext)

[RequiresPermission(typeof(GrpcSubmitterService), "WaitForAvailability")]
[Obsolete("WaitForAvailabilityAsync is obsolete")]
public override Task<AvailabilityReply> WaitForAvailability(ResultRequest request, ServerCallContext context)

21.289.4.14.1. Parameters

request ResultRequest

context ServerCallContext

21.289.4.14.2. Returns

Task<AvailabilityReply>

21.289.4.15. WaitForCompletion(WaitRequest, ServerCallContext)

[RequiresPermission(typeof(GrpcSubmitterService), "WaitForCompletion")]
[Obsolete]
public override Task<Count> WaitForCompletion(WaitRequest request, ServerCallContext context)

21.289.4.15.1. Parameters

request WaitRequest

context ServerCallContext

21.289.4.15.2. Returns

Task<Count>