提交日志

为Rust编写的顺序，基于磁盘的提交日志库。该库可以用于在分布式日志（如Paxos、链式复制或Raft）之上构建各种高级分布式抽象。

文档

用法

首先，将以下内容添加到您的 Cargo.toml

[dependencies]
commitlog = "0.1"

extern crate commitlog;

use commitlog::*;

fn main() {
    // open a directory called 'log' for segment and index storage
    let opts = LogOptions::new("log");
    let mut log = CommitLog::new(opts).unwrap();

    // append to the log
    log.append("hello world").unwrap(); // offset 0
    log.append("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
}

先有技术

• Apache Kafka
• Jocko + 优秀的博客文章