Adapter

Trait Adapter 

Source
pub trait Adapter {
    // Required method
    fn name(&self) -> &str;

    // Provided methods
    fn transport_kind(&self) -> &str { ... }
    fn connection_state(&self) -> &str { ... }
    fn lag(&self) -> Option<u64> { ... }
    fn status_fields(&self) -> Map<String, Value> { ... }
}
Expand description

Minimal adapter identity contract.

Required Methods§

Source

fn name(&self) -> &str

Stable adapter name for logs/obs.

Provided Methods§

Source

fn transport_kind(&self) -> &str

Adapter transport family label.

Source

fn connection_state(&self) -> &str

Best-effort connection/runtime state for operator visibility.

Source

fn lag(&self) -> Option<u64>

Best-effort queue/stream lag, when the adapter can observe it.

Source

fn status_fields(&self) -> Map<String, Value>

Transport-specific runtime fields that can be attached to operator snapshots.

Implementations on Foreign Types§

Source§

impl<T> Adapter for Box<T>
where T: Adapter + ?Sized,

Implementors§