Struct HttpEgress 

pub struct HttpEgress { /* private fields */ }

Minimal blocking HTTP egress adapter.

Each write_msg() performs a POST with application/octet-stream body bytes.

Implementations

impl HttpEgress

pub fn new( name: impl Into<String>, url: impl Into<String>, headers: Vec<(String, String)>, timeout: Duration, max_retries: usize, ) -> Result<Self, AdapterError>

Create a blocking HTTP egress adapter.

pub fn with_method( name: impl Into<String>, url: impl Into<String>, method: impl Into<String>, headers: Vec<(String, String)>, timeout: Duration, max_retries: usize, ) -> Result<Self, AdapterError>

Create a blocking HTTP egress adapter with an explicit method.

Trait Implementations

impl Adapter for HttpEgress

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 EgressAdapter for HttpEgress

fn write_msg(&mut self, msg: &[u8]) -> Result<(), AdapterError>

Write one message.

fn flush(&mut self) -> Result<(), AdapterError>

Flush buffered output.