Struct ClientDataTunnel 

pub struct ClientDataTunnel { /* private fields */ }

A client single path data tunnel.

Implementations

impl ClientDataTunnel

pub fn is_closed(&self) -> bool

Return true if this tunnel is closed and therefore unusable.

pub fn last_hop(&self) -> Result<TargetHop>

Return a TargetHop representing precisely the last hop of the circuit as in set as a HopLocation with its id and hop number.

Return an error if there is no last hop.

pub fn terminate(&self)

Shutdown the tunnel meaning this sends a shutdown command to the underlying circuit reactor which will stop asynchronously.

Note that it is not necessary to use this method as in if the tunnel reference is dropped, the circuit will close automatically.

pub fn unique_id(&self) -> UniqId

Return a process-unique identifier for this tunnel.

pub async fn send_raw_msg(&self, msg: AnyRelayMsg, hop: TargetHop) -> Result<()>

Available on crate feature send-control-msg only.

Send raw message.

pub async fn start_conversation( &self, msg: Option<AnyRelayMsg>, reply_handler: impl MsgHandler + Send + 'static, hop: TargetHop, ) -> Result<Conversation<'_>>

Available on crate feature send-control-msg only.

Start an ad-hoc protocol exchange to the specified hop on this tunnel.

See ClientTunnel::start_conversation documentation for more details.

pub fn wait_for_close( &self, ) -> impl Future<Output = ()> + Send + Sync + 'static + use<>

Return a future that will resolve once this circuit has closed.

Note that this method does not itself cause the circuit to shut down.

impl ClientDataTunnel

pub async fn begin_stream( &self, target: &str, port: u16, params: Option<StreamParameters>, ) -> Result<DataStream>

Start a stream to the given address and port, using a BEGIN cell.

The use of a string for the address is intentional: you should let the remote Tor relay do the hostname lookup for you.

impl ClientDataTunnel

pub async fn resolve(&self, hostname: &str) -> Result<Vec<IpAddr>>

Perform a DNS lookup, using a RESOLVE cell with the last relay in this circuit.

Note that this function does not check for timeouts; that’s the caller’s responsibility.

pub async fn resolve_ptr(&self, addr: IpAddr) -> Result<Vec<String>>

Perform a reverse DNS lookup, using a RESOLVE cell with the last relay in this circuit.

Note that this function does not check for timeouts; that’s the caller’s responsibility.

impl ClientDataTunnel

pub async fn extend<T: CircTarget>( &self, target: &T, params: CircParameters, ) -> Result<()>

Extend the circuit to a new target last hop using the ntor v3 handshake.

TODO: Might want to pass which handshake type as a parameter so this function can be a catch all on all possible handshakes. For now, use ntor v3 for all the things.

pub fn n_hops(&self) -> Result<usize>

Return the number of hops of the underlying circuit.

Trait Implementations

impl AsRef<ClientTunnel> for ClientDataTunnel

fn as_ref(&self) -> &ClientTunnel

Converts this type into a shared reference of the (usually inferred) input type.

impl Debug for ClientDataTunnel

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

Formats the value using the given formatter.

impl From<Arc<ClientTunnel>> for ClientDataTunnel

fn from(tunnel: Arc<ClientTunnel>) -> Self

Converts to this type from the input type.

impl From<ClientTunnel> for ClientDataTunnel

fn from(tunnel: ClientTunnel) -> Self

Converts to this type from the input type.