Struct HttpWebhookSender 

pub struct HttpWebhookSender { /* private fields */ }

HTTP webhook sender with retry logic

Example

use reinhardt_tasks::webhook::{HttpWebhookSender, WebhookConfig, RetryConfig};
use std::time::Duration;

let config = WebhookConfig {
    url: "https://example.com/webhook".to_string(),
    method: "POST".to_string(),
    headers: Default::default(),
    timeout: Duration::from_secs(5),
    retry_config: RetryConfig::default(),
};

let sender = HttpWebhookSender::new(config);

Implementations

impl HttpWebhookSender

pub fn new(config: WebhookConfig) -> Self

Create a new HTTP webhook sender

Example

use reinhardt_tasks::webhook::{HttpWebhookSender, WebhookConfig};

let sender = HttpWebhookSender::new(WebhookConfig::default());

pub fn calculate_backoff(&self, retry_count: u32) -> Duration

Calculate backoff duration with exponential backoff and jitter

Example

use reinhardt_tasks::webhook::{HttpWebhookSender, WebhookConfig, RetryConfig};
use std::time::Duration;

let config = WebhookConfig {
    url: "https://example.com".to_string(),
    method: "POST".to_string(),
    headers: Default::default(),
    timeout: Duration::from_secs(5),
    retry_config: RetryConfig::default(),
};

let sender = HttpWebhookSender::new(config);
let backoff = sender.calculate_backoff(2);
assert!(backoff > Duration::from_millis(0));

Trait Implementations

impl WebhookSender for HttpWebhookSender

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

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

Send a webhook event