gel_stream

Struct Connector

Source 
pub struct Connector<D: TlsDriver = Ssl> { /* private fields */ }
Expand description

A connector can be used to connect multiple times to the same target.

Implementations§

Source§

impl Connector<Ssl>

Source

pub fn new(target: Target) -> Result<Self, Error>

Source§

impl<D: TlsDriver> Connector<D>

Source

pub fn new_explicit(target: Target) -> Result<Self, Error>

Source

pub fn set_keepalive(&mut self, keepalive: Option<Duration>)

Set a keepalive for the connection. This is only supported for TCP connections and will be ignored for unix sockets.

Source

pub fn ignore_missing_tls_close_notify(&mut self)

For TLS connections, ignore a hard close where the socket was closed before receiving CLOSE_NOTIFY.

This may result in vulnerability to truncation attacks for protocols that do not include an implicit length, but may also result in spurious failures on Windows where sockets may be closed before the CLOSE_NOTIFY is received.

Source

pub async fn connect( &self, ) -> Result<UpgradableStream<TokioStream, D>, ConnectionError>

Auto Trait Implementations§

§

impl<D> Freeze for Connector<D>

§

impl<D = RustlsDriver> !RefUnwindSafe for Connector<D>

§

impl<D> Send for Connector<D>

§

impl<D> Sync for Connector<D>

§

impl<D> Unpin for Connector<D>

§

impl<D = RustlsDriver> !UnwindSafe for Connector<D>

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> Instrument for T

Source§

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

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
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> Pointable for T

Source§

const ALIGN: usize

The alignment of pointer.
Source§

type Init = T

The type for initializers.
Source§

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

Initializes a with the given initializer. Read more
Source§

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

Dereferences the given pointer. Read more
Source§

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

Mutably dereferences the given pointer. Read more
Source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
Source§

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

Source§

type Error = Infallible

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

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

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.
Source§

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

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

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

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

impl<T> ErasedDestructor for T
where T: 'static,