Enum DmsgType 

#[repr(u8)]
pub enum DmsgType {
    Unknown = 0,
    Debug = 1,
    ParseError = 2,
    Req = 3,
    ReqForward = 4,
    Res = 5,
    CryptoHandshake = 6,
    GossipSyn = 7,
    GossipSynReply = 8,
    GossipAck = 9,
    GossipDigestSyn = 10,
    GossipDigestAck = 11,
    GossipDigestAck2 = 12,
    GossipShutdown = 13,
    HandoffChunk = 14,
    FtSearchReq = 15,
    FtSearchRep = 16,
}

DNODE message type identifier.

The numeric values match dmsg_type_t from the reference engine because the discriminator travels on the wire as a decimal.

Variants

Unknown = 0

Unset / unknown type.

Debug = 1

Diagnostic frame (unused on the live wire; kept for parity).

ParseError = 2

Parse-error frame (unused on the live wire; kept for parity).

Req = 3

Datastore request bound for the local DC.

ReqForward = 4

Datastore request to be forwarded across DCs.

Res = 5

Datastore response.

CryptoHandshake = 6

AES key handshake.

GossipSyn = 7

Gossip SYN.

GossipSynReply = 8

Gossip SYN reply.

GossipAck = 9

Gossip ACK.

GossipDigestSyn = 10

Gossip digest SYN.

GossipDigestAck = 11

Gossip digest ACK.

GossipDigestAck2 = 12

Gossip digest ACK round 2.

GossipShutdown = 13

Gossip shutdown notice.

HandoffChunk = 14

Explicit handoff chunk frame.

Carries one chunk of a token-range handoff stream from the previous owner of the range to the new owner. Distinct from the AAE exchange variants so the receiver can route handoff frames to the dedicated handoff coordinator without parsing the payload first.

FtSearchReq = 15

Cluster-wide RediSearch FT.SEARCH request frame.

Sent by the FT.SEARCH coordinator on the node that received the client request to every primary peer covering the index’s key range. The payload encodes a broadcast request (table name, serialised query body, top-K) - see the dynomite-search crate’s query_fsm::BroadcastRequest. Routed by the dispatcher to the dedicated FT.SEARCH coordinator FSM instead of the data-plane stack so the per-peer query runs against the local registry rather than being re-forwarded.

FtSearchRep = 16

Cluster-wide RediSearch FT.SEARCH reply frame.

Returned by every peer that received a Self::FtSearchReq once its local search completed (or the per-peer deadline elapsed). The payload encodes the per-peer top-K hit list plus a timed_out flag the coordinator uses to mark partial results.

Implementations

impl DmsgType

pub fn from_u8(v: u8) -> Option<Self>

Build a type from its on-the-wire integer value.

Examples

use dynomite::proto::dnode::DmsgType;
assert_eq!(DmsgType::from_u8(3), Some(DmsgType::Req));
assert_eq!(DmsgType::from_u8(99), None);

pub const fn as_u8(self) -> u8

Numeric on-the-wire value.

Examples

use dynomite::proto::dnode::DmsgType;
assert_eq!(DmsgType::CryptoHandshake.as_u8(), 6);

Trait Implementations

impl Clone for DmsgType

fn clone(&self) -> DmsgType

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for DmsgType

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for DmsgType

fn default() -> DmsgType

Returns the “default value” for a type.

impl Hash for DmsgType

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for DmsgType

fn eq(&self, other: &DmsgType) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for DmsgType

impl Eq for DmsgType

impl StructuralPartialEq for DmsgType