Struct ConnectionStream 

pub struct ConnectionStream {
    pub addy: Option<String>,
    pub protocol: Proto,
    pub tcp_stream: Option<Box<TcpStream>>,
    pub unix_stream: Option<Box<UnixStream>>,
}

Represents an open connection to the keystore.

Fields

addy: Option<String>

protocol: Proto

tcp_stream: Option<Box<TcpStream>>

unix_stream: Option<Box<UnixStream>>

Implementations

impl ConnectionStream

pub async fn new_tcp_connection(addy: String) -> Result<Self, ErrorArrayItem>

Create a new TCP connection to the keystore server.

pub async fn new_unix_connection() -> Result<Self, ErrorArrayItem>

Create a new Unix domain socket connection to the keystore server.

pub async fn ensure_connection(&mut self) -> Result<Self, ErrorArrayItem>

Ensure the internal connection is alive, reconnecting if necessary.

pub fn get_stream_mut(&mut self) -> StreamMut<'_>

Obtain a mutable reference to the underlying stream regardless of the protocol.

pub fn get_protocol(&self) -> Proto

Return the protocol associated with this connection.