List of all items

Structs

• backpressure::AcceptPayload
• backpressure::DeferPayload
• backpressure::RejectPayload
• backpressure::StreamPressure
• causal::CausalContext
• causal::MessageId
• envelope::MessageEnvelope
• envelope::SchemaId
• frame::DeliveredId
• frame::FrameHeader
• frame::LinkOffer
• frame::WorkerActivityDescriptor
• frame::WorkerRegistration
• lifecycle::LifecycleAction
• multiplex::StreamAllocator
• multiplex::StreamId
• multiplex::StreamTable
• version::ProtocolVersion
• worker_refusal::WorkerRefusal

Enums

• backpressure::PressureState
• error::ProtocolError
• frame::DisconnectReason
• frame::Frame
• frame::FrameType
• frame::LinkEnd
• frame::LinkOpenOutcome
• frame::WorkerRegisterOutcome
• lifecycle::ConnectionState
• multiplex::StreamState
• worker_refusal::WorkerRefusalCode

Traits

• multiplex::AllocateStreamId

Functions

• causal::extract_causal_context
• codec::decode
• codec::encode
• codec::encoded_len
• frame::validate_stream
• handshake::connect_ack_frame
• handshake::connect_error_frame
• handshake::connect_frame
• schema::negotiate_schema
• schema::subscribe_error_frame
• version::negotiate_version

Constants

• frame::CONVERSATION_REPLY_REQUESTED_FLAG
• frame::DELIVER_MESSAGE_ID_FLAG
• frame::DELIVER_MESSAGE_ID_VERSION
• frame::DISCONNECT_REASON_BODY_MAX
• frame::DISCONNECT_REASON_BODY_VERSION
• frame::DISCONNECT_REASON_NAME_MAX
• frame::HEADER_LEN
• frame::LINK_MACHINE_LEN
• frame::PUBLISH_ACK_POSITION_VERSION
• frame::PUBLISH_DELIVERED_FLAG
• frame::PUBLISH_DURABLE_POSITION_FLAG
• frame::PUBLISH_IDEMPOTENCY_KEY_FLAG
• frame::REVOCATION_CLOSE_VERSION
• worker_refusal::PUSH_REPLY_REFUSED_FLAG
• worker_refusal::WORKER_REFUSAL_WORDS_MAX