pjson-rs 0.6.3

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
43
44
45
46
47
48
49

//! 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 integration;
pub mod repositories;
pub mod schema_repository;
#[cfg(feature = "http-server")]
pub mod websocket;

pub use adapters::{
    ALLOWED_SORT_FIELDS, CompositeEventPublisher, EventPublisherVariant,
    GatInMemoryStreamRepository, GatInMemoryStreamStore, HttpEventPublisher,
    InMemoryEventPublisher, InMemoryFrameStore, InMemoryMetricsCollector, InMemoryStore,
    JsonAdapter, 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::{
    AdaptiveFrameStream, BatchFrameStream, CreateSessionRequest, CreateSessionResponse,
    HttpExtensionConfig, HttpServerConfig, PjsAppState, PjsError, PjsExtension,
    PriorityFrameStream, 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,
};
pub use integration::{
    AdapterConfig, IntegrationError, IntegrationResult, ResponseBody, StreamingAdapter,
    StreamingAdapterExt, StreamingFormat, UniversalAdapter, UniversalRequest, UniversalResponse,
    streaming_helpers,
};
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};