abstract class MinknowApi::Statistics::StatisticsService::Service

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/statistics.grpc.cr

Instance Method Summary

Instance Method Detail

def dispatch(method : String, body : Bytes, ctx : GRPC::ServerContext) : Tuple(Bytes, GRPC::Status) #
Description copied from class GRPC::Service

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


[View source]
def dispatch_server_stream(method : String, body : Bytes, ctx : GRPC::ServerContext, writer : GRPC::RawResponseStream) : GRPC::Status #
Description copied from class GRPC::Service

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.


[View source]
abstract def get_read_length_types(request : GetReadLengthTypesRequest, ctx : GRPC::ServerContext) : GetReadLengthTypesResponse #

[View source]
abstract def read_length_n50(request : ReadLengthN50Request, ctx : GRPC::ServerContext) : ReadLengthN50Response #

[View source]
def server_streaming?(method : String) : Bool #
Description copied from class GRPC::Service

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


[View source]
def service_full_name : String #
Description copied from class GRPC::Service

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


[View source]
abstract def stream_acquisition_output(request : StreamAcquisitionOutputRequest, writer : GRPC::ResponseStream(StreamAcquisitionOutputResponse), ctx : GRPC::ServerContext) : GRPC::Status #

[View source]
abstract def stream_basecall_boxplots(request : StreamBoxplotRequest, writer : GRPC::ResponseStream(BoxplotResponse), ctx : GRPC::ServerContext) : GRPC::Status #

[View source]
abstract def stream_bias_voltages(request : StreamBiasVoltagesRequest, writer : GRPC::ResponseStream(StreamBiasVoltagesResponse), ctx : GRPC::ServerContext) : GRPC::Status #

[View source]
abstract def stream_duty_time(request : StreamDutyTimeRequest, writer : GRPC::ResponseStream(StreamDutyTimeResponse), ctx : GRPC::ServerContext) : GRPC::Status #

[View source]
abstract def stream_encountered_acquisition_output_keys(request : StreamEncounteredAcquisitionOutputKeysRequest, writer : GRPC::ResponseStream(StreamEncounteredAcquisitionOutputKeysResponse), ctx : GRPC::ServerContext) : GRPC::Status #

[View source]
abstract def stream_q_accuracy_histogram(request : StreamQAccuracyHistogramRequest, writer : GRPC::ResponseStream(StreamQAccuracyHistogramResponse), ctx : GRPC::ServerContext) : GRPC::Status #

[View source]
abstract def stream_q_score_histogram(request : StreamQScoreHistogramRequest, writer : GRPC::ResponseStream(StreamQScoreHistogramResponse), ctx : GRPC::ServerContext) : GRPC::Status #

[View source]
abstract def stream_read_length_histogram(request : StreamReadLengthHistogramRequest, writer : GRPC::ResponseStream(StreamReadLengthHistogramResponse), ctx : GRPC::ServerContext) : GRPC::Status #

[View source]
abstract def stream_temperature(request : StreamTemperatureRequest, writer : GRPC::ResponseStream(StreamTemperatureResponse), ctx : GRPC::ServerContext) : GRPC::Status #

[View source]
abstract def stream_writer_output(request : StreamWriterOutputRequest, writer : GRPC::ResponseStream(StreamWriterOutputResponse), ctx : GRPC::ServerContext) : GRPC::Status #

[View source]