manager_handlers 0.7.2

A microservice manager implementation that creates HTTP-accessible handlers with configurable replicas. Handlers communicate via an internal bus, enabling collaborative request processing in a distributed architecture.
Documentation 
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
43
44
45
46
47
48
49
50
51
52

use crate::core::communication::multibus::MultiBus;
use crate::core::{states::SharedState, traits::Base};
use crate::handler;
use async_trait::async_trait;
use bytes::Bytes;
use futures_util::StreamExt;
use std::error::Error;
use std::io::Cursor;
use std::pin::Pin;
use std::sync::Arc;
use tokio::io::AsyncRead;
use tokio_stream::Stream;

handler! {
    DownloadHandler, download;
    async fn run_file(&self,_src: String,  _filename: String) -> Result<(Box<dyn AsyncRead + Send + Unpin>, u64), Box<dyn Error + Send + Sync>> {
        let data = b"test data".to_vec();
        let cursor = Cursor::new(data);
        Ok((Box::new(cursor), 9))
    },
}

handler! {
    TestUpload, upload;
    async fn run_stream(&self,_src: String, mut stream: Pin<Box<dyn Stream<Item = Bytes> + Send>>, _file_name: String, _lower_bound: usize) -> Result<String, Box<dyn Error + Send + Sync>> {
        let mut result = String::new();
        while let Some(chunk) = stream.next().await {
            let s = std::str::from_utf8(&chunk)?;
            result.push_str(s);
        }
        Ok(result)
    },
}

handler! {
    UploadHandler, upload;
    async fn run_stream(&self,_src: String, mut stream: Pin<Box<dyn Stream<Item = Bytes> + Send>>, _file_name: String, _lower_bound: usize) -> Result<String, Box<dyn Error + Send + Sync>> {
        let mut result = String::new();
        while let Some(chunk) = stream.next().await {
            let s = std::str::from_utf8(&chunk)?;
            result.push_str(s);
        }
        Ok(result)
    },
}

handler! {
    MetadataHandler, metadata;
    async fn run_metadata(&self,_src: String,_file_id: String) -> Result<String, Box<dyn Error + Send + Sync>> {
        Ok("metadata".to_string())
    },
}