Struct ChainExecutor 

pub struct ChainExecutor { /* private fields */ }

Executor for proxy chains.

Establishes a connection through a series of proxy hops, performing the appropriate protocol handshake at each step.

Chain Execution Flow

Transport to hop 1
→ TLS wrap (if hop.tls)
→ protocol handshake requesting hop 2
→ TLS wrap (if hop.tls)
→ protocol handshake requesting hop 3
→ final protocol handshake requesting destination

Implementations

impl ChainExecutor

pub fn new(handlers: Vec<Box<dyn HopHandler>>) -> Self

Creates a new ChainExecutor with the given protocol handlers.

pub fn with_tls_wrapper(self, wrapper: TlsWrapper) -> Self

Set a TLS wrapper for upstream hops with tls: true.

pub fn with_shared_tls_config(self, config: Option<Arc<ClientConfig>>) -> Self

Set a shared TLS client config for protocols that need their own TLS handshake (e.g., Trojan).

pub fn with_insecure_shared_tls_config( self, config: Option<Arc<ClientConfig>>, ) -> Self

Set an insecure shared TLS client config used when a hop has insecure = true (?insecure in the URI).

pub fn shared_tls_config(&self) -> Option<&Arc<ClientConfig>>

Get the shared TLS client config, if set.

pub fn insecure_shared_tls_config(&self) -> Option<&Arc<ClientConfig>>

Get the insecure shared TLS config (if any).

pub async fn execute( &self, chain: &[ProxyHopSpec], target: &TargetAddr, ) -> Result<BoxStream, ChainError>

Execute a proxy chain to connect to the target.

Arguments

• chain - The ordered list of proxy hops
• target - The final destination to connect to

Returns

A connected stream ready for data transfer, or a ChainError.