Struct sshx_server::state::mesh::StorageMesh

pub struct StorageMesh { /* private fields */ }

Communication with a distributed mesh of sshx server nodes.

This uses a Redis instance to persist data across restarts, as well as a pub/sub channel to keep be notified of when another node becomes the owner of an active session.

All servers must be accessible to each other through TCP mesh networking, since requests are forwarded to the controller of a given session.

Implementations

impl StorageMesh

pub fn new(redis_url: &str, host: Option<&str>) -> Result<Self>

Construct a new storage object from Redis URL.

pub fn host(&self) -> Option<&str>

Returns the hostname of this server, if running in mesh node.

pub async fn get_owner(&self, name: &str) -> Result<Option<String>>

Retrieve the hostname of the owner of a session.

pub async fn get_owner_snapshot( &self, name: &str, ) -> Result<(Option<String>, Option<Vec<u8>>)>

Retrieve the owner and snapshot of a session.

pub async fn background_sync(&self, name: &str, session: Arc<Session>)

Periodically set the owner and snapshot of a session.

pub async fn mark_closed(&self, name: &str) -> Result<()>

Mark a session as closed, so it will expire and never be accessed again.

pub async fn notify_transfer(&self, name: &str, host: &str) -> Result<()>

Notify a host that a session has been transferred.

pub fn listen_for_transfers(&self) -> impl Stream<Item = String> + Send + '_

Listen for sessions that are transferred away from this host.

Trait Implementations

impl Clone for StorageMesh

fn clone(&self) -> StorageMesh

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.