rustmann

使用 tokio 的 riemann 客户端。此项目仍处于早期阶段，API变化频繁。

用法

请参阅 示例 和 API文档。

特性 & TODOs

• TCP客户端
• TLS TCP客户端（通过启用 tls 特性）
• UDP客户端
• 报告API（《code>send_events）
• 查询API（《code>send_query）
• 事件构建器API

许可证

MIT/Apache-2.0

lib.rs:

Rustmann

Rustmann是用于 riemann 的Rust客户端，riemann是一个流行的分布式系统事件聚合和处理程序。

此实现基于tokio，并使用异步await风格API。

特性

• 完整的异步await API
• 支持TCP/UDP/TLS传输
• 自动重连
• 发送和查询API
• 事件构建器
• 示例中的可用的CLI

快速入门

use rustmann::{EventBuilder, RiemannClient, RiemannClientError, RiemannClientOptions};

#[tokio::main]
async fn main() -> Result<(), RiemannClientError> {
    // create client with default configuration (to localhost:5555)
    let mut client = RiemannClient::new(&RiemannClientOptions::default());

    // create a riemann event using evnet builder API
    let event = EventBuilder::new()
        .service("riemann_test")
        .state("ok")
        .metric_f(123.4)
        .build();

    // send event to server
    let response = client.send_events(vec![event]).await?;
    println!("{:?}", response);

    // query riemann
    let query_response = client.send_query("service = \"riemann_test\"").await?;
    println!("{:?}", query_response);
    Ok(())
}

请参阅 示例 了解更多用法演示。