class
MinknowApi::Acquisition::AcquisitionService::Client
- MinknowApi::Acquisition::AcquisitionService::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/acquisition.grpc.crConstructors
Instance Method Summary
- #append_mux_scan_result(request : MuxScanResult, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : AppendMuxScanResultResponse
- #append_mux_scan_result_response(request : MuxScanResult, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(AppendMuxScanResultResponse)
- #current_status(request : CurrentStatusRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : CurrentStatusResponse
- #current_status_response(request : CurrentStatusRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(CurrentStatusResponse)
- #get_acquisition_info(request : GetAcquisitionRunInfoRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : AcquisitionRunInfo
- #get_acquisition_info_response(request : GetAcquisitionRunInfoRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(AcquisitionRunInfo)
- #get_current_acquisition_run(request : GetCurrentAcquisitionRunRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : AcquisitionRunInfo
- #get_current_acquisition_run_response(request : GetCurrentAcquisitionRunRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(AcquisitionRunInfo)
- #get_progress(request : GetProgressRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GetProgressResponse
- #get_progress_response(request : GetProgressRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(GetProgressResponse)
- #get_signal_reader(request : GetSignalReaderRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GetSignalReaderResponse
- #get_signal_reader_response(request : GetSignalReaderRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(GetSignalReaderResponse)
- #list_acquisition_runs(request : ListAcquisitionRunsRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : ListAcquisitionRunsResponse
- #list_acquisition_runs_response(request : ListAcquisitionRunsRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(ListAcquisitionRunsResponse)
- #set_bream_info(request : SetBreamInfoRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : SetBreamInfoResponse
- #set_bream_info_response(request : SetBreamInfoRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(SetBreamInfoResponse)
- #set_signal_reader(request : SetSignalReaderRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : SetSignalReaderResponse
- #set_signal_reader_response(request : SetSignalReaderRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(SetSignalReaderResponse)
- #start(request : StartRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : StartResponse
- #start_response(request : StartRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(StartResponse)
- #stop(request : StopRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : StopResponse
- #stop_response(request : StopRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(StopResponse)
- #watch_current_acquisition_run(request : WatchCurrentAcquisitionRunRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::ServerStream(AcquisitionRunInfo)
-
#watch_for_status_change(ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::BidiCall(WatchForStatusChangeRequest, WatchForStatusChangeResponse)
watch_for_status_change opens a bidirectional-streaming RPC.
Constructor Detail
Instance Method Detail
def append_mux_scan_result(request : MuxScanResult, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : AppendMuxScanResultResponse
#
def append_mux_scan_result_response(request : MuxScanResult, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(AppendMuxScanResultResponse)
#
def current_status(request : CurrentStatusRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : CurrentStatusResponse
#
def current_status_response(request : CurrentStatusRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(CurrentStatusResponse)
#
def get_acquisition_info(request : GetAcquisitionRunInfoRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : AcquisitionRunInfo
#
def get_acquisition_info_response(request : GetAcquisitionRunInfoRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(AcquisitionRunInfo)
#
def get_current_acquisition_run(request : GetCurrentAcquisitionRunRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : AcquisitionRunInfo
#
def get_current_acquisition_run_response(request : GetCurrentAcquisitionRunRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(AcquisitionRunInfo)
#
def get_progress(request : GetProgressRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GetProgressResponse
#
def get_progress_response(request : GetProgressRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(GetProgressResponse)
#
def get_signal_reader(request : GetSignalReaderRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GetSignalReaderResponse
#
def get_signal_reader_response(request : GetSignalReaderRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(GetSignalReaderResponse)
#
def list_acquisition_runs(request : ListAcquisitionRunsRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : ListAcquisitionRunsResponse
#
def list_acquisition_runs_response(request : ListAcquisitionRunsRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(ListAcquisitionRunsResponse)
#
def set_bream_info(request : SetBreamInfoRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : SetBreamInfoResponse
#
def set_bream_info_response(request : SetBreamInfoRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(SetBreamInfoResponse)
#
def set_signal_reader(request : SetSignalReaderRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : SetSignalReaderResponse
#
def set_signal_reader_response(request : SetSignalReaderRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(SetSignalReaderResponse)
#
def start(request : StartRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : StartResponse
#
def start_response(request : StartRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(StartResponse)
#
def stop(request : StopRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : StopResponse
#
def stop_response(request : StopRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(StopResponse)
#
def watch_current_acquisition_run(request : WatchCurrentAcquisitionRunRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::ServerStream(AcquisitionRunInfo)
#
def 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.