Struct HttpPushSender 

pub struct HttpPushSender { /* private fields */ }

HTTP-based PushSender using hyper.

Retries failed deliveries according to a configurable PushRetryPolicy.

Security

• Rejects webhook URLs targeting private/loopback/link-local addresses to prevent SSRF attacks.
• Validates authentication credentials to prevent HTTP header injection (rejects values containing CR/LF characters).

Implementations

impl HttpPushSender

pub fn new() -> Self

Creates a new HttpPushSender with the default 30-second request timeout and default retry policy.

pub fn with_timeout(request_timeout: Duration) -> Self

Creates a new HttpPushSender with a custom per-request timeout.

pub fn with_retry_policy(self, policy: PushRetryPolicy) -> Self

Sets a custom retry policy for push notification delivery.

pub const fn allow_private_urls(self) -> Self

Creates an HttpPushSender that allows private/loopback URLs.

Warning: This disables SSRF protection and should only be used in testing or trusted environments.

Trait Implementations

impl Debug for HttpPushSender

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

Formats the value using the given formatter.

impl Default for HttpPushSender

fn default() -> Self

Returns the “default value” for a type.

impl PushSender for HttpPushSender

fn allows_private_urls(&self) -> bool

Returns true if this sender allows webhook URLs targeting private/loopback addresses. Used by the handler to skip SSRF validation at push config creation time in testing environments.

fn send<'a>( &'a self, url: &'a str, event: &'a StreamResponse, config: &'a TaskPushNotificationConfig, ) -> Pin<Box<dyn Future<Output = A2aResult<()>> + Send + 'a>>

Sends a streaming event to the client’s webhook URL.