Struct SubRequestConnector 

pub struct SubRequestConnector { /* private fields */ }

Shared HTTP connector for sub-requests.

Wraps Pingora’s Connector behind an Arc so that all filter instances share a single connection pool. Created once at server startup and passed through unchanged on config reload.

An optional admission semaphore limits the number of concurrently active sub-request exchanges.

use praxis_core::subrequest::SubRequestConnector;

let connector = SubRequestConnector::new(128, None);
let _clone = connector.clone();

Implementations

impl SubRequestConnector

pub fn new(keepalive_pool_size: usize, max_connections: Option<usize>) -> Self

Create a connector with the given keepalive pool size and optional active-connection limit.

use praxis_core::subrequest::SubRequestConnector;

let connector = SubRequestConnector::new(64, None);
let bounded = SubRequestConnector::new(64, Some(256));

pub fn with_options(opts: SubRequestConnectorOptions) -> Self

Create a connector from SubRequestConnectorOptions.

use praxis_core::subrequest::{SubRequestConnector, SubRequestConnectorOptions};

let connector = SubRequestConnector::with_options(SubRequestConnectorOptions {
    keepalive_pool_size: 64,
    max_connections: Some(256),
    circuit_breaker: None,
});

pub fn connector(&self) -> &Connector<()>

Access the underlying Pingora Connector.

pub async fn acquire_permit(&self) -> Option<OwnedSemaphorePermit>

Acquire an admission permit if a concurrency limit is configured. Returns None when no limit is set.

The returned permit must be held for the entire sub-request exchange. Dropping it releases the slot.

pub async fn try_acquire_permit( &self, timeout: Duration, ) -> Result<Option<OwnedSemaphorePermit>, SubRequestError>

Try to acquire an admission permit within the given deadline.

Returns Ok(Some(permit)) if acquired, Ok(None) if no concurrency limit is configured, or Err if the deadline expires before a slot opens.

Errors

Returns SubRequestError::AdmissionTimeout when the semaphore cannot be acquired within the timeout.

Trait Implementations

impl Clone for SubRequestConnector

fn clone(&self) -> SubRequestConnector

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubRequestConnector

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

Formats the value using the given formatter.