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 : MinknowApi::Data::GetChannelStatesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::ServerStream(MinknowApi::Data::GetChannelStatesResponse) #

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

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

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

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

[View source]
def get_live_reads(ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::BidiCall(MinknowApi::Data::GetLiveReadsRequest, MinknowApi::Data::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 : MinknowApi::Data::GetReadStatisticsRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : MinknowApi::Data::GetReadStatisticsResponse #

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

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

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

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

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

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

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

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

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

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

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

[View source]