List of all items

Structs

• frame::Preamble
• header::CreditHeader
• header::CursorHeader
• header::DataHeader
• header::ErrorHeader
• header::GuaranteeSet
• header::Hello
• header::SubscriptionHeader
• negotiate::Agreed

Enums

• frame::FrameKind
• frame::PreambleError
• header::Acknowledgement
• header::Backpressure
• header::CursorLevel
• header::Deduplication
• header::Delivery
• header::Durability
• header::HeaderError
• header::OrderingMode
• header::ProducerNaming
• header::ReportMode
• negotiate::NegotiateError
• varint::VarintError

Functions

• codes::name
• codes::stop_reason
• frame::encode_frame
• frame::encode_preamble
• frame::parse_preamble
• frame::preamble_bytes
• header::decode_cursor_record
• header::encode_cursor_record
• header::filter::matches
• header::filter::validate
• negotiate::negotiate
• varint::decode_varint
• varint::encode_varint
• varint::varint_len
• varint::write_varint

Constants

• ALPN
• VERSION
• codes::CANCELED
• codes::INTERNAL
• codes::LIMIT_EXCEEDED
• codes::NEGOTIATION_FAILED
• codes::NO_ERROR
• codes::PROTOCOL_VIOLATION
• codes::REJECTED
• codes::SHUTDOWN
• codes::UNKNOWN_ENDPOINT
• codes::UNSUPPORTED
• frame::MAGIC
• frame::MAX_PREAMBLE_LEN
• header::MAX_CURSOR_RECORD_LEN
• header::filter::ONE_SEGMENT
• header::filter::REST
• header::filter::SEPARATOR
• header::limits::MAX_CONTENT_TYPE_BYTES
• header::limits::MAX_ENDPOINT_BYTES
• header::limits::MAX_FILTER_BYTES
• header::limits::MAX_LIST_ITEMS
• header::limits::MAX_MESSAGE_BYTES
• header::limits::MAX_REPORT_LEVELS
• header::limits::MAX_SKIP_DEPTH
• header::limits::MAX_TOPIC_BYTES
• header::limits::MAX_TRACEPARENT_BYTES
• header::limits::MAX_TRACESTATE_BYTES
• header::limits::PRODUCER_BYTES
• varint::MAX
• varint::MAX_ENCODED_LEN