Struct ConnectionRepositoryAdapter 

pub struct ConnectionRepositoryAdapter { /* private fields */ }

Implementations

impl ConnectionRepositoryAdapter

pub fn new(manager: Arc<ConnectionManager>) -> Self

pub fn manager(&self) -> Arc<ConnectionManager>

pub async fn upsert_pending( &self, connection_id: String, node_id: Option<String>, device_id: Option<String>, endpoint_id: Option<String>, ) -> ConnectionRecord

pub async fn mark_connected( &self, connection_id: &str, endpoint_id: Option<String>, ) -> Option<ConnectionRecord>

pub async fn mark_disconnected( &self, connection_id: &str, reason: Option<String>, )

pub async fn get_by_connection_id( &self, connection_id: &str, ) -> Option<ConnectionRecord>

pub async fn get_by_node_id(&self, node_id: &str) -> Vec<ConnectionRecord>

Trait Implementations

impl Clone for ConnectionRepositoryAdapter

fn clone(&self) -> ConnectionRepositoryAdapter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for ConnectionRepositoryAdapter

fn default() -> ConnectionRepositoryAdapter

Returns the “default value” for a type.