class MinknowApi::Acquisition::AcquisitionService::Client

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.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(channel : GRPC::Channel) #

[View source]

Instance Method Detail

def append_mux_scan_result(request : MuxScanResult, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : AppendMuxScanResultResponse #

[View source]
def append_mux_scan_result_response(request : MuxScanResult, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(AppendMuxScanResultResponse) #

[View source]
def current_status(request : CurrentStatusRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : CurrentStatusResponse #

[View source]
def current_status_response(request : CurrentStatusRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(CurrentStatusResponse) #

[View source]
def get_acquisition_info(request : GetAcquisitionRunInfoRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : AcquisitionRunInfo #

[View source]
def get_acquisition_info_response(request : GetAcquisitionRunInfoRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(AcquisitionRunInfo) #

[View source]
def get_current_acquisition_run(request : GetCurrentAcquisitionRunRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : AcquisitionRunInfo #

[View source]
def get_current_acquisition_run_response(request : GetCurrentAcquisitionRunRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(AcquisitionRunInfo) #

[View source]
def get_progress(request : GetProgressRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GetProgressResponse #

[View source]
def get_progress_response(request : GetProgressRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(GetProgressResponse) #

[View source]
def get_signal_reader(request : GetSignalReaderRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GetSignalReaderResponse #

[View source]
def get_signal_reader_response(request : GetSignalReaderRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(GetSignalReaderResponse) #

[View source]
def list_acquisition_runs(request : ListAcquisitionRunsRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : ListAcquisitionRunsResponse #

[View source]
def list_acquisition_runs_response(request : ListAcquisitionRunsRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(ListAcquisitionRunsResponse) #

[View source]
def set_bream_info(request : SetBreamInfoRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : SetBreamInfoResponse #

[View source]
def set_bream_info_response(request : SetBreamInfoRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(SetBreamInfoResponse) #

[View source]
def set_signal_reader(request : SetSignalReaderRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : SetSignalReaderResponse #

[View source]
def set_signal_reader_response(request : SetSignalReaderRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(SetSignalReaderResponse) #

[View source]
def start(request : StartRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : StartResponse #

[View source]
def start_response(request : StartRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(StartResponse) #

[View source]
def stop(request : StopRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : StopResponse #

[View source]
def stop_response(request : StopRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(StopResponse) #

[View source]
def watch_current_acquisition_run(request : WatchCurrentAcquisitionRunRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::ServerStream(AcquisitionRunInfo) #

[View source]
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.


[View source]