class MinknowApi::Data::DataService::Client

Overview

Client is the generated type-safe client stub. Create one per GRPC::Channel and reuse across calls.

Defined in:

generated/minknow_api/data.grpc.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(channel : GRPC::Channel) #

[View source]

Instance Method Detail

def get_channel_states(request : GetChannelStatesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::ServerStream(GetChannelStatesResponse) #

[View source]
def get_data_types(request : GetDataTypesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GetDataTypesResponse #

[View source]
def get_data_types_response(request : GetDataTypesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(GetDataTypesResponse) #

[View source]
def get_experiment_yield_info(request : GetExperimentYieldInfoRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GetExperimentYieldInfoResponse #

[View source]
def get_experiment_yield_info_response(request : GetExperimentYieldInfoRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(GetExperimentYieldInfoResponse) #

[View source]
def get_live_reads(ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::BidiCall(GetLiveReadsRequest, GetLiveReadsResponse) #

get_live_reads opens a bidirectional-streaming RPC. Send messages via the returned BidiCall, then call close_send to signal end-of-input and iterate the replies with #each.


[View source]
def get_read_statistics(request : GetReadStatisticsRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GetReadStatisticsResponse #

[View source]
def get_read_statistics_response(request : GetReadStatisticsRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(GetReadStatisticsResponse) #

[View source]
def get_signal_bytes(request : GetSignalBytesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::ServerStream(GetSignalBytesResponse) #

[View source]
def get_signal_min_max(request : GetSignalMinMaxRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::ServerStream(GetSignalMinMaxResponse) #

[View source]
def lock_channel_states(request : LockChannelStatesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : LockChannelStatesResponse #

[View source]
def lock_channel_states_response(request : LockChannelStatesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(LockChannelStatesResponse) #

[View source]
def record_adaptive_sampling_information(request : RecordAdaptiveSamplingInformationRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : RecordAdaptiveSamplingInformationResponse #

[View source]
def record_adaptive_sampling_information_response(request : RecordAdaptiveSamplingInformationRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(RecordAdaptiveSamplingInformationResponse) #

[View source]
def reset_channel_states(request : ResetChannelStatesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : ResetChannelStatesResponse #

[View source]
def reset_channel_states_response(request : ResetChannelStatesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(ResetChannelStatesResponse) #

[View source]
def unlock_channel_states(request : UnlockChannelStatesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : UnlockChannelStatesResponse #

[View source]
def unlock_channel_states_response(request : UnlockChannelStatesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(UnlockChannelStatesResponse) #

[View source]