Struct ConnectorOptions

Source

pub struct ConnectorOptions {
    pub ca_file: Option<String>,
    pub cert_key_file: Option<(String, String)>,
    pub debug_ssl_keylog: bool,
    pub keepalive_pool_size: usize,
    pub offload_threadpool: Option<(usize, usize)>,
    pub bind_to_v4: Vec<SocketAddr>,
    pub bind_to_v6: Vec<SocketAddr>,
}

Expand description

The options to configure a TransportConnector

Fields§

§ca_file: Option<String>

Path to the CA file used to validate server certs.

If None, the CA in the default locations will be loaded

§cert_key_file: Option<(String, String)>

The default client cert and key to use for mTLS

Each individual connection can use their own cert key to override this.

§debug_ssl_keylog: bool

When enabled allows TLS keys to be written to a file specified by the SSLKEYLOG env variable. This can be used by tools like Wireshark to decrypt traffic for debugging purposes.

§keepalive_pool_size: usize

How many connections to keepalive

§offload_threadpool: Option<(usize, usize)>

Optionally offload the connection establishment to dedicated thread pools

TCP and TLS connection establishment can be CPU intensive. Sometimes such tasks can slow down the entire service, which causes timeouts which leads to more connections which snowballs the issue. Use this option to isolate these CPU intensive tasks from impacting other traffic.

Syntax: (#pools, #thread in each pool)

§bind_to_v4: Vec<SocketAddr>

Bind to any of the given source IPv6 addresses

§bind_to_v6: Vec<SocketAddr>

Bind to any of the given source IPv4 addresses

Struct ConnectorOptions Copy item path

Fields§

Implementations§

impl ConnectorOptions

pub fn from_server_conf(server_conf: &ServerConf) -> ConnectorOptions

pub fn new(keepalive_pool_size: usize) -> ConnectorOptions

Trait Implementations§

impl Clone for ConnectorOptions

fn clone(&self) -> ConnectorOptions

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

Auto Trait Implementations§

impl Freeze for ConnectorOptions

impl RefUnwindSafe for ConnectorOptions

impl Send for ConnectorOptions

impl Sync for ConnectorOptions

impl Unpin for ConnectorOptions

impl UnwindSafe for ConnectorOptions

Blanket Implementations§

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

fn type_id(&self) -> TypeId

impl<T> ArchivePointee for T

type ArchivedMetadata = ()

fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata

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

fn borrow(&self) -> &T

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

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

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

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

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>where F: FnOnce(&Self) -> bool,

impl<T> LayoutRaw for T

fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>

impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2where T: SharedNiching<N1, N2>, N1: Niching<T>, N2: Niching<T>,

unsafe fn is_niched(niched: *const NichedOption<T, N1>) -> bool

fn resolve_niched(out: Place<NichedOption<T, N1>>)

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T> Pointee for T

type Metadata = ()

impl<T> Same for T

type Output = T

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

fn clone_into(&self, target: &mut T)

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

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

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

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

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

impl<T> Upcastable for Twhere T: Any + Send + Sync + 'static,

fn upcast_any_ref(&self) -> &(dyn Any + 'static)

fn upcast_any_mut(&mut self) -> &mut (dyn Any + 'static)

fn upcast_any_box(self: Box<T>) -> Box<dyn Any>

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct ConnectorOptions

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

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

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

impl<T> CloneToUninit for T
where T: Clone,

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

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2
where T: SharedNiching<N1, N2>, N1: Niching<T>, N2: Niching<T>,

impl<T> ToOwned for T
where T: Clone,

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

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

impl<T> Upcastable for T
where T: Any + Send + Sync + 'static,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,