Skip to main content

Po

Struct Po 

Source
pub struct Po { /* private fields */ }
Expand description

A PO node — the main entry point for the protocol.

Wraps all the complexity of QUIC, crypto handshake, and encryption behind a dead-simple API.

Implementations§

Source§

impl Po

Source

pub async fn connect(addr: &str) -> Result<Self, PoError>

Connect to a remote PO node.

This will:

  1. Establish a QUIC connection
  2. Perform the E2EE handshake (Ed25519 + X25519 + ChaCha20)
  3. Return a ready-to-use encrypted connection
let mut po = Po::connect("192.168.1.5:4433").await?;
po.send(b"encrypted hello!").await?;
Source

pub async fn bind(port: u16) -> Result<Self, PoError>

Listen for an incoming connection on the given port.

This will:

  1. Start a QUIC listener
  2. Accept the first incoming connection
  3. Perform the E2EE handshake
  4. Return a ready-to-use encrypted connection
let mut po = Po::bind(4433).await?;
let data = po.recv().await?;
Source

pub async fn send(&mut self, data: &[u8]) -> Result<(), PoError>

Send encrypted data to the connected peer.

Source

pub async fn recv(&mut self) -> Result<Option<(u32, Vec<u8>)>, PoError>

Receive the next message from the connected peer.

Returns Some((channel_id, data)) or None if the connection closed.

Source

pub fn node_id(&self) -> String

Get our node ID.

Source

pub fn public_key(&self) -> [u8; 32]

Get our Ed25519 public key bytes (32 bytes).

Source

pub fn peer_node_id(&self) -> Option<String>

Get the peer’s node ID (if connected).

Source

pub fn peer_info(&self) -> Option<&PeerInfo>

Get information about the connected peer.

Source

pub async fn close(&mut self) -> Result<(), PoError>

Gracefully close the connection.

Auto Trait Implementations§

§

impl Freeze for Po

§

impl RefUnwindSafe for Po

§

impl Send for Po

§

impl Sync for Po

§

impl Unpin for Po

§

impl UnsafeUnpin for Po

§

impl UnwindSafe for Po

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

Source§

type Output = T

Should always be Self
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