MoodyBlues SDK For Rust

简介

Overlord 类似共识算法的追踪器SDK，帮助您调试或优化算法。

共识算法总是与分布式系统打交道，调试或优化非常困难。如果我们能记录事件来描述共识状态变化时发生的事情，然后使用可视化仪表板进行回放，调试或优化就会容易得多。

快速开始

让我们从一个简单的追踪示例开始。这个例子展示了如何使用SDK将TracePoint写入文件的JSON格式。

Cargo.toml

[dependencies]
moodyblues-sdk = { git = "https://github.com/nervosnetwork/moodyblues-client-rust" }

use std::fs::File;
use std::io::Write;
use std::sync::Mutex;

use serde_json::{json, to_string};

use moodyblues_sdk::event::{EventType, TraceEvent};
use moodyblues_sdk::point::{Metadata, TracePoint};
use moodyblues_sdk::trace;
use moodyblues_sdk::time::now;

struct ConsensusStateMachine {
    block_height: u64,
    round_id: u64,
}

impl ConsensusStateMachine {
    fn new_block(&mut self, block_height: u64) {
        self.block_height = &self.block_height + 1;
        self.round_id = 0;
        // create a trace point mark as starts with block
        trace::start_block(block_height);
    }

    fn new_round(&mut self, round_id: u64) {
        self.round_id = round_id;

        // create a trace point mark as starts with round
        trace::start_round(self.round_id, self.block_height);
    }
}

struct Consensus;

impl Consensus {
    fn verify_signature(signature: String, hash: String) {
        trace::custom(
            "verify_signature".to_string(),
            Some(json!({
              "hash": hash,
              "signature": signature
            })),
        )
    }
}

struct WriteReporter<W: Write + Send + 'static> {
    reporter: Mutex<W>,
}

impl<W: Write + Send + 'static> WriteReporter<W> {
    fn new(writable: W) -> Box<WriteReporter<W>> {
        Box::new(WriteReporter {
            reporter: Mutex::new(writable),
        })
    }
}

impl<W: Write + Send + 'static> trace::Trace for WriteReporter<W> {
    fn report(&self, point: TracePoint) {
        let mut file = self.reporter.lock().unwrap();
        file.write_all(to_string(&point).unwrap().as_bytes());
    }

    fn metadata(&self) -> Metadata {
        // information of current node
        Metadata {
            address: "0x0000000000000000000000000000000000000000".to_string(),
        }
    }

    fn now(&self) -> u64 {
        // timestamp for each point
        now()
    }
}

fn main() {
    trace::set_boxed_tracer(WriteReporter::new(File::create("log.log").unwrap()));
    trace::start_block(1);
}

文档

目前，请跳转到 trace.rs 获取更多信息。在第一个发布版本之前，API可能会频繁更改。