Expand description
§JetStream Rpc
Defines Rpc primitives for JetStream.
Of note is the Protocol trait which is meant to be used with the service attribute macro.
client::ClientTransport and server::ServiceTransport describe
one ordered frame sequence. session describes the thing that can
open another one: a session::Session is the association with a
peer, and a lane is one sequence obtained from it — which is what
those two traits already are. See the guide at
https://sevki.github.io/jetstream/sessions.html.
Re-exports§
pub use framer::*;
Modules§
Structs§
- Framed
- A unified
StreamandSinkinterface to an underlying I/O object, using theEncoderandDecodertraits to encode and decode frames. - Mux
- Client Mux
- Rerror
- Rlerror
- Router
- RpcCall
- RpcStream
- The caller’s end of a subscription: many responses under one tag.
- Rversion
- version – negotiate protocol version
- TagPool
- r[impl jetstream.subscription.cancel] Three regions of the tag space, not one pool.
- Tversion
- version – negotiate protocol version
Enums§
- Encoding
- Encoding
Error - Error
Frame - RpcFuture
- Either a call that reached the lane, or one that could not.
- Version
- Version
Frame - Waiter
- What is waiting on a tag.
Constants§
- HEADER_
KEY_ JETSTREAM_ PROTO - MIMETYPE_
JETSTREAM - MIMETYPE_
JSON - MIMETYPE_
OCTET_ STREAM - MIMETYPE_
XML - RERROR
- r[impl jetstream.error.v2.wireformat.error-frame]
A global id, below
MESSAGE_ID_START, like every other id in this frame. - RJETSTREAMERROR
- RLERROR
- RVERSION
- TVERSION
Traits§
- AnyServer
- Decoder
- Decoding of frames via buffers.
- Encoder
- Trait of helper objects to write out messages as bytes, for use with
FramedWrite. - Handler
- Incoming
- Into
Error - IntoError trait allows conversion of various error types into Jetstream Error.
- Message
- A trait representing a message that can be encoded and decoded.
- Protocol
- Defines the request and response types for the JetStream protocol.