class

MinknowApi::Acquisition::AcquisitionService::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

append_mux_scan_result(request : MuxScanResult, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : AppendMuxScanResultResponse
Source
append_mux_scan_result_response(request : MuxScanResult, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(AppendMuxScanResultResponse)
Source
current_status(request : CurrentStatusRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : CurrentStatusResponse
Source
current_status_response(request : CurrentStatusRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(CurrentStatusResponse)
Source
get_acquisition_info(request : GetAcquisitionRunInfoRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : AcquisitionRunInfo
Source
get_acquisition_info_response(request : GetAcquisitionRunInfoRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(AcquisitionRunInfo)
Source
get_current_acquisition_run(request : GetCurrentAcquisitionRunRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : AcquisitionRunInfo
Source
get_current_acquisition_run_response(request : GetCurrentAcquisitionRunRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(AcquisitionRunInfo)
Source
get_progress(request : GetProgressRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GetProgressResponse
Source
get_progress_response(request : GetProgressRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(GetProgressResponse)
Source
get_signal_reader(request : GetSignalReaderRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GetSignalReaderResponse
Source
get_signal_reader_response(request : GetSignalReaderRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(GetSignalReaderResponse)
Source
list_acquisition_runs(request : ListAcquisitionRunsRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : ListAcquisitionRunsResponse
Source
list_acquisition_runs_response(request : ListAcquisitionRunsRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(ListAcquisitionRunsResponse)
Source
set_bream_info(request : SetBreamInfoRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : SetBreamInfoResponse
Source
set_bream_info_response(request : SetBreamInfoRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(SetBreamInfoResponse)
Source
set_signal_reader(request : SetSignalReaderRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : SetSignalReaderResponse
Source
set_signal_reader_response(request : SetSignalReaderRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(SetSignalReaderResponse)
Source
start(request : StartRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : StartResponse
Source
start_response(request : StartRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(StartResponse)
Source
stop(request : StopRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : StopResponse
Source
stop_response(request : StopRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(StopResponse)
Source
watch_current_acquisition_run(request : WatchCurrentAcquisitionRunRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::ServerStream(AcquisitionRunInfo)
Source
watch_for_status_change(ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::BidiCall(WatchForStatusChangeRequest, WatchForStatusChangeResponse)

watch_for_status_change 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