liminal_bus_protocol/
lib.rs

1pub mod backpressure;
2pub mod causal;
3pub mod codec;
4pub mod envelope;
5pub mod error;
6pub mod frame;
7pub mod handshake;
8pub mod lifecycle;
9pub mod multiplex;
10pub mod schema;
11pub mod version;
12pub mod worker_refusal;
13
14#[cfg(test)]
15mod worker_refusal_tests;
16
17pub use backpressure::{AcceptPayload, DeferPayload, PressureState, RejectPayload, StreamPressure};
18pub use causal::{CausalContext, MessageId, extract_causal_context};
19pub use codec::{decode, encode, encoded_len};
20pub use envelope::{MessageEnvelope, SchemaId};
21pub use error::{PASS_EXPIRED_CODE, ProtocolError};
22pub use frame::{
23    CONVERSATION_REPLY_REQUESTED_FLAG, DELIVER_MESSAGE_ID_FLAG, DELIVER_MESSAGE_ID_VERSION,
24    DELIVER_POSITION_FLAG, DISCONNECT_REASON_BODY_MAX, DISCONNECT_REASON_BODY_VERSION,
25    DISCONNECT_REASON_NAME_MAX, DeliveredId, DisconnectReason, Frame, FrameHeader, FrameType,
26    INBOX_ACK_VERSION, LINK_MACHINE_LEN, LinkEnd, LinkOffer, LinkOpenOutcome,
27    PUBLISH_ACK_BOOT_FLAG, PUBLISH_ACK_BOOT_VERSION, PUBLISH_ACK_POSITION_VERSION,
28    PUBLISH_DELIVERED_FLAG, PUBLISH_DURABLE_POSITION_FLAG, PUBLISH_IDEMPOTENCY_KEY_FLAG,
29    REVOCATION_CLOSE_VERSION, WorkerActivityDescriptor, WorkerRegisterOutcome, WorkerRegistration,
30    validate_stream,
31};
32pub use multiplex::{StreamAllocator, StreamId, StreamState, StreamTable};
33pub use schema::{negotiate_schema, subscribe_error_frame};
34pub use version::{ProtocolVersion, negotiate_version};
35pub use worker_refusal::{
36    PUSH_REPLY_REFUSED_FLAG, WORKER_REFUSAL_WORDS_MAX, WorkerRefusal, WorkerRefusalCode,
37};
liminal_bus_protocol/lib.rs

liminal_bus_protocol/
lib.rs
