Struct AsyncSecretConnection 

pub struct AsyncSecretConnection<Io> { /* private fields */ }

Available on crate feature async only.

Encrypted connection between peers in a CometBFT network, implemented using asynchronous I/O provided by the Tokio async runtime.

Implementations

impl<Io: AsyncReadExt + AsyncWriteExt + Send + Sync + Unpin> AsyncSecretConnection<Io>

pub async fn new<Identity>(io: Io, identity_key: &Identity) -> Result<Self>

where Identity: Signer<Signature>, VerifyingKey: for<'a> From<&'a Identity>,

Performs a handshake and returns a new AsyncSecretConnection, authenticating ourselves with the provided Identity (Ed25519 signing key).

The IdentitySecret type can be used as an identity_key.

Errors

• if sharing of the pubkey fails
• if sharing of the signature fails
• if receiving the signature fails
• if verifying the signature fails

impl<Io> AsyncSecretConnection<Io>

pub fn local_public_key(&self) -> &PublicKey

Get the local (i.e. our) PublicKey.

pub fn peer_public_key(&self) -> &PublicKey

Returns the remote peer’s PublicKey.

pub fn split(self) -> (AsyncSecretReader<Io>, AsyncSecretWriter<Io>)

Split this AsyncSecretConnection into an AsyncSecretReader and AsyncSecretWriter which can be used independently of each other.

Trait Implementations

impl<Io: AsyncReadExt + Send + Sync + Unpin> AsyncReadMsg for AsyncSecretConnection<Io>

fn read_msg<M: Message + Default>( &mut self, ) -> impl Future<Output = Result<M>> + Send + Sync

Read from the underlying I/O object, decrypting the data and decoding it into the given Protobuf message.

impl<Io: AsyncWriteExt + Send + Sync + Unpin> AsyncWriteMsg for AsyncSecretConnection<Io>

fn write_msg<M: Message>( &mut self, msg: M, ) -> impl Future<Output = Result<()>> + Send + Sync

Encode the given Protobuf as bytes, encrypted it, and write the ciphertext to the underlying I/O object.