ferrokinesis 0.1.1

A local AWS Kinesis mock server for testing, written in Rust
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

use crate::constants;
use crate::error::KinesisErrorResponse;
use crate::store::Store;
use crate::types::StreamStatus;
use serde_json::Value;

pub async fn execute(store: &Store, data: Value) -> Result<Option<Value>, KinesisErrorResponse> {
    let stream_name = data[constants::STREAM_NAME].as_str().unwrap_or("");

    // Verify stream exists and set to DELETING
    store
        .update_stream(stream_name, |stream| {
            stream.stream_status = StreamStatus::Deleting;
            Ok(())
        })
        .await?;

    // Delete after delay
    let store_clone = store.clone();
    let name = stream_name.to_string();
    let delay = store.options.delete_stream_ms;
    tokio::spawn(async move {
        tokio::time::sleep(tokio::time::Duration::from_millis(delay)).await;
        store_clone.delete_stream(&name).await;
    });

    Ok(None)
}