Struct Ctx 

pub struct Ctx {
    pub home: Home,
    pub store: Mutex<Store>,
    pub backend: Arc<dyn CloneBackend>,
    pub started_at: Instant,
    pub room: Notify,
    pub events_tx: Sender<EventRow>,
    /* private fields */
}

Fields

home: Home

store: Mutex<Store>

backend: Arc<dyn CloneBackend>

started_at: Instant

room: Notify

Woken whenever a clone goes away or the settings change, so queued creates look again.

events_tx: Sender<EventRow>

Every event events::emit writes, for mitosis events --follow connections.

Implementations

impl Ctx

pub fn open(home: Home, config: Config) -> Result<Ctx>

pub fn config(&self) -> Config

A snapshot of the current settings; a later reload does not change it.

pub fn set_config(&self, config: Config)

pub fn installs(&self) -> Vec<PgInstall>

A snapshot of the known Postgres installs, newest first.

pub async fn install_major(&self, major: u32) -> Result<PgInstall>

The install of major; on a miss the machine is searched once more before giving up.

pub async fn newest_install(&self) -> Result<PgInstall>

The newest install; on a miss the machine is searched once more before giving up.

pub fn router(&self) -> MutexGuard<'_, RouterState>

Locks the router state; never hold it across an await or a store call.

pub fn store(&self) -> MutexGuard<'_, Store>

Locks the store; use it for one store call at a time, never across Postgres work.