rocketman 0.4.0

A modular(ish) jetstream consumer.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use anyhow::Result;
use async_trait::async_trait;
use serde_json::Value;
use tracing::info;

use crate::types::event::Event;

#[async_trait]
pub trait LexiconIngestor {
    async fn ingest(&self, message: Event<Value>) -> Result<()>;
}

pub struct DefaultLexiconIngestor;

#[async_trait]
impl LexiconIngestor for DefaultLexiconIngestor {
    async fn ingest(&self, message: Event<Value>) -> Result<()> {
        info!("Default lexicon processing: {:?}", message);
        // Process message for default lexicon.
        Ok(())
    }
}