netbat 0.9.0

Thin sync-first server/network boundary exposure layer for syncbat.
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

mod error;
mod frame;
mod hex;
mod limiter;
mod limits;
mod stream_frame;
mod stream_tcp;
mod tcp;
#[cfg(feature = "tls")]
mod tls;

pub use error::NetbatError;
pub use frame::{
    decode_line, dispatch_frame, encode_request, encode_response, RequestFrame, ResponseFrame,
};
pub use hex::{decode_hex, decode_hex_str, encode_hex, encode_hex_into, encode_hex_str};
pub use limiter::{ConnectionLimit, DEFAULT_MAX_CONNECTIONS};
pub use limits::{
    IoTimeouts, Limits, CALL_VERB, DEFAULT_MAX_CURSOR_BYTES, DEFAULT_MAX_INPUT_BYTES,
    DEFAULT_MAX_LINE_BYTES, DEFAULT_MAX_OPERATION_NAME_BYTES, DEFAULT_MAX_OUTPUT_BYTES,
    DEFAULT_MAX_STREAM_ERROR_MESSAGE_BYTES, DEFAULT_MAX_STREAM_PAYLOAD_BYTES,
    DEFAULT_MAX_SUBSCRIPTION_ID_BYTES, LINE_PROTOCOL_VERSION, PROTOCOL_PREFIX,
    STREAM_PROTOCOL_VERSION, SUBSCRIBE_VERB, SUB_ACK_VERB, SUB_CANCEL_VERB, SUB_END_VERB,
    SUB_ERR_VERB, SUB_EVENT_VERB, SUB_WATERMARK_VERB,
};
pub use stream_frame::{
    decode_stream_line, encode_stream_frame, ClientWindow, CursorBytes, DeliveryIndex, MaybeCursor,
    PayloadSchemaRef, StreamFrame, StreamReasonCode, SubAckFrame, SubCancelFrame, SubEndFrame,
    SubErrFrame, SubEventFrame, SubWatermarkFrame, SubscribeFrame, SubscriptionToken,
};
pub use stream_tcp::{
    serve_subscription_stream, serve_tcp_subscription_listener,
    serve_tcp_subscription_listener_secured, SubscriptionDispatch, TcpSubscriptionServeStats,
    TcpSubscriptionServerConfig,
};
pub use tcp::{
    serve_stream, serve_tcp_listener, serve_tcp_listener_secured, ShutdownHandle, TcpServeStats,
    TcpServerConfig, TransportSecurity, DEFAULT_MAX_REQUESTS_PER_CONNECTION,
};
#[cfg(feature = "tls")]
pub use tls::TlsServerConfig;