[−][src]Struct tmq::SocketBuilder
Builder which provides bind
and connect
methods to build a corresponding ZMQ socket as per the standard functions
You can use the standard functions from the crate to create a builder
Use the set_
functions to set socket options before binding/connecting
See ZMQ documentation for more info on what these options do: http://api.zeromq.org/4-2:zmq-setsockopt
Implementations
impl<T> SocketBuilder<T> where
T: FromZmqSocket<T>,
[src]
T: FromZmqSocket<T>,
pub fn connect(self, endpoint: &str) -> Result<T>
[src]
Connect to a ZMQ endpoint at the given address.
pub fn bind(self, endpoint: &str) -> Result<T>
[src]
Bind to a ZMQ endpoint at the given address.
pub fn monitor(self, monitor_endpoint: &str, events: i32) -> Self
[src]
Configure the socket for monitoring
pub fn set_ipv6(self, value: bool) -> Self
[src]
Setter for the ZMQ_IPV6
option.
pub fn set_immediate(self, value: bool) -> Self
[src]
Setter for the ZMQ_IMMEDIATE
option.
pub fn set_plain_server(self, value: bool) -> Self
[src]
Setter for the ZMQ_PLAIN_SERVER
option.
pub fn set_conflate(self, value: bool) -> Self
[src]
Setter for the ZMQ_CONFLATE
option.
pub fn set_probe_router(self, value: bool) -> Self
[src]
Setter for the ZMQ_PROBE_ROUTER
option.
pub fn set_curve_server(self, value: bool) -> Self
[src]
Setter for the ZMQ_CURVE_SERVER
option.
pub fn set_gssapi_server(self, value: bool) -> Self
[src]
Setter for the ZMQ_GSSAPI_SERVER
option.
pub fn set_gssapi_plaintext(self, value: bool) -> Self
[src]
Setter for the ZMQ_GSSAPI_PLAINTEXT
option.
pub fn set_maxmsgsize(self, value: i64) -> Self
[src]
Setter for the ZMQ_MAXMSGSIZE
option.
pub fn set_sndhwm(self, value: i32) -> Self
[src]
Setter for the ZMQ_SNDHWM
option.
pub fn set_rcvhwm(self, value: i32) -> Self
[src]
Setter for the ZMQ_RCVHWM
option.
pub fn set_affinity(self, value: u64) -> Self
[src]
Setter for the ZMQ_AFFINITY
option.
pub fn set_rate(self, value: i32) -> Self
[src]
Setter for the ZMQ_RATE
option.
pub fn set_recovery_ivl(self, value: i32) -> Self
[src]
Setter for the ZMQ_RECOVERY_IVL
option.
pub fn set_sndbuf(self, value: i32) -> Self
[src]
Setter for the ZMQ_SNDBUF
option.
pub fn set_rcvbuf(self, value: i32) -> Self
[src]
Setter for the ZMQ_RCVBUF
option.
pub fn set_tos(self, value: i32) -> Self
[src]
Setter for the ZMQ_TOS
option.
pub fn set_linger(self, value: i32) -> Self
[src]
Setter for the ZMQ_LINGER
option.
pub fn set_reconnect_ivl(self, value: i32) -> Self
[src]
Setter for the ZMQ_RECONNECT_IVL
option.
pub fn set_reconnect_ivl_max(self, value: i32) -> Self
[src]
Setter for the ZMQ_RECONNECT_IVL_MAX
option.
pub fn set_backlog(self, value: i32) -> Self
[src]
Setter for the ZMQ_BACKLOG
option.
pub fn set_identity(self, value: &[u8]) -> Self
[src]
Setter for the ZMQ_IDENTITY
option.
Auto Trait Implementations
impl<T> !RefUnwindSafe for SocketBuilder<T>
impl<T> Send for SocketBuilder<T> where
T: Send,
T: Send,
impl<T> !Sync for SocketBuilder<T>
impl<T> Unpin for SocketBuilder<T> where
T: Unpin,
T: Unpin,
impl<T> !UnwindSafe for SocketBuilder<T>
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,