mirror of
https://github.com/neondatabase/neon.git
synced 2026-01-15 01:12:56 +00:00
600e1a0080
It's created once early in server startup, after parsing the command-line options, and never modified afterwards. To simplify things, pass it around as static ref, instead of making copies in all the different structs. We still pass around a reference to it, rather than putting it in a global variable, to allow unit testing with different configs in the same process.
33 lines
1.1 KiB
Rust
33 lines
1.1 KiB
Rust
//! This module acts as a switchboard to access different repositories managed by this
|
|
//! page server. Currently, a Page Server can only manage one repository, so there
|
|
//! isn't much here. If we implement multi-tenancy, this will probably be changed into
|
|
//! a hash map, keyed by the tenant ID.
|
|
|
|
use crate::repository::rocksdb::RocksRepository;
|
|
use crate::repository::Repository;
|
|
use crate::walredo::PostgresRedoManager;
|
|
use crate::PageServerConf;
|
|
use lazy_static::lazy_static;
|
|
use std::sync::{Arc, Mutex};
|
|
|
|
lazy_static! {
|
|
pub static ref REPOSITORY: Mutex<Option<Arc<dyn Repository + Send + Sync>>> = Mutex::new(None);
|
|
}
|
|
|
|
pub fn init(conf: &'static PageServerConf) {
|
|
let mut m = REPOSITORY.lock().unwrap();
|
|
|
|
// Set up a WAL redo manager, for applying WAL records.
|
|
let walredo_mgr = PostgresRedoManager::new(conf);
|
|
|
|
// we have already changed current dir to the repository.
|
|
let repo = RocksRepository::new(conf, Arc::new(walredo_mgr));
|
|
|
|
*m = Some(Arc::new(repo));
|
|
}
|
|
|
|
pub fn get_repository() -> Arc<dyn Repository + Send + Sync> {
|
|
let o = &REPOSITORY.lock().unwrap();
|
|
Arc::clone(o.as_ref().unwrap())
|
|
}
|