iii-sdk 0.18.0-next.1

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 serde_json::Value;

use crate::error::IIIError;
use crate::types::{
    DeleteResult, SetResult, StreamDeleteInput, StreamGetInput, StreamListGroupsInput,
    StreamListInput, StreamSetInput, StreamUpdateInput, UpdateResult,
};

/// 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>, IIIError>;
    async fn set(&self, input: StreamSetInput) -> Result<Option<SetResult>, IIIError>;
    async fn delete(&self, input: StreamDeleteInput) -> Result<DeleteResult, IIIError>;
    async fn list(&self, input: StreamListInput) -> Result<Vec<Value>, IIIError>;
    async fn list_groups(&self, input: StreamListGroupsInput) -> Result<Vec<String>, IIIError>;
    async fn update(&self, input: StreamUpdateInput) -> Result<Option<UpdateResult>, IIIError>;
}