class Minknow::DataService

Overview

Wrapper around the MinKNOW Data gRPC service.

Exposes the live-reads bidirectional stream and helper types for building GetLiveReadsRequest messages. Access via Connection#data.

Defined in:

minknow/data_service.cr

Constructors

Class Method Summary

Instance Method Summary

Constructor Detail

def self.new(channel : GRPC::Channel, ctx : GRPC::ClientContext) #

[View source]

Class Method Detail

def self.actions_request(actions : Array(Action)) : LiveRequest #

Convenience: builds an actions-only request from a batch of actions.


[View source]
def self.setup_request(first_channel : Int32 = 1, last_channel : Int32 = 512, raw_data_type : RawDataType = RawDataType::CALIBRATED, sample_minimum_chunk_size : UInt64 = 0_u64, accepted_first_chunk_classifications : Array(Int32) = [] of Int32) : LiveRequest #

Convenience: builds a setup-only request message.


[View source]
def self.stop_action(action_id : String, channel : UInt32, read_id : String) : Action #

Convenience: builds a stop-further-data action.


[View source]
def self.unblock_action(action_id : String, channel : UInt32, read_id : String, duration : Float64 = 0.1) : Action #

Convenience: builds an unblock action.


[View source]

Instance Method Detail


[View source]
def data_types : DataTypes #

Returns the data types (signal calibration, dtype) for this device.


[View source]
def live_reads : GRPC::BidiCall(LiveRequest, LiveResponse) #

Opens a bidirectional live-reads stream.

Returns a GRPC::BidiCall that you send GetLiveReadsRequest messages into and receive GetLiveReadsResponse messages from. The first message sent must contain a StreamSetup.


[View source]