Struct Queries

pub struct Queries { /* private fields */ }

Queries let you manage query connections during a node implementation

Implementations

impl Queries

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

Creates a new instance of Queries.

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

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

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

Creates a new query, this query has type information