arete_server/websocket/
mod.rs

1pub mod admission;
2pub mod auth;
3pub mod client_manager;
4pub mod frame;
5#[cfg(test)]
6mod load_tests;
7pub mod rate_limiter;
8pub mod server;
9pub mod subscription;
10pub mod usage;
11
12pub use admission::{WebSocketAdmissionProvider, WebSocketConnectionPermit};
13pub use auth::{
14    AllowAllAuthPlugin, AuthContext, AuthDecision, AuthDeny, AuthErrorDetails,
15    ConnectionAuthRequest, ErrorResponse, RetryPolicy, SignedSessionAuthPlugin,
16    StaticTokenAuthPlugin, WebSocketAuthPlugin,
17};
18pub use client_manager::{ClientInfo, ClientManager, RateLimitConfig, SendError, WebSocketSender};
19pub use frame::{
20    Frame, Mode, SnapshotEntity, SnapshotFrame, SortConfig, SortOrder, SubscribedFrame,
21    UnsubscribedFrame,
22};
23pub use rate_limiter::{RateLimitResult, RateLimitWindow, RateLimiterConfig, WebSocketRateLimiter};
24pub use server::WebSocketServer;
25pub use subscription::{
26    ClientMessage, RefreshAuthRequest, RefreshAuthResponse, SnapshotOptions, SocketIssueMessage,
27    Subscription, SubscriptionQuery, Unsubscription, PROTOCOL_VERSION,
28};
29pub use usage::{
30    ChannelUsageEmitter, HttpUsageEmitter, WebSocketUsageBatch, WebSocketUsageEmitter,
31    WebSocketUsageEnvelope, WebSocketUsageEvent,
32};
arete_server/websocket/mod.rs

arete_server/websocket/
mod.rs
