class

MinknowApi::Instance::InstanceService::Service

Inherits GRPC::Service < Reference < Object

Service is the generated abstract base class for server implementations. Subclass it and implement each RPC method, then register with GRPC::Server#handle.

Instance methods

dispatch(method : String, body : Bytes, ctx : GRPC::ServerContext) : Tuple(Bytes, GRPC::Status)

dispatch routes an incoming unary RPC call to the correct method implementation. Returns {response_body : Bytes, status : Status}.

Source
dispatch_server_stream(method : String, body : Bytes, ctx : GRPC::ServerContext, writer : GRPC::RawResponseStream) : GRPC::Status

dispatch_server_stream dispatches a server-streaming RPC. The transport passes a RawResponseStream; generated subclasses wrap it in a typed ResponseStream(T) before handing off to the user implementation.

Source
get_default_output_directories(request : GetDefaultOutputDirectoriesRequest, ctx : GRPC::ServerContext) : OutputDirectories
Source
get_disk_space_info(request : GetDiskSpaceInfoRequest, ctx : GRPC::ServerContext) : GetDiskSpaceInfoResponse
Source
get_machine_id(request : GetMachineIdRequest, ctx : GRPC::ServerContext) : GetMachineIdResponse
Source
get_output_directories(request : GetOutputDirectoriesRequest, ctx : GRPC::ServerContext) : OutputDirectories
Source
get_version_info(request : GetVersionInfoRequest, ctx : GRPC::ServerContext) : GetVersionInfoResponse
Source
server_streaming?(method : String) : Bool

server_streaming? returns true if method is a server-streaming RPC. Generated service base classes override this; the default is false (unary).

Source
service_full_name

service_full_name returns the full gRPC service name (e.g. "helloworld.Greeter").

Source
set_output_directory(request : SetOutputDirectoryRequest, ctx : GRPC::ServerContext) : SetOutputDirectoryResponse
Source
set_reads_directory(request : SetReadsDirectoryRequest, ctx : GRPC::ServerContext) : SetReadsDirectoryResponse
Source
stream_disk_space_info(request : StreamDiskSpaceInfoRequest, writer : GRPC::ResponseStream(GetDiskSpaceInfoResponse), ctx : GRPC::ServerContext) : GRPC::Status
Source
stream_instance_activity(request : StreamInstanceActivityRequest, writer : GRPC::ResponseStream(StreamInstanceActivityResponse), ctx : GRPC::ServerContext) : GRPC::Status
Source