class

MinknowApi::Data::DataService::Client

Inherits Reference < Object

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

Constructors

new(channel : GRPC::Channel)
Source

Instance methods

get_channel_states(request : GetChannelStatesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::ServerStream(GetChannelStatesResponse)
Source
get_data_types(request : GetDataTypesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GetDataTypesResponse
Source
get_data_types_response(request : GetDataTypesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(GetDataTypesResponse)
Source
get_experiment_yield_info(request : GetExperimentYieldInfoRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GetExperimentYieldInfoResponse
Source
get_experiment_yield_info_response(request : GetExperimentYieldInfoRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(GetExperimentYieldInfoResponse)
Source
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.

Source
get_read_statistics(request : GetReadStatisticsRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GetReadStatisticsResponse
Source
get_read_statistics_response(request : GetReadStatisticsRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(GetReadStatisticsResponse)
Source
get_signal_bytes(request : GetSignalBytesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::ServerStream(GetSignalBytesResponse)
Source
get_signal_min_max(request : GetSignalMinMaxRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::ServerStream(GetSignalMinMaxResponse)
Source
lock_channel_states(request : LockChannelStatesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : LockChannelStatesResponse
Source
lock_channel_states_response(request : LockChannelStatesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(LockChannelStatesResponse)
Source
record_adaptive_sampling_information(request : RecordAdaptiveSamplingInformationRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : RecordAdaptiveSamplingInformationResponse
Source
record_adaptive_sampling_information_response(request : RecordAdaptiveSamplingInformationRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(RecordAdaptiveSamplingInformationResponse)
Source
reset_channel_states(request : ResetChannelStatesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : ResetChannelStatesResponse
Source
reset_channel_states_response(request : ResetChannelStatesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(ResetChannelStatesResponse)
Source
unlock_channel_states(request : UnlockChannelStatesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : UnlockChannelStatesResponse
Source
unlock_channel_states_response(request : UnlockChannelStatesRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(UnlockChannelStatesResponse)
Source