litellm-rs 0.6.0

A high-performance AI Gateway written in Rust, providing OpenAI-compatible APIs with intelligent routing, load balancing, and enterprise features
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

//! Tests for the event publish-subscribe system

use super::broker::{EventBroker, EventBrokerConfig};
use super::types::{Event, EventType, Subscriber, SubscriptionHandle};
use std::sync::Arc;
use std::sync::atomic::{AtomicU32, Ordering};
use std::time::Duration;
use tokio::sync::Barrier;
use tokio::time::timeout;

#[derive(Debug, Clone, PartialEq)]
struct TestData {
    id: u64,
    value: String,
}

impl TestData {
    fn new(id: u64, value: &str) -> Self {
        Self {
            id,
            value: value.to_string(),
        }
    }
}

mod broker_concurrency_tests;
mod broker_config_tests;
mod broker_creation_tests;
mod broker_edge_case_tests;
mod broker_publish_tests;
mod broker_subscription_tests;
mod event_tests;
mod event_type_tests;
mod subscriber_trait_tests;
mod subscription_handle_tests;