Struct WebhookSink 

pub struct WebhookSink { /* private fields */ }

POSTs each event as JSON to a configured URL.

Uses a simple HTTP client implementation without external dependencies — actual HTTP I/O is performed by the caller via the composition root when a real HTTP client is available.

For testing and registration purposes, this sink captures the URL and verifies serialization without making network calls.

Implementations

impl WebhookSink

pub fn new(url: impl Into<String>) -> Self

Create a new webhook sink targeting the given URL.

pub fn url(&self) -> &str

Return the configured webhook URL.

Trait Implementations

impl EventSink for WebhookSink

fn name(&self) -> &'static str

Machine-readable sink name.

fn on_event<'life0, 'life1, 'async_trait>( &'life0 self, event: &'life1 RazeriEvent, ) -> Pin<Box<dyn Future<Output = Result<(), EventSinkError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Handle an event. Should not block or panic.

fn flush<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), EventSinkError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Flush any buffered events.