[−][src]Crate analytics
A Rust client to Segment's tracking API.
For more on what Segment is, refer to Segment's documentation.
Examples
Simple
use analytics::http::HttpClient; use analytics::client::Client; use analytics::message::{Track, Message, User}; use serde_json::json; fn main() { let write_key = "YOUR_WRITE_KEY"; let client = HttpClient::default(); client.send(write_key, &Message::Track(Track { user: User::UserId { user_id: "some_user_id".to_owned() }, event: "Example Event".to_owned(), properties: json!({ "some property": "some value", "some other property": "some other value", }), ..Default::default() })).expect("could not send to Segment"); }
ETL-Like
use analytics::http::HttpClient; use analytics::client::Client; use analytics::message::{BatchMessage, Track, User}; use analytics::batcher::Batcher; use serde_json::json; fn main() { let write_key = "YOUR_WRITE_KEY"; let client = HttpClient::default(); let mut batcher = Batcher::new(None); // Pretend this is reading off of a queue, a file, or some other data // source. for i in 0..100 { let msg = BatchMessage::Track(Track { user: User::UserId { user_id: format!("user-{}", i) }, event: "Example Event".to_owned(), properties: json!({ "foo": format!("bar-{}", i), }), ..Default::default() }); // An error here indicates a message is too large. In real life, you // would probably want to put this message in a deadletter queue or some // equivalent. if let Some(msg) = batcher.push(msg).unwrap() { client.send(write_key, &batcher.into_message()).unwrap(); batcher = Batcher::new(None); batcher.push(msg).unwrap(); // Same error condition as above. } } }
Modules
batcher | Utilities for batching up messages. |
client | Interfaces to the Segment tracking API. |
errors | Errors which may arise from this crate. |
http | Low-level HTTP bindings to the Segment tracking API. |
message | Representations of the messages which may be sent to Segment's tracking API. |