Struct LineIngress 

pub struct LineIngress<R> { /* private fields */ }

A simple line-delimited ingress adapter.

Each call to IngressAdapter::read_next reads one line, strips the trailing \n (and optional \r), and copies it into the provided output buffer.

Implementations

impl<R> LineIngress<R>

pub fn new(name: impl Into<String>, inner: R) -> Self

Create a line-delimited ingress adapter.

Trait Implementations

impl<R> Adapter for LineIngress<R>

fn name(&self) -> &str

Stable adapter name for logs/obs.

fn transport_kind(&self) -> &str

Adapter transport family label.

fn connection_state(&self) -> &str

Best-effort connection/runtime state for operator visibility.

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

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

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

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

impl<R: BufRead> IngressAdapter for LineIngress<R>

fn read_next(&mut self, out: &mut [u8]) -> Result<Option<usize>, AdapterError>

Read the next message.