Struct Queryables

pub struct Queryables { /* private fields */ }

Queryables let you manage queryable connections during a node implementation

Implementations

impl Queryables

pub fn new( senders: Arc<Mutex<HashMap<Uuid, HashMap<Uuid, MessageSender>>>>, receivers: Arc<Mutex<HashMap<Uuid, MessageReceiver>>>, clock: Arc<HLC>, source: NodeLayout, ) -> Self

Creates a new instance of ‘Queryables’

pub async fn raw( &mut self, queryable: impl Into<String>, ) -> Result<RawQueryable>

Creates a new raw Queryable, this raw queryable has no type information so you have to manually transform it

pub async fn with<T: ArrowMessage, F: ArrowMessage>( &mut self, queryable: impl Into<String>, ) -> Result<Queryable<T, F>>

Creates a new typed Queryable, this queryable has type information