List of all items

Structs

• client::Client
• client::ClientConfig
• client::HttpConfig
• client::Subscription
• client::builder::ClientBuilder
• client::http::HttpClientBackend
• client::http::HttpConfig
• client::http::h3::H3Reader
• client::message_dispatcher::MessageDispatcher
• client::subscriptions::Subscription
• client::subscriptions::Subscriptions
• codec::JsonCodec
• hyper_exec::HyperExecutor
• message::Error
• message::Notification
• message::NotificationResult
• message::Request
• message::Response
• server::ConnState
• server::HttpConfig
• server::Server
• server::ServerConfig
• server::acceptor::StreamAcceptor
• server::acceptor::WsAcceptor
• server::builder::ServerBuilder
• server::channel::Channel
• server::channel::NewNotification
• server::channel::Subscription
• server::dispatch::NewRequest
• server::http::HttpConfig
• server::http::HttpServer
• server::http::h3::BodyReader

Enums

• client::ClientBackend
• client::http::HttpTransport
• client::multiplexed::NewMsg
• error::Error
• error::RPCError
• server::ServerBackend
• server::dispatch::Handler
• server::dispatch::SanityCheckResult

Traits

• client::WsCodec
• codec::Codec
• codec::JsonRpcCodec
• codec::JsonRpcWsCodec
• server::WsCodec
• server::acceptor::AsyncAcceptor
• server::acceptor::StreamListener
• server::http::HttpAcceptor
• server::pubsub_service::PubSubRPCService
• server::service::RPCService

Attribute Macros

• rpc_impl
• rpc_method
• rpc_pubsub_impl

Functions

• client::http::build_backend
• client::http::h1::build_request
• client::http::h1::send
• client::http::h2::connect
• client::http::h2::driver_task
• client::http::h2::send
• client::http::h3::connect
• client::http::h3::driver_task
• client::http::h3::read_response
• client::http::h3::send
• client::http::h3::start_request
• client::http::h3::subscribe
• client::http::h3::subscription_task
• client::http::http_client_backend
• client::http::parse_response
• client::multiplexed::background_loop
• client::multiplexed::build_backend_state
• client::multiplexed::build_byte_backend
• client::multiplexed::build_ws_backend
• client::multiplexed::connect_byte
• client::multiplexed::connect_ws
• client::multiplexed::handle_mux_msg
• client::multiplexed::run_io_loop
• client::multiplexed::send_request
• client::multiplexed::start_io_loop
• client::quic_stream::build_backend
• client::quic_stream::call
• client::quic_stream::subscribe
• client::quic_stream::subscription_stream_task
• client::subscriptions::decode_notification
• client::subscriptions::default_notification_decoder
• codec::decode_body
• codec::encode_msg
• codec::extend_buf
• server::accept_backoff
• server::builder::default_notification_encoder
• server::create_backend
• server::dispatch::err_res
• server::dispatch::method_not_found
• server::dispatch::sanity_check
• server::http::encode_response
• server::http::h1h2::accept_tcp
• server::http::h1h2::encode_hyper_response
• server::http::h1h2::handle_hyper_request
• server::http::h1h2::serve_conn
• server::http::h1h2::serve_task
• server::http::h3::accept_h3
• server::http::h3::h3_err
• server::http::h3::h3_send
• server::http::h3::handle_h3_request
• server::http::h3::handle_h3_subscription
• server::http::h3::handle_request_task
• server::http::h3::ok_response
• server::http::h3::serve_conn
• server::http::h3::serve_conn_task
• server::http::h3::serve_incoming_task
• server::http::json_response
• server::http::json_response_bytes
• server::http::parse_error_response
• server::quic::handle_quic_stream
• server::quic::handle_quic_subscription
• server::quic::quic_accept_streams_task
• server::quic::quic_handle_stream_task
• server::request_task
• server::stream_reader_task
• server::stream_writer_task

Type Aliases

• client::NotificationDecoder
• client::RequestID
• client::http::h2::H2SendRequest
• client::http::h3::H3RecvStream
• client::http::h3::H3SendRequest
• client::http::h3::H3SendStream
• client::http::h3::H3Stream
• client::subscriptions::NotificationDecoder
• codec::ByteBuffer
• error::RPCResult
• error::Result
• message::ID
• message::SubscriptionID
• server::http::h3::H3Recv
• server::http::h3::H3Resolver
• server::http::h3::H3Send
• server::pubsub_service::PubSubRPCMethod
• server::pubsub_service::PubSubRPCMethodOutput
• server::service::RPCMethod
• server::service::RPCMethodOutput

Constants

• client::builder::DEFAULT_MAX_SUBSCRIPTION_BUFFER_SIZE
• client::builder::DEFAULT_TIMEOUT
• client::multiplexed::OUTBOUND_BUFFER_SIZE
• codec::DEFAULT_CONTENT_TYPE
• codec::DEFAULT_MAX_BUFFER_SIZE
• message::INTERNAL_ERROR_CODE
• message::INTERNAL_ERROR_MSG
• message::INVALID_PARAMS_ERROR_CODE
• message::INVALID_REQUEST_ERROR_CODE
• message::JSONRPC_VERSION
• message::METHOD_NOT_FOUND_ERROR_CODE
• message::PARSE_ERROR_CODE
• server::ACCEPT_BACKOFF_BASE
• server::ACCEPT_BACKOFF_MAX
• server::CHANNEL_SUBSCRIPTION_BUFFER_SIZE
• server::FAILED_TO_PARSE_ERROR_MSG
• server::INVALID_REQUEST_ERROR_MSG
• server::MAX_CONCURRENT_REQUESTS
• server::METHOD_NOT_FOUND_ERROR_MSG
• server::RESPONSE_QUEUE_SIZE
• server::UNSUPPORTED_JSONRPC_VERSION
• server::builder::DEFAULT_HANDSHAKE_TIMEOUT
• server::http::ERR_BODY_TOO_LARGE
• server::http::ERR_ENCODE_RESPONSE
• server::http::ERR_METHOD_NOT_ALLOWED
• server::http::ERR_READ_BODY
• server::http::MAX_HTTP_BODY_SIZE