Struct RawQueryable

pub struct RawQueryable {
    pub tx: HashMap<Uuid, MessageSender>,
    pub rx: MessageReceiver,
    pub clock: Arc<HLC>,
    pub source: NodeLayout,
    pub layout: QueryableLayout,
}

Not typed Queryable to receive data from the dataflow

Fields

tx: HashMap<Uuid, MessageSender>

The sender part of the MPSC channel with the Query

rx: MessageReceiver

The receiver part of the MPSC channel with the Query

clock: Arc<HLC>

Shared clock with the runtime

source: NodeLayout

The source node layout, useful for debugging

layout: QueryableLayout

The layout of the queryable, useful for debugging

Implementations

impl RawQueryable

pub fn new( tx: HashMap<Uuid, MessageSender>, rx: MessageReceiver, clock: Arc<HLC>, source: NodeLayout, layout: QueryableLayout, ) -> Self

Create a new RawQueryable instance

pub fn blocking_on_demand( &mut self, response: impl FnOnce(DataflowMessage) -> Result<ArrayData>, ) -> Result<()>

Let the queryable handle a message

pub async fn on_demand( &mut self, response: impl AsyncFnOnce(DataflowMessage) -> Result<ArrayData>, ) -> Result<()>

Let the queryable handle a message asynchronously