iii-sdk 0.21.3

SDK for III Engine - a platform for building distributed applications
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use async_trait::async_trait;
use iii_helpers::stream::{
    StreamDeleteInput, StreamDeleteResult, StreamGetInput, StreamListGroupsInput, StreamListInput,
    StreamSetInput, StreamSetResult, StreamUpdateInput, StreamUpdateResult,
};
use serde_json::Value;

use crate::error::Error;

/// Custom stream-provider trait. Implementors override the engine's built-in
/// stream storage for a specific stream name when registered through
/// `create_stream` in the `helpers` submodule.
#[async_trait]
pub trait IStream: Send + Sync + 'static {
    async fn get(&self, input: StreamGetInput) -> Result<Option<Value>, Error>;
    async fn set(&self, input: StreamSetInput) -> Result<Option<StreamSetResult>, Error>;
    async fn delete(&self, input: StreamDeleteInput) -> Result<StreamDeleteResult, Error>;
    async fn list(&self, input: StreamListInput) -> Result<Vec<Value>, Error>;
    async fn list_groups(&self, input: StreamListGroupsInput) -> Result<Vec<String>, Error>;
    async fn update(&self, input: StreamUpdateInput) -> Result<Option<StreamUpdateResult>, Error>;
}