1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42

//! # Event Streams wasmCloud Actor Interface
//!
//! This crate provides an abstraction over the `wasmcloud:eventstreams` contract. This allows
//! actors to write immutable events to a stream, receive events from a stream,
//! and query events from a stream.
//!
//! # Example:
//! ```
//! extern crate wasmcloud_actor_core as actor;
//! extern crate wasmcloud_actor_eventstreams as streams;
//! extern crate wasmcloud_actor_http_server as http;
//!
//! use wapc_guest::HandlerResult;
//! use streams::*;
//! use std::collections::HashMap;
//!
//! #[actor::init]
//! fn init() {
//!   http::Handlers::register_handle_request(handle_request);
//! }
//!
//! fn handle_request(_req: http::Request) -> HandlerResult<http::Response> {
//!    // process event, query streams, or send new events...
//!    let _evts_so_far = streams::default()
//!       .query_stream(StreamQuery{
//!           stream_id: "hello_stream".to_string(),
//!           range: None,
//!           count: 0                   
//!    });
//!    let ack = streams::default().write_event("hello_stream".to_string(),
//!          HashMap::new())?;
//!    Ok(http::Response::ok())
//! }
//! ```

#[allow(dead_code)]
mod generated;

pub use generated::*;

pub const OP_WRITE_EVENT: &str = "WriteEvent";
pub const OP_QUERY_STREAM: &str = "QueryStream";