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
62 downloads per month
18KB
175 lines
changes_stream2
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 streamcouchdb_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