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

Constructors

.new(channel : GRPC::Channel)

Instance Method Summary

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

Constructor Detail

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

[View source]

Instance Method Detail

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

[View source]

def append_mux_scan_result_response(request : MinknowApi::Acquisition::MuxScanResult, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(MinknowApi::Acquisition::AppendMuxScanResultResponse) #

[View source]

def current_status(request : MinknowApi::Acquisition::CurrentStatusRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : MinknowApi::Acquisition::CurrentStatusResponse #

[View source]

def current_status_response(request : MinknowApi::Acquisition::CurrentStatusRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(MinknowApi::Acquisition::CurrentStatusResponse) #

[View source]

def get_acquisition_info(request : MinknowApi::Acquisition::GetAcquisitionRunInfoRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : MinknowApi::Acquisition::AcquisitionRunInfo #

[View source]

def get_acquisition_info_response(request : MinknowApi::Acquisition::GetAcquisitionRunInfoRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(MinknowApi::Acquisition::AcquisitionRunInfo) #

[View source]

def get_current_acquisition_run(request : MinknowApi::Acquisition::GetCurrentAcquisitionRunRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : MinknowApi::Acquisition::AcquisitionRunInfo #

[View source]

def get_current_acquisition_run_response(request : MinknowApi::Acquisition::GetCurrentAcquisitionRunRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(MinknowApi::Acquisition::AcquisitionRunInfo) #

[View source]

def get_progress(request : MinknowApi::Acquisition::GetProgressRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : MinknowApi::Acquisition::GetProgressResponse #

[View source]

def get_progress_response(request : MinknowApi::Acquisition::GetProgressRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(MinknowApi::Acquisition::GetProgressResponse) #

[View source]

def get_signal_reader(request : MinknowApi::Acquisition::GetSignalReaderRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : MinknowApi::Acquisition::GetSignalReaderResponse #

[View source]

def get_signal_reader_response(request : MinknowApi::Acquisition::GetSignalReaderRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(MinknowApi::Acquisition::GetSignalReaderResponse) #

[View source]

def list_acquisition_runs(request : MinknowApi::Acquisition::ListAcquisitionRunsRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : MinknowApi::Acquisition::ListAcquisitionRunsResponse #

[View source]

def list_acquisition_runs_response(request : MinknowApi::Acquisition::ListAcquisitionRunsRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(MinknowApi::Acquisition::ListAcquisitionRunsResponse) #

[View source]

def set_bream_info(request : MinknowApi::Acquisition::SetBreamInfoRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : MinknowApi::Acquisition::SetBreamInfoResponse #

[View source]

def set_bream_info_response(request : MinknowApi::Acquisition::SetBreamInfoRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(MinknowApi::Acquisition::SetBreamInfoResponse) #

[View source]

def set_signal_reader(request : MinknowApi::Acquisition::SetSignalReaderRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : MinknowApi::Acquisition::SetSignalReaderResponse #

[View source]

def set_signal_reader_response(request : MinknowApi::Acquisition::SetSignalReaderRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(MinknowApi::Acquisition::SetSignalReaderResponse) #

[View source]

def start(request : MinknowApi::Acquisition::StartRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : MinknowApi::Acquisition::StartResponse #

[View source]

def start_response(request : MinknowApi::Acquisition::StartRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(MinknowApi::Acquisition::StartResponse) #

[View source]

def stop(request : MinknowApi::Acquisition::StopRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : MinknowApi::Acquisition::StopResponse #

[View source]

def stop_response(request : MinknowApi::Acquisition::StopRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::UnaryResponse(MinknowApi::Acquisition::StopResponse) #

[View source]

def watch_current_acquisition_run(request : MinknowApi::Acquisition::WatchCurrentAcquisitionRunRequest, ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::ServerStream(MinknowApi::Acquisition::AcquisitionRunInfo) #

[View source]

def watch_for_status_change(ctx : GRPC::ClientContext = GRPC::ClientContext.new) : GRPC::BidiCall(MinknowApi::Acquisition::WatchForStatusChangeRequest, MinknowApi::Acquisition::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]