Struct ServerStateInner 

pub struct ServerStateInner {
    pub config: Config,
    pub pool: PgPool,
    pub services: Weak<Services>,
    pub sushi: Sender<MessageSync>,
    pub sushi_sfu: Sender<SfuCommand>,
    pub blobs: Operator,
    pub sfus: DashMap<SfuId, ()>,
    pub thread_to_sfu: DashMap<ChannelId, SfuId>,
}

Fields

config: Config

pool: PgPool

services: Weak<Services>

sushi: Sender<MessageSync>

sushi_sfu: Sender<SfuCommand>

blobs: Operator

sfus: DashMap<SfuId, ()>

thread_to_sfu: DashMap<ChannelId, SfuId>

Implementations

impl ServerStateInner

pub fn data(&self) -> Box<dyn Data>

pub fn services(&self) -> Arc<Services>

pub async fn broadcast_room( &self, _room_id: RoomId, _user_id: UserId, msg: MessageSync, ) -> Result<()>

pub async fn broadcast_channel( &self, _thread_id: ChannelId, _user_id: UserId, msg: MessageSync, ) -> Result<()>

pub fn broadcast(&self, msg: MessageSync) -> Result<()>

pub fn get_s3_url(&self, path: &str) -> Result<Url>

pub async fn presign(&self, _media: &mut Media) -> Result<()>

presigns every relevant url in a piece of media

pub async fn audit_log_append(&self, entry: AuditLogEntry) -> Result<()>

pub async fn presign_message(&self, message: &mut Message) -> Result<()>

presigns every relevant url in a Message

pub async fn alloc_sfu(&self, thread_id: ChannelId) -> Result<SfuId>

select the “best” sfu and pair it with this thread id. return the existing sfu id if it exists.

currently “best” means the sfu with least load in terms of # of threads using it