Struct wascc_actor::events::EventStreamsHostBinding

pub struct EventStreamsHostBinding { /* fields omitted */ }

A host binding for an event stream capability provider

Implementations

impl EventStreamsHostBinding

pub fn write_event(
    &self,
    stream: &str,
    values: HashMap<String, String>
) -> HandlerResult<String>

Writes the given event (a collection of key-value pairs) to a named stream

pub fn read_all(&self, stream: &str) -> HandlerResult<Vec<Event>>

Reads all available events from the given stream

pub fn read_limit(&self, stream: &str, limit: u64) -> HandlerResult<Vec<Event>>

Reads all available events from a given stream up to a given maximum number. May return less than the specified limit if less than that exist on the stream