Struct RawQueryable

pub struct RawQueryable {
    pub tx: HashMap<Uuid, Sender<DataflowMessage>>,
    pub rx: Receiver<DataflowMessage>,
    pub clock: Arc<HLC>,
    pub source: NodeID,
    pub layout: QueryableID,
}

Not typed Queryable to receive data from the dataflow

Fields

tx: HashMap<Uuid, Sender<DataflowMessage>>

The sender part of the MPSC channel with the Query

rx: Receiver<DataflowMessage>

The receiver part of the MPSC channel with the Query

clock: Arc<HLC>

Shared clock with the runtime

source: NodeID

The source node layout, useful for debugging

layout: QueryableID

The layout of the queryable, useful for debugging

Implementations

impl RawQueryable

pub fn new( tx: HashMap<Uuid, Sender<DataflowMessage>>, rx: Receiver<DataflowMessage>, clock: Arc<HLC>, source: NodeID, layout: QueryableID, ) -> RawQueryable

Create a new RawQueryable instance

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

Let the queryable handle a message asynchronously