Trait wascc_actor::EventStreams

pub trait EventStreams {
    fn write_event(
        &self, 
        stream: &str, 
        values: HashMap<String, String>
    ) -> Result<String>;
    fn read_all(&self, stream: &str) -> Result<Vec<Event>>;
}

Interaction with append-only event streams. This API is not yet mature and is missing functionality.

Required methods

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

Writes an event to the stream and, if successful, returns a string containing the new event's unique ID

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

Reads all of the events from a stream

Loading content...

Implementors

impl EventStreams for DefaultEventStreams

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

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

Loading content...