abstract class MinknowApi::Data::DataService::Service

• MinknowApi::Data::DataService::Service
• GRPC::Service
• Reference
• Object

Overview

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

Defined in:

generated/minknow_api/data.grpc.cr

Instance Method Summary

• #bidi_streaming?(method : String) : Bool

  bidi_streaming? returns true if method is a bidirectional streaming RPC.

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

  dispatch routes an incoming unary RPC call to the correct method implementation.

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

  dispatch_bidi_stream dispatches a bidirectional streaming RPC.

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

  dispatch_server_stream dispatches a server-streaming RPC.

• #get_channel_states(request : MinknowApi::Data::GetChannelStatesRequest, writer : GRPC::ResponseStream(MinknowApi::Data::GetChannelStatesResponse), ctx : GRPC::ServerContext) : GRPC::Status
• #get_data_types(request : MinknowApi::Data::GetDataTypesRequest, ctx : GRPC::ServerContext) : MinknowApi::Data::GetDataTypesResponse
• #get_experiment_yield_info(request : MinknowApi::Data::GetExperimentYieldInfoRequest, ctx : GRPC::ServerContext) : MinknowApi::Data::GetExperimentYieldInfoResponse
• #get_live_reads(requests : GRPC::RequestStream(MinknowApi::Data::GetLiveReadsRequest), writer : GRPC::ResponseStream(MinknowApi::Data::GetLiveReadsResponse), ctx : GRPC::ServerContext) : GRPC::Status
• #get_read_statistics(request : MinknowApi::Data::GetReadStatisticsRequest, ctx : GRPC::ServerContext) : MinknowApi::Data::GetReadStatisticsResponse
• #get_signal_bytes(request : MinknowApi::Data::GetSignalBytesRequest, writer : GRPC::ResponseStream(MinknowApi::Data::GetSignalBytesResponse), ctx : GRPC::ServerContext) : GRPC::Status
• #get_signal_min_max(request : MinknowApi::Data::GetSignalMinMaxRequest, writer : GRPC::ResponseStream(MinknowApi::Data::GetSignalMinMaxResponse), ctx : GRPC::ServerContext) : GRPC::Status
• #lock_channel_states(request : MinknowApi::Data::LockChannelStatesRequest, ctx : GRPC::ServerContext) : MinknowApi::Data::LockChannelStatesResponse
• #record_adaptive_sampling_information(request : MinknowApi::Data::RecordAdaptiveSamplingInformationRequest, ctx : GRPC::ServerContext) : MinknowApi::Data::RecordAdaptiveSamplingInformationResponse
• #reset_channel_states(request : MinknowApi::Data::ResetChannelStatesRequest, ctx : GRPC::ServerContext) : MinknowApi::Data::ResetChannelStatesResponse
• #server_streaming?(method : String) : Bool

  server_streaming? returns true if method is a server-streaming RPC.

• #service_full_name : String

  service_full_name returns the full gRPC service name (e.g.

• #unlock_channel_states(request : MinknowApi::Data::UnlockChannelStatesRequest, ctx : GRPC::ServerContext) : MinknowApi::Data::UnlockChannelStatesResponse

Instance Method Detail