aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorDeterminant <[email protected]>2020-06-16 14:50:05 -0400
committerDeterminant <[email protected]>2020-06-16 14:50:05 -0400
commit88b5fabd56ec0f9d46eed2dbf7fbc08b84b1f216 (patch)
treeb0a20cb80d5b03e92cefb1fa55159d298d49d19f /src
parent6b8000d8fd8b88afbc7fb45094da29fb02627ed2 (diff)
prepare for publish
Diffstat (limited to 'src')
-rw-r--r--src/lib.rs44
-rw-r--r--src/wal.rs2
2 files changed, 45 insertions, 1 deletions
diff --git a/src/lib.rs b/src/lib.rs
index 906ec41..6e3109d 100644
--- a/src/lib.rs
+++ b/src/lib.rs
@@ -1,3 +1,47 @@
+//! Simple and modular write-ahead-logging implementation.
+//!
+//! # Examples
+//!
+//! ```
+//! use growthring::{WALStoreAIO, wal::WALLoader};
+//! use futures::executor::block_on;
+//! // start from empty WAL (trucate = true)
+//! let store = WALStoreAIO::new("./walfiles", true, |_, _| {Ok(())});
+//! let mut wal = WALLoader::new(9, 8, 1000).recover(store).unwrap();
+//! // write a vector of records to WAL
+//! for f in wal.grow(vec!["record1(foo)", "record2(bar)", "record3(foobar)"]).into_iter() {
+//! let ring_id = block_on(f).unwrap().1;
+//! println!("WAL recorded record to {:?}", ring_id);
+//! }
+//!
+//!
+//! // load from WAL if exists (trucate = false)
+//! let store = WALStoreAIO::new("./walfiles", false, |payload, ringid| {
+//! // redo the operations in your application
+//! println!("recover(payload={}, ringid={:?})",
+//! std::str::from_utf8(&payload).unwrap(),
+//! ringid);
+//! Ok(())
+//! });
+//! let mut wal = WALLoader::new(9, 8, 1000).recover(store).unwrap();
+//! // We'll see the playback of the log even if there is no failure. Let's remove the old log
+//! // entries by assuming they are already persistent in your application.
+//! let ring_ids = wal.grow((0..100).into_iter().map(|i| "a".repeat(i)).collect::<Vec<_>>())
+//! .into_iter().map(|f| block_on(f).unwrap().1).collect::<Vec<_>>();
+//!
+//!
+//! // Let's assume all these records are not longer needed. There will only be one remaining file
+//! // in ./walfiles
+//! block_on(wal.peel(ring_ids)).unwrap();
+//!
+//! let store = WALStoreAIO::new("./walfiles", false, |payload, _| {
+//! println!("payload.len() = {}", payload.len());
+//! Ok(())
+//! });
+//! let wal = WALLoader::new(9, 8, 1000).recover(store).unwrap();
+//! // The ./walfiles is empty now as all records are played back.
+//! ```
+
#[macro_use] extern crate scan_fmt;
pub mod wal;
diff --git a/src/wal.rs b/src/wal.rs
index c378e0a..aefec36 100644
--- a/src/wal.rs
+++ b/src/wal.rs
@@ -73,7 +73,7 @@ impl Record for String {
fn serialize(&self) -> WALBytes { self.as_bytes().into() }
}
-impl Record for str {
+impl Record for &str {
fn serialize(&self) -> WALBytes { self.as_bytes().into() }
}