class

MinknowApi::Data::DataService::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

bidi_streaming?(method : String) : Bool

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

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

dispatch_bidi_stream(method : String, requests : GRPC::RawRequestStream, ctx : GRPC::ServerContext, writer : GRPC::RawResponseStream) : GRPC::Status

dispatch_bidi_stream dispatches a bidirectional streaming RPC. requests is a RawRequestStream that yields raw message bytes as they arrive. The transport passes a RawResponseStream; generated subclasses wrap it in a typed ResponseStream(T) before handing off to the user implementation.

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.

get_channel_states(request : GetChannelStatesRequest, writer : GRPC::ResponseStream(GetChannelStatesResponse), ctx : GRPC::ServerContext) : GRPC::Status

get_data_types(request : GetDataTypesRequest, ctx : GRPC::ServerContext) : GetDataTypesResponse

get_experiment_yield_info(request : GetExperimentYieldInfoRequest, ctx : GRPC::ServerContext) : GetExperimentYieldInfoResponse

get_live_reads(requests : GRPC::RequestStream(GetLiveReadsRequest), writer : GRPC::ResponseStream(GetLiveReadsResponse), ctx : GRPC::ServerContext) : GRPC::Status

get_read_statistics(request : GetReadStatisticsRequest, ctx : GRPC::ServerContext) : GetReadStatisticsResponse

get_signal_bytes(request : GetSignalBytesRequest, writer : GRPC::ResponseStream(GetSignalBytesResponse), ctx : GRPC::ServerContext) : GRPC::Status

get_signal_min_max(request : GetSignalMinMaxRequest, writer : GRPC::ResponseStream(GetSignalMinMaxResponse), ctx : GRPC::ServerContext) : GRPC::Status

lock_channel_states(request : LockChannelStatesRequest, ctx : GRPC::ServerContext) : LockChannelStatesResponse

record_adaptive_sampling_information(request : RecordAdaptiveSamplingInformationRequest, ctx : GRPC::ServerContext) : RecordAdaptiveSamplingInformationResponse

reset_channel_states(request : ResetChannelStatesRequest, ctx : GRPC::ServerContext) : ResetChannelStatesResponse

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

service_full_name

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

unlock_channel_states(request : UnlockChannelStatesRequest, ctx : GRPC::ServerContext) : UnlockChannelStatesResponse