pjson-rs 0.7.0

Priority JSON Streaming Protocol - high-performance priority-based JSON streaming (requires nightly Rust)
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
36
37
38
39
40
41
42

//! Infrastructure layer - External concerns and adapters
//!
//! Implements infrastructure adapters for databases, HTTP servers,
//! message queues, WebSocket transport, and other external systems.

pub mod adapters;
pub mod bounded_channel;
#[cfg(feature = "http-server")]
pub mod http;
pub mod repositories;
pub mod schema_repository;
#[cfg(feature = "http-server")]
pub mod websocket;

pub use adapters::{
    GatInMemoryStreamRepository, GatInMemoryStreamStore, InMemoryEventPublisher,
    InMemoryFrameStore, InMemoryMetricsCollector, InMemoryStore, MAX_HEALTH_METRICS,
    MAX_PAGINATION_LIMIT, MAX_PAGINATION_OFFSET, MAX_RESULTS_LIMIT, MAX_SCAN_LIMIT,
    PerformanceMetrics, SessionMetrics, SessionStore, StoredEvent, StreamMetrics, StreamStore,
    TimestampedMetrics,
};
pub use bounded_channel::{
    ByteBoundedSender, Envelope, SendError, TrySendError, byte_bounded_channel,
};
#[cfg(feature = "http-server")]
pub use http::{
    BatchFrameStream, ConnectionLimits, CreateSessionRequest, CreateSessionResponse,
    HttpExtensionConfig, HttpServerConfig, PjsAppState, PjsError, PjsExtension, RateLimitConfig,
    RateLimitMiddleware, StartStreamRequest, StreamFormat, StreamParams, StreamTransportError,
    TrustedProxyConfig, create_pjs_router, create_pjs_router_with_auth,
    create_pjs_router_with_config, create_pjs_router_with_rate_limit,
    create_pjs_router_with_rate_limit_and_auth, create_pjs_router_with_rate_limit_and_config,
    create_streaming_response, create_streaming_response_with_content_type, serve_with_limits,
};
pub use schema_repository::SchemaRepository;
#[cfg(feature = "http-server")]
pub use websocket::{
    AdaptiveStreamController, AxumWebSocketTransport, ClientMetrics, SecureWebSocketHandler,
    StreamOptions, WebSocketStreamSession, WebSocketTransport, WsMessage, create_websocket_router,
};
#[cfg(all(feature = "http-server", feature = "websocket-client"))]
pub use websocket::{PjsWebSocketClient, StreamStats};