pub struct BaseSocketProxy { /* private fields */ }
Implementations§
source§impl BaseSocketProxy
impl BaseSocketProxy
sourcepub fn take_event_stream(&self) -> BaseSocketEventStream
pub fn take_event_stream(&self) -> BaseSocketEventStream
Get a Stream of events from the remote end of the BaseSocket protocol
Panics
Panics if the event stream was already taken.
pub fn clone2(&self, request: ServerEnd<CloneableMarker>) -> Result<(), Error>
sourcepub fn close(&self) -> QueryResponseFut<CloseableCloseResult>
pub fn close(&self) -> QueryResponseFut<CloseableCloseResult>
Terminates the connection.
After calling Close
, the client must not send any other requests.
Servers, after sending the status response, should close the connection regardless of status and without sending an epitaph.
Closing the client end of the channel should be semantically equivalent
to calling Close
without knowing when the close has completed or its
status.
pub fn query(&self) -> QueryResponseFut<Vec<u8>>
sourcepub fn set_reuse_address(
&self,
value: bool
) -> QueryResponseFut<BaseSocketSetReuseAddressResult>
pub fn set_reuse_address( &self, value: bool ) -> QueryResponseFut<BaseSocketSetReuseAddressResult>
Set SOL_SOCKET
-> SO_REUSEADDR
.
sourcepub fn get_reuse_address(
&self
) -> QueryResponseFut<BaseSocketGetReuseAddressResult>
pub fn get_reuse_address( &self ) -> QueryResponseFut<BaseSocketGetReuseAddressResult>
Get SOL_SOCKET
-> SO_REUSEADDR
.
sourcepub fn get_error(&self) -> QueryResponseFut<BaseSocketGetErrorResult>
pub fn get_error(&self) -> QueryResponseFut<BaseSocketGetErrorResult>
Get SOL_SOCKET
-> SO_ERROR
.
Returns the last error if there is an error set on the socket.
sourcepub fn set_broadcast(
&self,
value: bool
) -> QueryResponseFut<BaseSocketSetBroadcastResult>
pub fn set_broadcast( &self, value: bool ) -> QueryResponseFut<BaseSocketSetBroadcastResult>
Set SOL_SOCKET
-> SO_BROADCAST
.
sourcepub fn get_broadcast(&self) -> QueryResponseFut<BaseSocketGetBroadcastResult>
pub fn get_broadcast(&self) -> QueryResponseFut<BaseSocketGetBroadcastResult>
Get SOL_SOCKET
-> SO_BROADCAST
.
sourcepub fn set_send_buffer(
&self,
value_bytes: u64
) -> QueryResponseFut<BaseSocketSetSendBufferResult>
pub fn set_send_buffer( &self, value_bytes: u64 ) -> QueryResponseFut<BaseSocketSetSendBufferResult>
Set SOL_SOCKET
-> SO_SNDBUF
.
sourcepub fn get_send_buffer(&self) -> QueryResponseFut<BaseSocketGetSendBufferResult>
pub fn get_send_buffer(&self) -> QueryResponseFut<BaseSocketGetSendBufferResult>
Get SOL_SOCKET
-> SO_SNDBUF
.
sourcepub fn set_receive_buffer(
&self,
value_bytes: u64
) -> QueryResponseFut<BaseSocketSetReceiveBufferResult>
pub fn set_receive_buffer( &self, value_bytes: u64 ) -> QueryResponseFut<BaseSocketSetReceiveBufferResult>
Set SOL_SOCKET
-> SO_RCVBUF
.
sourcepub fn get_receive_buffer(
&self
) -> QueryResponseFut<BaseSocketGetReceiveBufferResult>
pub fn get_receive_buffer( &self ) -> QueryResponseFut<BaseSocketGetReceiveBufferResult>
Get SOL_SOCKET
-> SO_RCVBUF
.
sourcepub fn set_keep_alive(
&self,
value: bool
) -> QueryResponseFut<BaseSocketSetKeepAliveResult>
pub fn set_keep_alive( &self, value: bool ) -> QueryResponseFut<BaseSocketSetKeepAliveResult>
Set SOL_SOCKET
-> SO_KEEPALIVE
.
sourcepub fn get_keep_alive(&self) -> QueryResponseFut<BaseSocketGetKeepAliveResult>
pub fn get_keep_alive(&self) -> QueryResponseFut<BaseSocketGetKeepAliveResult>
Get SOL_SOCKET
-> SO_KEEPALIVE
.
sourcepub fn set_out_of_band_inline(
&self,
value: bool
) -> QueryResponseFut<BaseSocketSetOutOfBandInlineResult>
pub fn set_out_of_band_inline( &self, value: bool ) -> QueryResponseFut<BaseSocketSetOutOfBandInlineResult>
Set SOL_SOCKET
-> SO_OOBINLINE
.
sourcepub fn get_out_of_band_inline(
&self
) -> QueryResponseFut<BaseSocketGetOutOfBandInlineResult>
pub fn get_out_of_band_inline( &self ) -> QueryResponseFut<BaseSocketGetOutOfBandInlineResult>
Get SOL_SOCKET
-> SO_OOBINLINE
.
sourcepub fn set_no_check(
&self,
value: bool
) -> QueryResponseFut<BaseSocketSetNoCheckResult>
pub fn set_no_check( &self, value: bool ) -> QueryResponseFut<BaseSocketSetNoCheckResult>
Set SOL_SOCKET
-> SO_NO_CHECK
.
sourcepub fn get_no_check(&self) -> QueryResponseFut<BaseSocketGetNoCheckResult>
pub fn get_no_check(&self) -> QueryResponseFut<BaseSocketGetNoCheckResult>
Get SOL_SOCKET
-> SO_NO_CHECK
.
sourcepub fn set_linger(
&self,
linger: bool,
length_secs: u32
) -> QueryResponseFut<BaseSocketSetLingerResult>
pub fn set_linger( &self, linger: bool, length_secs: u32 ) -> QueryResponseFut<BaseSocketSetLingerResult>
Set SOL_SOCKET
-> SO_LINGER
.
sourcepub fn get_linger(&self) -> QueryResponseFut<BaseSocketGetLingerResult>
pub fn get_linger(&self) -> QueryResponseFut<BaseSocketGetLingerResult>
Get SOL_SOCKET
-> SO_LINGER
.
sourcepub fn set_reuse_port(
&self,
value: bool
) -> QueryResponseFut<BaseSocketSetReusePortResult>
pub fn set_reuse_port( &self, value: bool ) -> QueryResponseFut<BaseSocketSetReusePortResult>
Set SOL_SOCKET
-> SO_REUSEPORT
.
sourcepub fn get_reuse_port(&self) -> QueryResponseFut<BaseSocketGetReusePortResult>
pub fn get_reuse_port(&self) -> QueryResponseFut<BaseSocketGetReusePortResult>
Get SOL_SOCKET
-> SO_REUSEPORT
.
sourcepub fn get_accept_conn(&self) -> QueryResponseFut<BaseSocketGetAcceptConnResult>
pub fn get_accept_conn(&self) -> QueryResponseFut<BaseSocketGetAcceptConnResult>
Get SOL_SOCKET
-> SO_ACCEPTCONN
.
sourcepub fn set_bind_to_device(
&self,
value: &str
) -> QueryResponseFut<BaseSocketSetBindToDeviceResult>
pub fn set_bind_to_device( &self, value: &str ) -> QueryResponseFut<BaseSocketSetBindToDeviceResult>
Set SOL_SOCKET
-> SO_BINDTODEVICE
.
sourcepub fn get_bind_to_device(
&self
) -> QueryResponseFut<BaseSocketGetBindToDeviceResult>
pub fn get_bind_to_device( &self ) -> QueryResponseFut<BaseSocketGetBindToDeviceResult>
Get SOL_SOCKET
-> SO_BINDTODEVICE
.
sourcepub fn set_timestamp(
&self,
value: TimestampOption
) -> QueryResponseFut<BaseSocketSetTimestampResult>
pub fn set_timestamp( &self, value: TimestampOption ) -> QueryResponseFut<BaseSocketSetTimestampResult>
Set SOL_SOCKET
-> SO_TIMESTAMP
or SO_TIMESTAMPNS
.
sourcepub fn get_timestamp(&self) -> QueryResponseFut<BaseSocketGetTimestampResult>
pub fn get_timestamp(&self) -> QueryResponseFut<BaseSocketGetTimestampResult>
Get SOL_SOCKET
-> SO_TIMESTAMP
or SO_TIMESTAMPNS
.
Trait Implementations§
source§impl BaseSocketProxyInterface for BaseSocketProxy
impl BaseSocketProxyInterface for BaseSocketProxy
fn clone2(&self, request: ServerEnd<CloneableMarker>) -> Result<(), Error>
type CloseResponseFut = QueryResponseFut<Result<(), i32>>
fn close(&self) -> Self::CloseResponseFut
type QueryResponseFut = QueryResponseFut<Vec<u8, Global>>
fn query(&self) -> Self::QueryResponseFut
type SetReuseAddressResponseFut = QueryResponseFut<Result<(), Errno>>
fn set_reuse_address(&self, value: bool) -> Self::SetReuseAddressResponseFut
type GetReuseAddressResponseFut = QueryResponseFut<Result<bool, Errno>>
fn get_reuse_address(&self) -> Self::GetReuseAddressResponseFut
type GetErrorResponseFut = QueryResponseFut<Result<(), Errno>>
fn get_error(&self) -> Self::GetErrorResponseFut
type SetBroadcastResponseFut = QueryResponseFut<Result<(), Errno>>
fn set_broadcast(&self, value: bool) -> Self::SetBroadcastResponseFut
type GetBroadcastResponseFut = QueryResponseFut<Result<bool, Errno>>
fn get_broadcast(&self) -> Self::GetBroadcastResponseFut
type SetSendBufferResponseFut = QueryResponseFut<Result<(), Errno>>
fn set_send_buffer(&self, value_bytes: u64) -> Self::SetSendBufferResponseFut
type GetSendBufferResponseFut = QueryResponseFut<Result<u64, Errno>>
fn get_send_buffer(&self) -> Self::GetSendBufferResponseFut
type SetReceiveBufferResponseFut = QueryResponseFut<Result<(), Errno>>
fn set_receive_buffer( &self, value_bytes: u64 ) -> Self::SetReceiveBufferResponseFut
type GetReceiveBufferResponseFut = QueryResponseFut<Result<u64, Errno>>
fn get_receive_buffer(&self) -> Self::GetReceiveBufferResponseFut
type SetKeepAliveResponseFut = QueryResponseFut<Result<(), Errno>>
fn set_keep_alive(&self, value: bool) -> Self::SetKeepAliveResponseFut
type GetKeepAliveResponseFut = QueryResponseFut<Result<bool, Errno>>
fn get_keep_alive(&self) -> Self::GetKeepAliveResponseFut
type SetOutOfBandInlineResponseFut = QueryResponseFut<Result<(), Errno>>
fn set_out_of_band_inline( &self, value: bool ) -> Self::SetOutOfBandInlineResponseFut
type GetOutOfBandInlineResponseFut = QueryResponseFut<Result<bool, Errno>>
fn get_out_of_band_inline(&self) -> Self::GetOutOfBandInlineResponseFut
type SetNoCheckResponseFut = QueryResponseFut<Result<(), Errno>>
fn set_no_check(&self, value: bool) -> Self::SetNoCheckResponseFut
type GetNoCheckResponseFut = QueryResponseFut<Result<bool, Errno>>
fn get_no_check(&self) -> Self::GetNoCheckResponseFut
type SetLingerResponseFut = QueryResponseFut<Result<(), Errno>>
fn set_linger(&self, linger: bool, length_secs: u32) -> Self::SetLingerResponseFut
type GetLingerResponseFut = QueryResponseFut<Result<(bool, u32), Errno>>
fn get_linger(&self) -> Self::GetLingerResponseFut
type SetReusePortResponseFut = QueryResponseFut<Result<(), Errno>>
fn set_reuse_port(&self, value: bool) -> Self::SetReusePortResponseFut
type GetReusePortResponseFut = QueryResponseFut<Result<bool, Errno>>
fn get_reuse_port(&self) -> Self::GetReusePortResponseFut
type GetAcceptConnResponseFut = QueryResponseFut<Result<bool, Errno>>
fn get_accept_conn(&self) -> Self::GetAcceptConnResponseFut
type SetBindToDeviceResponseFut = QueryResponseFut<Result<(), Errno>>
fn set_bind_to_device(&self, value: &str) -> Self::SetBindToDeviceResponseFut
type GetBindToDeviceResponseFut = QueryResponseFut<Result<String, Errno>>
fn get_bind_to_device(&self) -> Self::GetBindToDeviceResponseFut
type SetTimestampResponseFut = QueryResponseFut<Result<(), Errno>>
fn set_timestamp(&self, value: TimestampOption) -> Self::SetTimestampResponseFut
type GetTimestampResponseFut = QueryResponseFut<Result<TimestampOption, Errno>>
fn get_timestamp(&self) -> Self::GetTimestampResponseFut
source§impl Clone for BaseSocketProxy
impl Clone for BaseSocketProxy
source§fn clone(&self) -> BaseSocketProxy
fn clone(&self) -> BaseSocketProxy
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moresource§impl Debug for BaseSocketProxy
impl Debug for BaseSocketProxy
source§impl Proxy for BaseSocketProxy
impl Proxy for BaseSocketProxy
§type Protocol = BaseSocketMarker
type Protocol = BaseSocketMarker
Proxy
controls.