nominal-streaming 0.8.0

Library for durable, low-latency streaming into Nominal Core
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

use std::error::Error;
use std::fmt::Debug;
use std::panic::RefUnwindSafe;
use std::sync::Arc;

use nominal_api::tonic::io::nominal::scout::api::proto::WriteRequestNominal;
use tracing::error;

pub trait NominalStreamListener: Send + Sync + Debug + RefUnwindSafe {
    fn on_error(&self, error: &dyn Error, request: &WriteRequestNominal);

    fn on_success(&self, _request: &WriteRequestNominal) {}
}

impl NominalStreamListener for Vec<Arc<dyn NominalStreamListener>> {
    fn on_error(&self, error: &dyn Error, request: &WriteRequestNominal) {
        for listener in self {
            listener.on_error(error, request);
        }
    }

    fn on_success(&self, request: &WriteRequestNominal) {
        for listener in self {
            listener.on_success(request);
        }
    }
}

#[derive(Debug, Default, Clone)]
pub struct LoggingListener;

impl NominalStreamListener for LoggingListener {
    fn on_error(&self, error: &dyn Error, request: &WriteRequestNominal) {
        let len = request.series.len();
        let message = format!("Failed to consume request with {len} series");
        error!("{message}: {error}");
    }
}