Struct WalRegistry

pub struct WalRegistry<IO: Io, S> { /* private fields */ }

Wal Registry maintains a set of shared Wal, and their respective set of files.

Implementations

impl<S> WalRegistry<StdIO, S>

pub fn new( storage: Arc<S>, checkpoint_notifier: Sender<CheckpointMessage>, ) -> Result<Self>

impl<IO: Io, S> WalRegistry<IO, S>

pub fn new_with_io( io: IO, storage: Arc<S>, checkpoint_notifier: Sender<CheckpointMessage>, ) -> Result<Self>

pub async fn get_async( &self, namespace: &NamespaceName, ) -> Option<Arc<SharedWal<IO>>>

impl<IO, S> WalRegistry<IO, S>

where IO: Io, S: Storage<Segment = SealedSegment<IO::File>>,

pub fn open( self: Arc<Self>, db_path: &Path, namespace: &NamespaceName, ) -> Result<Arc<SharedWal<IO>>>

pub async fn tombstone( &self, namespace: &NamespaceName, ) -> Option<Arc<SharedWal<IO>>>

pub async fn remove(&self, namespace: &NamespaceName)

pub async fn sync_all(&self, conccurency: usize) -> Result<()>

where S: Storage,

Attempts to sync all loaded dbs with durable storage

pub async fn shutdown(self: Arc<Self>) -> Result<()>

pub fn storage(&self) -> Arc<S>