Struct DirectSubmitConfig 

pub struct DirectSubmitConfig {

    pub per_target_timeout: Duration,
    pub global_timeout: Duration,
    pub direct_target_rounds: usize,
    pub direct_submit_attempts: usize,
    pub hybrid_direct_attempts: usize,
    pub rebroadcast_interval: Duration,
    pub agave_rebroadcast_enabled: bool,
    pub agave_rebroadcast_window: Duration,
    pub agave_rebroadcast_interval: Duration,
    pub hybrid_rpc_broadcast: bool,
    pub latency_aware_targeting: bool,
    pub latency_probe_timeout: Duration,
    pub latency_probe_port: Option<u16>,
    pub latency_probe_max_targets: usize,
}

Direct submit tuning.

Fields

per_target_timeout: Duration

Per-target send timeout.

global_timeout: Duration

Global send budget for one submission.

direct_target_rounds: usize

Number of rounds to iterate across selected direct targets.

direct_submit_attempts: usize

Number of direct-only submit attempts (target selection can refresh per attempt).

hybrid_direct_attempts: usize

Number of direct submit attempts in Hybrid mode before RPC fallback.

rebroadcast_interval: Duration

Delay between direct rebroadcast attempts/rounds (Agave-like pacing).

agave_rebroadcast_enabled: bool

Enables Agave-style post-ack rebroadcast persistence for direct submits.

agave_rebroadcast_window: Duration

Maximum time budget for background rebroadcast persistence.

agave_rebroadcast_interval: Duration

Delay between background rebroadcast cycles.

hybrid_rpc_broadcast: bool

When true, Hybrid mode broadcasts to RPC even after direct send succeeds.

latency_aware_targeting: bool

Enables latency-aware ordering of direct targets before submit.

latency_probe_timeout: Duration

Timeout used for per-target TCP latency probes.

latency_probe_port: Option<u16>

Optional extra TCP port to probe (in addition to target TPU port).

latency_probe_max_targets: usize

Max number of targets to probe per submission.

Implementations

impl DirectSubmitConfig

pub const fn from_reliability(reliability: SubmitReliability) -> Self

Builds a direct-submit config from a reliability profile.

pub const fn normalized(self) -> Self

Returns this config with minimum valid retry counters.

Trait Implementations

impl Clone for DirectSubmitConfig

fn clone(&self) -> DirectSubmitConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DirectSubmitConfig

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

Formats the value using the given formatter.

impl Default for DirectSubmitConfig

fn default() -> Self

Returns the “default value” for a type.

impl PartialEq for DirectSubmitConfig

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for DirectSubmitConfig

impl StructuralPartialEq for DirectSubmitConfig