Class Submitter.SubmitterBase
Namespace: ArmoniK.Api.gRPC.V1.Submitter
Assembly: ArmoniK.Api.Core.dll
Base class for server-side implementations of Submitter
[BindServiceMethod(typeof(Submitter), "BindService")]
public abstract class Submitter.SubmitterBase
Inheritance
Inherited Members
object.Equals(object?), object.Equals(object?, object?), object.GetHashCode(), object.GetType(), object.MemberwiseClone(), object.ReferenceEquals(object?, object?), object.ToString()
Methods
CancelSession(Session, ServerCallContext)
[Obsolete]
public virtual Task<Empty> CancelSession(Session request, ServerCallContext context)
Parameters
request Session
context ServerCallContext
Returns
Task<Empty>
CancelTasks(TaskFilter, ServerCallContext)
[Obsolete]
public virtual Task<Empty> CancelTasks(TaskFilter request, ServerCallContext context)
Parameters
request TaskFilter
context ServerCallContext
Returns
Task<Empty>
CountTasks(TaskFilter, ServerCallContext)
[Obsolete]
public virtual Task<Count> CountTasks(TaskFilter request, ServerCallContext context)
Parameters
request TaskFilter
context ServerCallContext
Returns
Task<Count>
CreateLargeTasks(IAsyncStreamReader<CreateLargeTaskRequest>, ServerCallContext)
[Obsolete]
public virtual Task<CreateTaskReply> CreateLargeTasks(IAsyncStreamReader<CreateLargeTaskRequest> requestStream, ServerCallContext context)
Parameters
requestStream IAsyncStreamReader<CreateLargeTaskRequest>
context ServerCallContext
Returns
Task<CreateTaskReply>
CreateSession(CreateSessionRequest, ServerCallContext)
[Obsolete]
public virtual Task<CreateSessionReply> CreateSession(CreateSessionRequest request, ServerCallContext context)
Parameters
request CreateSessionRequest
context ServerCallContext
Returns
Task<CreateSessionReply>
CreateSmallTasks(CreateSmallTaskRequest, ServerCallContext)
[Obsolete]
public virtual Task<CreateTaskReply> CreateSmallTasks(CreateSmallTaskRequest request, ServerCallContext context)
Parameters
request CreateSmallTaskRequest
context ServerCallContext
Returns
Task<CreateTaskReply>
GetResultStatus(GetResultStatusRequest, ServerCallContext)
[Obsolete]
public virtual Task<GetResultStatusReply> GetResultStatus(GetResultStatusRequest request, ServerCallContext context)
Parameters
request GetResultStatusRequest
context ServerCallContext
Returns
Task<GetResultStatusReply>
GetServiceConfiguration(Empty, ServerCallContext)
[Obsolete]
public virtual Task<Configuration> GetServiceConfiguration(Empty request, ServerCallContext context)
Parameters
request Empty
context ServerCallContext
Returns
Task<Configuration>
GetTaskStatus(GetTaskStatusRequest, ServerCallContext)
[Obsolete]
public virtual Task<GetTaskStatusReply> GetTaskStatus(GetTaskStatusRequest request, ServerCallContext context)
Parameters
request GetTaskStatusRequest
context ServerCallContext
Returns
Task<GetTaskStatusReply>
ListSessions(SessionFilter, ServerCallContext)
[Obsolete]
public virtual Task<SessionIdList> ListSessions(SessionFilter request, ServerCallContext context)
Parameters
request SessionFilter
context ServerCallContext
Returns
Task<SessionIdList>
ListTasks(TaskFilter, ServerCallContext)
[Obsolete]
public virtual Task<TaskIdList> ListTasks(TaskFilter request, ServerCallContext context)
Parameters
request TaskFilter
context ServerCallContext
Returns
Task<TaskIdList>
TryGetResultStream(ResultRequest, IServerStreamWriter<ResultReply>, ServerCallContext)
[Obsolete]
public virtual Task TryGetResultStream(ResultRequest request, IServerStreamWriter<ResultReply> responseStream, ServerCallContext context)
Parameters
request ResultRequest
responseStream IServerStreamWriter<ResultReply>
context ServerCallContext
Returns
TryGetTaskOutput(TaskOutputRequest, ServerCallContext)
[Obsolete]
public virtual Task<Output> TryGetTaskOutput(TaskOutputRequest request, ServerCallContext context)
Parameters
request TaskOutputRequest
context ServerCallContext
Returns
Task<Output>
WaitForAvailability(ResultRequest, ServerCallContext)
[Obsolete]
public virtual Task<AvailabilityReply> WaitForAvailability(ResultRequest request, ServerCallContext context)
Parameters
request ResultRequest
context ServerCallContext
Returns
Task<AvailabilityReply>
WaitForCompletion(WaitRequest, ServerCallContext)
[Obsolete]
public virtual Task<Count> WaitForCompletion(WaitRequest request, ServerCallContext context)
Parameters
request WaitRequest
context ServerCallContext
Returns
Task<Count>
WatchResults(IAsyncStreamReader<WatchResultRequest>, IServerStreamWriter<WatchResultStream>, ServerCallContext)
This endpoint allows a user to watch a list of results and be notified when there is any change. The user sends the list of ids they want to watch. The submitter will then send the statuses for all requested ids immediately and keep the stream open. Ids not present in DB will be returned at that time with the special state NOTFOUND. The submitter will send updates to the client via the opened stream. Any reply can be implicitely chunked if there are too many event to report at the same time (or for the first reply). It is possible to filter out specific statuses from events.
[Obsolete]
public virtual Task WatchResults(IAsyncStreamReader<WatchResultRequest> requestStream, IServerStreamWriter<WatchResultStream> responseStream, ServerCallContext context)
Parameters
requestStream IAsyncStreamReader<WatchResultRequest>
Used for reading requests from the client.
responseStream IServerStreamWriter<WatchResultStream>
Used for sending responses back to the client.
context ServerCallContext
The context of the server-side call handler being invoked.
Returns
A task indicating completion of the handler.