changes_stream2

基于 https://github.com/ashleygwilliams/changes-stream-rust / https://crates.io/crates/changes-stream 的分支。

Rust 中 changes-stream 的实现。

此代码从端点读取可读流，解析每一行，并以 CouchDB 变更事件的形式返回，这些事件在 src/event.rs 中定义。

用法

在您的 Cargo.toml 中

[dependencies]
changes-stream2 = "0.2"

从 examples/follower.rs

use changes_stream2::{ChangesStream, Event};
use futures_util::stream::StreamExt;

#[tokio::main]
async fn main() {
    let url = "https://replicate.npmjs.com/_changes".to_string();
    let mut changes = ChangesStream::new(url).await.unwrap();
    while let Some(event) = changes.next().await {
        match event {
            Ok(Event::Change(change)) => println!("Change ({}): {}", change.seq, change.id),
            Ok(Event::Finished(finished)) => println!("Finished: {}", finished.last_seq),
            Err(err) => println!("Error: {:?}", err),
        }
    }
}

功能

metrics

启用变更流的指标收集，作为计数器值。名称由 URL 的主机和路径（数据库名称）生成。这些指标包括

• couchdb_changes_{name}_bytes：从变更流中读取的总字节数
• couchdb_changes_{name}_entries：解析的总变更条目数

raw_value_doc

将 ChangeEvent::Doc 的类型从 serde_json::Map<String, serde_json::Value> 更改为 serde_json::value::RawValue。

native-tls

使用 native-tls crate 进行 TLS 连接。这是默认设置。

rustls-tls

使用 rustls crate 进行 TLS 连接。