Struct Server 

pub struct Server<C: Config> { /* private fields */ }

Implementations

impl<C: Config> Server<C>

pub async fn new<Tz>( config: C, db: PgPool, cache_watermark: usize, vacuum_schedule: ServerVacuumSchedule<Tz>, ) -> Result<(Self, JoinHandle<usize>)>

where Tz: 'static + Send + TimeZone, Tz::Offset: Send,

Returns both the server itself, as well as a JoinHandle that will resolve once all the operations needed for database upgrading are over. The handle resolves with the number of errors that occurred during the upgrade, normal runs would return 0. There will be one error message in the tracing logs for each such error.

pub async fn login_session( &self, user_id: User, session_name: String, expiration_time: Option<SystemTime>, ) -> Result<(SessionToken, SessionRef)>

pub async fn answer(&self, socket: WebSocket)

pub async fn vacuum( &self, no_new_changes_before: Option<EventId>, kill_sessions_older_than: Option<SystemTime>, ) -> Result<()>

Cleans up and optimizes up the database

After running this, the database will reject any new change that would happen before no_new_changes_before if it is set.