Struct PacketPipelineConfig 

pub struct PacketPipelineConfig {
    pub output_concurrency: Option<usize>,
    pub input_concurrency: Option<usize>,
    pub surb_resolution_wait: Option<Duration>,
    pub ack_config: AcknowledgementPipelineConfig,
    pub arbitration: PoolArbitrationConfig,
}

Overall configuration of the input/output packet processing pipeline.

Fields

output_concurrency: Option<usize>

Maximum concurrency when processing outgoing packets.

None or Some(0) both fall back to the default (available parallelism * 8).

input_concurrency: Option<usize>

Maximum concurrency when processing incoming packets (SPHINX decode).

None or Some(0) both fall back to the default (available parallelism * 8), the same as output_concurrency. Encode is no longer protected by throttling this queue depth below output’s (which regressed relay forwarding — #8246); protection now lives in the shared-pool arbiter (see PoolArbitrationConfig), which throttles decode admission only under a genuine flood, leaving pure forwarding at full concurrency.

surb_resolution_wait: Option<Duration>

How long routing resolution keeps waiting for a return path’s SURBs before giving up on the packet.

None falls back to the default of 6 s. Some(0) disables the wait entirely, dropping a return packet the first time its SURBs are missing.

The right value trades two failures against each other. Too short loses data on a session whose SURB pool is only momentarily empty, which is why the wait exists at all. Too long stalls every packet the node originates, not just this one: resolution preserves submission order, so an unresolvable packet withholds everything behind it, and a counterparty that has gone away never sends another SURB. An unbounded wait here took a production exit’s entire egress down for 1h44m while it still forwarded and acknowledged normally.

Set this if you know your session’s frame timeout. The default errs long, because a library cannot know it; a packet held past that timeout is discarded by the receiver anyway, so the wait is pure stall from then on. hoprd, whose sessions time frames out at 3 s, configures 1 s.

ack_config: AcknowledgementPipelineConfig

Configuration of the packet acknowledgement processing

arbitration: PoolArbitrationConfig

Arbitration of the shared Rayon pool between encode and decode.

Trait Implementations

impl Clone for PacketPipelineConfig

fn clone(&self) -> PacketPipelineConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for PacketPipelineConfig

impl Debug for PacketPipelineConfig

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

Formats the value using the given formatter.

impl Default for PacketPipelineConfig

fn default() -> PacketPipelineConfig

Returns the “default value” for a type.

impl PartialEq for PacketPipelineConfig

fn eq(&self, other: &PacketPipelineConfig) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for PacketPipelineConfig

impl Validate for PacketPipelineConfig

fn validate(&self) -> Result<(), ValidationErrors>

impl<'v_a> ValidateArgs<'v_a> for PacketPipelineConfig

type Args = ()

fn validate_with_args(&self, args: Self::Args) -> Result<(), ValidationErrors>