#meilisearch #analytics #server #user #com-meilisearch

segment

Segment analytics client for Rust. Forked for Meilisearch: https://github.com/meilisearch

10 releases

0.2.6 Mar 5, 2025
0.2.4 May 7, 2024
0.2.3 Oct 25, 2023
0.2.2 Jan 9, 2023
0.1.2 Oct 27, 2021

#2 in #meilisearch

Download history 6393/week @ 2024-12-09 6480/week @ 2024-12-16 3025/week @ 2024-12-23 4139/week @ 2024-12-30 6202/week @ 2025-01-06 7351/week @ 2025-01-13 7550/week @ 2025-01-20 6896/week @ 2025-01-27 8941/week @ 2025-02-03 8103/week @ 2025-02-10 6985/week @ 2025-02-17 8843/week @ 2025-02-24 7949/week @ 2025-03-03 7523/week @ 2025-03-10 7954/week @ 2025-03-17 6904/week @ 2025-03-24

30,950 downloads per month

MIT license

38KB
602 lines

Segment

Test Status API

This crate is an unofficial segment analytics client for Rust used by Meilisearch

Example usage(s)

use segment::{HttpClient, Client, AutoBatcher, Batcher};
use segment::message::{Track, User};
use serde_json::json;

#[tokio::main(flavor = "current_thread")]
async fn main() {
    let write_key = "YOUR_WRITE_KEY";

    let client = HttpClient::default();
    let batcher = Batcher::new(None);
    let mut batcher = AutoBatcher::new(client, batcher, write_key.to_string());

    // Pretend this is reading off of a queue, a file, or some other data
    // source.
    for i in 0..100 {
        let msg = 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.
        batcher.push(msg).await.unwrap();
    }

    batcher.flush().await.unwrap();
}

or when you want to do struct to struct transformations

use segment::{HttpClient, Client};
use segment::message::{Track, Message, User};
use serde_json::json;

#[tokio::main(flavor = "current_thread")]
async fn main() {
    let write_key = "YOUR_WRITE_KEY";

    let client = HttpClient::default();
    client.send(write_key.to_string(), Message::from(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()
    })).await.expect("could not send to Segment");
}

License

Licensed under MIT license.

Dependencies

~5–19MB
~290K SLoC