Struct WebhookSubscriber 

pub struct WebhookSubscriber { /* private fields */ }

Subscriber that POSTs the event as JSON to a webhook URL.

Retries failed deliveries with exponential backoff (up to 3 attempts, 5 s timeout per attempt). The HTTP client is created once and reused.

Event type filtering is handled by the EventPublisher at subscription time – this subscriber receives only events that already passed the filter.

Examples

use ironflow_engine::notify::{Event, EventPublisher, WebhookSubscriber};

let mut publisher = EventPublisher::new();
publisher.subscribe(
    WebhookSubscriber::new("https://hooks.example.com/events"),
    &[Event::RUN_STATUS_CHANGED, Event::STEP_FAILED],
);

Implementations

impl WebhookSubscriber

pub fn new(url: &str) -> Self

Create a new webhook subscriber targeting the given URL.

Panics

Panics if the HTTP client cannot be built (TLS backend unavailable).

Examples

use ironflow_engine::notify::WebhookSubscriber;

let subscriber = WebhookSubscriber::new("https://example.com/hook");
assert_eq!(subscriber.url(), "https://example.com/hook");

pub fn url(&self) -> &str

Returns the target URL.

Trait Implementations

impl EventSubscriber for WebhookSubscriber

fn name(&self) -> &str

A short identifier for this subscriber (used in logs).

fn handle<'a>(&'a self, event: &'a Event) -> SubscriberFuture<'a>

Handle a domain event.