Skip to main content

TcpProxy

Struct TcpProxy 

Source
pub struct TcpProxy { /* private fields */ }
Expand description

Layer-4 (raw TCP) reverse proxy with round-robin load balancing.

Call TcpProxy::bind to start accepting connections. Each connection is handled in its own thread pair (one thread per direction), so bind blocks the calling thread indefinitely.

Implementations§

Source§

impl TcpProxy

Source

pub fn new<I, S>(backends: I) -> Self
where I: IntoIterator<Item = S>, S: Into<String>,

Create a proxy that distributes connections across backends in round-robin order. Each entry must be "host:port".

Source

pub fn connect_timeout_ms(self, ms: u64) -> Self

Override the TCP connect timeout to each backend (default: 5 s).

Source

pub fn bind(self, addr: &str) -> Result<(), String>

Bind on addr and start proxying. Blocks until the listener is closed.

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = !

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, !>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.