4 releases
0.2.1 | Apr 16, 2021 |
---|---|
0.2.0 | Mar 10, 2021 |
0.1.1 | Feb 17, 2021 |
0.1.0 | Feb 10, 2021 |
#1602 in WebAssembly
Used in wasmcloud-streams-redis
11KB
152 lines
wasmCloud Event Streams 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
#[macro_use]
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())
}
Dependencies
~1–2MB
~41K SLoC