Struct WebhookSubscriber 

pub struct WebhookSubscriber {
    pub id: String,
    pub url: String,
    pub event_pattern: String,
    pub headers: HashMap<String, String>,
    pub retry_count: u32,
    pub timeout_ms: u64,
    pub retry: EventRetryConfig,
}

Delivers events via HTTP POST to a webhook URL.

Delivery contract (spec docs/features/event-system.md §Event Delivery Semantics, Issue #61): on_event performs a single HTTP attempt and returns Err(ModuleError) on 5xx or network errors so that the surrounding EventEmitter retry+DLQ policy (configured via retry) applies uniformly across subscriber types. 4xx responses are non-retryable client errors — they are logged at WARN and reported as Ok to suppress the spec retry loop.

Requires the events cargo feature for actual HTTP delivery.

Fields

id: String

url: String

event_pattern: String

headers: HashMap<String, String>

retry_count: u32

Deprecated alias for retry.max_attempts. Retained as a public field for backward-compatible construction; new code should configure retry instead. When both are present in YAML the spec requires retry.max_attempts to win — that resolution happens in build_webhook_subscriber.

timeout_ms: u64

retry: EventRetryConfig

Retry policy applied by EventEmitter — see spec §Event Delivery Semantics (#61).

Implementations

impl WebhookSubscriber

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

pub fn with_retry(self, retry: EventRetryConfig) -> Self

Override the retry policy applied by EventEmitter.

Trait Implementations

impl Clone for WebhookSubscriber

fn clone(&self) -> WebhookSubscriber

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for WebhookSubscriber

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl EventSubscriber for WebhookSubscriber

fn subscriber_id(&self) -> &str

Unique ID for this subscriber (used by unsubscribe).

fn subscriber_type(&self) -> &str

Declared subscriber type, surfaced in apcore.event.delivery_failed DLQ payloads as subscriber_type (sync finding A-D-029).

fn event_pattern(&self) -> &str

The event type pattern this subscriber is interested in.

fn retry(&self) -> EventRetryConfig

Retry configuration for delivery of events to this subscriber.

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

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

Handle an incoming event.

fn event_type_filter(&self) -> Option<&str>

The bound event-type string for bulk unsubscription, if set.

fn on_failure<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _event: &'life1 ApCoreEvent, _error: &'life2 ModuleError, _attempt_count: u32, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Called after all retry attempts are exhausted for a single event.