26.294. Class GrpcSubmitterService

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

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

26.294.1. Inheritance

object ← Submitter.SubmitterBase ← GrpcSubmitterService

26.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()

26.294.3. Constructors

26.294.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)

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

objectStorage IObjectStorage

Interface to manage data

logger ILogger<GrpcSubmitterService>

The logger instance for logging information.

26.294.4. Methods

26.294.4.1. CancelSession(Session, ServerCallContext)

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

26.294.4.1.1. Parameters

request Session

context ServerCallContext

26.294.4.1.2. Returns

Task<Empty>

26.294.4.2. CancelTasks(TaskFilter, ServerCallContext)

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

26.294.4.2.1. Parameters

request TaskFilter

context ServerCallContext

26.294.4.2.2. Returns

Task<Empty>

26.294.4.3. CountTasks(TaskFilter, ServerCallContext)

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

26.294.4.3.1. Parameters

request TaskFilter

context ServerCallContext

26.294.4.3.2. Returns

Task<Count>

26.294.4.4. CreateLargeTasks(IAsyncStreamReader<CreateLargeTaskRequest>, ServerCallContext)

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

26.294.4.4.1. Parameters

requestStream IAsyncStreamReader<CreateLargeTaskRequest>

context ServerCallContext

26.294.4.4.2. Returns

Task<CreateTaskReply>

26.294.4.5. CreateSession(CreateSessionRequest, ServerCallContext)

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

26.294.4.5.1. Parameters

request CreateSessionRequest

context ServerCallContext

26.294.4.5.2. Returns

Task<CreateSessionReply>

26.294.4.6. CreateSmallTasks(CreateSmallTaskRequest, ServerCallContext)

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

26.294.4.6.1. Parameters

request CreateSmallTaskRequest

context ServerCallContext

26.294.4.6.2. Returns

Task<CreateTaskReply>

26.294.4.7. GetResultStatus(GetResultStatusRequest, ServerCallContext)

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

26.294.4.7.1. Parameters

request GetResultStatusRequest

context ServerCallContext

26.294.4.7.2. Returns

Task<GetResultStatusReply>

26.294.4.8. GetServiceConfiguration(Empty, ServerCallContext)

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

26.294.4.8.1. Parameters

request Empty

context ServerCallContext

26.294.4.8.2. Returns

Task<Configuration>

26.294.4.9. GetTaskStatus(GetTaskStatusRequest, ServerCallContext)

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

26.294.4.9.1. Parameters

request GetTaskStatusRequest

context ServerCallContext

26.294.4.9.2. Returns

Task<GetTaskStatusReply>

26.294.4.10. ListSessions(SessionFilter, ServerCallContext)

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

26.294.4.10.1. Parameters

request SessionFilter

context ServerCallContext

26.294.4.10.2. Returns

Task<SessionIdList>

26.294.4.11. ListTasks(TaskFilter, ServerCallContext)

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

26.294.4.11.1. Parameters

request TaskFilter

context ServerCallContext

26.294.4.11.2. Returns

Task<TaskIdList>

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

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

26.294.4.12.1. Parameters

request ResultRequest

responseStream IServerStreamWriter<ResultReply>

context ServerCallContext

26.294.4.12.2. Returns

Task

26.294.4.13. TryGetTaskOutput(TaskOutputRequest, ServerCallContext)

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

26.294.4.13.1. Parameters

request TaskOutputRequest

context ServerCallContext

26.294.4.13.2. Returns

Task<Output>

26.294.4.14. WaitForAvailability(ResultRequest, ServerCallContext)

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

26.294.4.14.1. Parameters

request ResultRequest

context ServerCallContext

26.294.4.14.2. Returns

Task<AvailabilityReply>

26.294.4.15. WaitForCompletion(WaitRequest, ServerCallContext)

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

26.294.4.15.1. Parameters

request WaitRequest

context ServerCallContext

26.294.4.15.2. Returns

Task<Count>