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.

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]asyncfnmain(){let url = "https://replicate.npmjs.com/_changes".to_string();letmut changes = ChangesStream::new(url).await.unwrap();whileletSome(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),}}}

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

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

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

Use the rustls crate for TLS connections.