Module jsonrpsee_core::server
source · Available on crate feature
server
only.Expand description
Shared modules for the JSON-RPC servers.
Re-exports
pub use helpers::BatchResponseBuilder;
pub use helpers::BoundedWriter;
pub use helpers::MethodResponse;
pub use helpers::MethodSink;
Modules
- Helpers.
Structs
- This wraps
tokio::sync::Semaphore
and is used to limit the number of subscriptions per connection. - Error that may occur during
crate::server::MethodSink::send
orcrate::server::SubscriptionSink::send
. - Represents a subscription until it is unsubscribed.
- Reference-counted, clone-on-write collection of synchronous and asynchronous methods.
- The error returned while accepting a subscription.
- Represents a single subscription that is waiting to be accepted or rejected.
- Sets of JSON-RPC methods can be organized into “module“s that are in turn registered on the server or, alternatively, merged with other modules to construct a cohesive API.
RpcModule
wraps an additional context argument that can be used to access data during call execution. - Wrapper struct that maintains a subscription “mainly” for testing.
- Represent a unique subscription entry based on
SubscriptionId
andConnectionId
. - Subscription message.
- Represents a single subscription that hasn’t been processed yet.
- Helper struct to manage subscriptions.
Enums
- This represent a response to a RPC call and
Subscribe
calls are handled differently because we want to prevent subscriptions to start before the actual subscription call has been answered. - Callback wrapper that can be either sync or async.
- Result of a method, either direct value or a future of one.
- Error that may occur during
crate::server::MethodSink::send_timeout
orcrate::server::SubscriptionSink::send_timeout
. - Represents what action that will sent when a subscription callback returns.
- A complete subscription message or partial subscription message.
- Error that may occur during
crate::server::MethodSink::try_send
orcrate::server::SubscriptionSink::try_send
.
Traits
- Something that can be converted into a JSON-RPC method call response.
- Convert something into a subscription close notification before a subscription is terminated.
Type Aliases
- Similar to
SyncMethod
, but represents an asynchronous handler. - Connection ID, used for stateful protocol such as WebSockets. For stateless protocols such as http it’s unused, so feel free to set it some hardcoded value.
- Max response size.
- Raw response from an RPC A tuple containing:
- Type-alias for subscribers.
- Method callback for subscriptions.
- Subscription permit.
- A
MethodCallback
is an RPC endpoint, callable with a standard JSON-RPC request, implemented as a function pointer to aFn
function taking four arguments: theid
,params
, a channel the function uses to communicate the result (or error) back tojsonrpsee
, and the connection ID (useful for the websocket transport).