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

arete_server/websocket/
mod.rs
