commitlog 0.0.10

Implementation of an append-only commit log backed by disk.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

extern crate commitlog;

use commitlog::message::*;
use commitlog::*;
use std::time::{self, SystemTime};

fn main() {
    // open a directory called 'log' for segment and index storage
    let opts = LogOptions::new(format!(
        ".log{}",
        SystemTime::now()
            .duration_since(time::UNIX_EPOCH)
            .unwrap()
            .as_secs()
    ));
    let mut log = CommitLog::new(opts).unwrap();

    // append to the log
    log.append_msg("hello world").unwrap(); // offset 0
    log.append_msg("second message").unwrap(); // offset 1

    // read the messages
    let messages = log.read(0, ReadLimit::default()).unwrap();
    for msg in messages.iter() {
        println!(
            "{} - {}",
            msg.offset(),
            String::from_utf8_lossy(msg.payload())
        );
    }

    // prints:
    //    0 - hello world
    //    1 - second message
}