19 releases

new 0.2.19 Nov 21, 2024
0.2.18 Jul 8, 2024
0.2.16 Jun 7, 2024
0.2.13 May 21, 2024
0.2.1 Mar 15, 2021

#773 in Web programming

Download history 13/week @ 2024-07-28 1/week @ 2024-08-04 17/week @ 2024-08-11 23/week @ 2024-08-18 26/week @ 2024-08-25 2/week @ 2024-09-01 2/week @ 2024-09-15 36/week @ 2024-09-22 34/week @ 2024-09-29 12/week @ 2024-10-06 15/week @ 2024-10-13 1/week @ 2024-10-20 27/week @ 2024-10-27 15/week @ 2024-11-03 18/week @ 2024-11-10

62 downloads per month

MIT license

18KB
175 lines

changes_stream2

License Cargo Documentation

Fork of https://github.com/ashleygwilliams/changes-stream-rust / https://crates.io/crates/changes-stream.

An implementation of changes-stream in Rust.

This code reads in a readable stream from an endpoint, parses each line and returns CouchDB changes events as defined in src/event.rs.

usage

in your Cargo.toml:

[dependencies]
changes-stream2 = "0.2"

from 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),
        }
    }
}

features

metrics

Enables metrics collection of the changes stream as counter values. The name is generated from the host and path of the url(database name). The metrics are:

  • couchdb_changes_{name}_bytes: Total bytes read from the changes stream
  • couchdb_changes_{name}_entries: Total parsed change entries

raw_value_doc

Changes the type of ChangeEvent::Doc from serde_json::Map<String, serde_json::Value> to serde_json::value::RawValue.

native-tls

Use the native-tls crate for TLS connections. This is the default.

rustls-tls

Use the rustls crate for TLS connections.

Dependencies

~6–18MB
~238K SLoC