Struct Db 

pub struct Db {
    pub pool: Pool,
    /* private fields */
}

Fields

pool: Pool

Implementations

impl Db

pub fn connect(cfg: &Config) -> Result<Db>

pub fn sql(&self, q: &str) -> String

Swap chess. and site. table prefixes for the configured schemas (only where a prefix starts a word, so prose in comments is safe).

pub async fn conn(&self) -> Result<Conn>

pub fn channel(&self) -> &str

pub fn subscribe(&self) -> Receiver<Note>

pub fn encode(n: &Note) -> String

pub fn decode(s: &str) -> Option<Note>

pub async fn migrate(&self) -> Result<()>

Run migrations: this server’s schema and tables. The site’s schema must exist (its players and API tokens are what we sign people in with).

pub async fn listen(self, cfg: Config, stop: Receiver<bool>)

Keep a LISTEN connection open and forward notifications into the local broadcast. Reconnects with backoff; after a reconnect every stream is told to resync.

Trait Implementations

impl Clone for Db

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.