Struct TurnServer 

pub struct TurnServer { /* private fields */ }

A TURN server.

Implementations

impl TurnServer

pub fn new(ttype: TransportType, listen_addr: SocketAddr, realm: String) -> Self

Construct a new TurnServer

Examples

let realm = String::from("realm");
let listen_addr = "10.0.0.1:3478".parse().unwrap();
let server = TurnServer::new(TransportType::Udp, listen_addr, realm);
assert_eq!(server.listen_address(), listen_addr);

pub fn transport(&self) -> TransportType

The TransportType of this TURN server.

Trait Implementations

impl Debug for TurnServer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl TurnServerApi for TurnServer

fn add_user(&mut self, username: String, password: String)

Add a user credentials that would be accepted by this TurnServerApi.

fn listen_address(&self) -> SocketAddr

The address that the TurnServerApi is listening on for incoming client connections.

fn set_nonce_expiry_duration(&mut self, expiry_duration: Duration)

Set the amount of time that a Nonce (used for authentication) will expire and a new Nonce will need to be acquired by a client.

fn recv_icmp<T: AsRef<[u8]>>( &mut self, family: AddressFamily, bytes: T, now: Instant, ) -> Option<Transmit<Vec<u8>>>

Provide a received ICMP packet to the TurnServerApi.

fn recv<T: AsRef<[u8]> + Debug>( &mut self, transmit: Transmit<T>, now: Instant, ) -> Option<TransmitBuild<DelayedMessageOrChannelSend<T>>>

Provide received data to the TurnServerApi.

fn poll(&mut self, now: Instant) -> TurnServerPollRet

Poll the TurnServerApi in order to make further progress.

fn poll_transmit(&mut self, now: Instant) -> Option<Transmit<Vec<u8>>>

Poll for a new Transmit to send over a socket.

fn allocated_socket( &mut self, transport: TransportType, local_addr: SocketAddr, remote_addr: SocketAddr, allocation_transport: TransportType, family: AddressFamily, socket_addr: Result<SocketAddr, SocketAllocateError>, now: Instant, )

Notify the TurnServerApi that a UDP socket has been allocated (or an error) in response to TurnServerPollRet::AllocateSocket.

fn tcp_connected( &mut self, relayed_addr: SocketAddr, peer_addr: SocketAddr, listen_addr: SocketAddr, client_addr: SocketAddr, socket_addr: Result<SocketAddr, TcpConnectError>, now: Instant, )

Indicate that a TCP connection has been configured (or an error) for a client to connect over TCP with a peer.