Struct seshat::RecoveryDatabase

pub struct RecoveryDatabase { /* private fields */ }

Database that can be used to reindex the events.

Reindexing the database may be needed if the index schema changes. This may happen occasionally on upgrades or if language settings for the database change.

Implementations

impl RecoveryDatabase

pub fn new<P: AsRef<Path>>(path: P) -> Result<Self>where PathBuf: From<P>,

Open a read-only Seshat database.

Arguments

• path - The directory where the database will be stored in. This should be an empty directory if a new database should be created.

pub fn new_with_config<P: AsRef<Path>>(path: P, config: &Config) -> Result<Self>where PathBuf: From<P>,

Open a recovery Seshat database with the provided config.

Arguments

• path - The directory where the database will be stored in. This should be an empty directory if a new database should be created.

• config - Configuration that changes the behaviour of the database.

pub fn delete_the_index(&mut self) -> Result<()>

Delete the Seshat index, leaving only the events database.

After this operation is done, the index can be rebuilt.

pub fn load_events_deserialized( &self, limit: usize, from_event: Option<&Event> ) -> Result<Vec<Event>>

Load deserialized events from the database.

• limit - The number of events to load.
• from_event - The event where to continue loading from.

Events that fail to be deserialized will be filtered out.

pub fn load_events( &self, limit: usize, from_event: Option<&Event> ) -> Result<Vec<String>>

Load serialized events from the database.

• limit - The number of events to load.
• from_event - The event where to continue loading from.

pub fn open_index(&mut self) -> Result<()>

Create and open a new index.

Returns ReindexError if the index wasn’t deleted first.

pub fn info(&self) -> &RecoveryInfo

Get the recovery info for the database.

pub fn get_connection(&self) -> Result<Connection>

Get a database connection.

Note that this connection should only be used for reading.

pub fn index_events(&mut self, events: &[Event]) -> Result<()>

Re-index a batch of events.

Arguments

• events - The events that should be reindexed.

Returns ReindexError if the index wasn’t previously deleted and opened.

pub fn commit(&mut self) -> Result<bool>

Commit to the index.

Returns true if the commit was forwarded, false if not enough events are queued up.

Returns ReindexError if the index wasn’t previously deleted and opened.

pub fn commit_and_close(self) -> Result<()>

Commit the remaining added events and mark the reindex as done.

Returns ReindexError if the index wasn’t previously deleted and opened.

pub fn shutdown(self) -> Result<()>

Shut the database down.

This will terminate the writer thread making sure that no writes will happen after this operation.