siumai-bridge 0.11.0-beta.9

Protocol bridge helpers for siumai gateway and facade integrations
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

//! Stream bridge inspection.

use crate::{BridgeReport, BridgeTarget};

use super::profile::stream_bridge_profile;

/// Inspect a stream bridge route before the stream is consumed.
pub fn inspect_chat_stream_bridge(
    source: Option<BridgeTarget>,
    target: BridgeTarget,
    report: &mut BridgeReport,
) {
    let profile = stream_bridge_profile(source, target);

    if profile.cross_protocol_lossy {
        report.record_lossy_field(
            "stream.protocol",
            format!(
                "stream bridge {} -> {} runs through best-effort event normalization",
                profile.source.expect("profile source").as_str(),
                profile.target.as_str()
            ),
        );
    }
}