Module msg 

Message model: the in-memory shape every request and response takes inside the engine, plus the queues, indices, and per-DC response managers that thread them through the dispatcher.

This module exposes the data layer; the connection-coupled lifecycle (recv/send, timeout queues, peer forwarding) ships in Stage 9 once the connection state machine is in place. Helpers that already have a clean data-only definition (error response construction, fragment bookkeeping, quorum decisions) live here.

Examples

use dynomite::msg::{Msg, MsgQueue, MsgType, ResponseMgr};

let mut q = MsgQueue::new();
q.push_back(Msg::new(1, MsgType::ReqRedisGet, true));

let req = q.front().unwrap();
let mgr = ResponseMgr::new(req, 1, None);
assert_eq!(mgr.quorum_responses(), 1);

Re-exports

pub use self::index::MsgIndex;

pub use self::keypos::ArgPos;

pub use self::keypos::KeyPos;

pub use self::message::ConnId;

pub use self::message::Msg;

pub use self::message::MsgFlags;

pub use self::message::MsgParseResult;

pub use self::message::MsgRouting;

pub use self::msg_type::MsgType;

pub use self::queue::MsgQueue;

pub use self::response_mgr::QuorumOutcome;

pub use self::response_mgr::ResponseMgr;

pub use self::response_mgr::MAX_REPLICAS_PER_DC;

Modules

index

Message-id to message lookup.

keypos

Per-token position records collected by the protocol parsers.

message

In-memory representation of a single Dynomite message.

msg_type

Message type discriminant.

queue

Owning queue of Msg values.

request

Request lifecycle helpers.

response

Response lifecycle helpers.

response_mgr

Per-DC response aggregation and quorum decisions.

Enums

ConsistencyLevel

Cluster consistency level applied to a single message.

DynErrorCode

Dynomite-side error code carried in a message envelope.

Functions

is_read_repairs_enabled

True when read repairs are enabled cluster-wide.

set_read_repairs_enabled

Configure whether read repairs are globally enabled.