class
MinknowApi::Data::DataService::Client
- MinknowApi::Data::DataService::Client
- Reference
- Object
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.crConstructors
Instance Method Summary
- #get_channel_states(request : GetChannelStatesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::ServerStream(GetChannelStatesResponse)
- #get_data_types(request : GetDataTypesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GetDataTypesResponse
- #get_data_types_response(request : GetDataTypesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(GetDataTypesResponse)
- #get_experiment_yield_info(request : GetExperimentYieldInfoRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GetExperimentYieldInfoResponse
- #get_experiment_yield_info_response(request : GetExperimentYieldInfoRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(GetExperimentYieldInfoResponse)
-
#get_live_reads(ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::BidiCall(GetLiveReadsRequest, GetLiveReadsResponse)
get_live_reads opens a bidirectional-streaming RPC.
- #get_read_statistics(request : GetReadStatisticsRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GetReadStatisticsResponse
- #get_read_statistics_response(request : GetReadStatisticsRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(GetReadStatisticsResponse)
- #get_signal_bytes(request : GetSignalBytesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::ServerStream(GetSignalBytesResponse)
- #get_signal_min_max(request : GetSignalMinMaxRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::ServerStream(GetSignalMinMaxResponse)
- #lock_channel_states(request : LockChannelStatesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : LockChannelStatesResponse
- #lock_channel_states_response(request : LockChannelStatesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(LockChannelStatesResponse)
- #record_adaptive_sampling_information(request : RecordAdaptiveSamplingInformationRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : RecordAdaptiveSamplingInformationResponse
- #record_adaptive_sampling_information_response(request : RecordAdaptiveSamplingInformationRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(RecordAdaptiveSamplingInformationResponse)
- #reset_channel_states(request : ResetChannelStatesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : ResetChannelStatesResponse
- #reset_channel_states_response(request : ResetChannelStatesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(ResetChannelStatesResponse)
- #unlock_channel_states(request : UnlockChannelStatesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : UnlockChannelStatesResponse
- #unlock_channel_states_response(request : UnlockChannelStatesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(UnlockChannelStatesResponse)
Constructor Detail
Instance Method Detail
def get_channel_states(request : GetChannelStatesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::ServerStream(GetChannelStatesResponse)
#
def get_data_types(request : GetDataTypesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GetDataTypesResponse
#
def get_data_types_response(request : GetDataTypesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(GetDataTypesResponse)
#
def get_experiment_yield_info(request : GetExperimentYieldInfoRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GetExperimentYieldInfoResponse
#
def get_experiment_yield_info_response(request : GetExperimentYieldInfoRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(GetExperimentYieldInfoResponse)
#
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.
def get_read_statistics(request : GetReadStatisticsRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GetReadStatisticsResponse
#
def get_read_statistics_response(request : GetReadStatisticsRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(GetReadStatisticsResponse)
#
def get_signal_bytes(request : GetSignalBytesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::ServerStream(GetSignalBytesResponse)
#
def get_signal_min_max(request : GetSignalMinMaxRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::ServerStream(GetSignalMinMaxResponse)
#
def lock_channel_states(request : LockChannelStatesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : LockChannelStatesResponse
#
def lock_channel_states_response(request : LockChannelStatesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(LockChannelStatesResponse)
#
def record_adaptive_sampling_information(request : RecordAdaptiveSamplingInformationRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : RecordAdaptiveSamplingInformationResponse
#
def record_adaptive_sampling_information_response(request : RecordAdaptiveSamplingInformationRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(RecordAdaptiveSamplingInformationResponse)
#
def reset_channel_states(request : ResetChannelStatesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : ResetChannelStatesResponse
#
def reset_channel_states_response(request : ResetChannelStatesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(ResetChannelStatesResponse)
#
def unlock_channel_states(request : UnlockChannelStatesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : UnlockChannelStatesResponse
#
def unlock_channel_states_response(request : UnlockChannelStatesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(UnlockChannelStatesResponse)
#