Enum ClusterRequest 

pub enum ClusterRequest {
    FetchMetadata {
        header: RequestHeader,
        topics: Option<Vec<String>>,
    },
    ProposeMetadata {
        header: RequestHeader,
        command: MetadataCommand,
    },
    Fetch {
        header: RequestHeader,
        partition: PartitionId,
        offset: u64,
        max_bytes: u32,
    },
    Append {
        header: RequestHeader,
        partition: PartitionId,
        records: Vec<u8>,
        required_acks: Acks,
    },
    ReplicaState {
        header: RequestHeader,
        partition: PartitionId,
        log_end_offset: u64,
        high_watermark: u64,
    },
    ElectLeader {
        header: RequestHeader,
        partition: PartitionId,
        preferred_leader: Option<NodeId>,
    },
    Heartbeat {
        header: RequestHeader,
        partitions: Vec<HeartbeatPartition>,
    },
}

Request types for cluster operations

Variants

FetchMetadata

Fetch metadata for topics

Fields

header: RequestHeader

topics: Option<Vec<String>>

ProposeMetadata

Propose a metadata change (forwarded to Raft leader)

Fields

header: RequestHeader

command: MetadataCommand

Fetch

Fetch records from a partition (follower -> leader)

Fields

header: RequestHeader

partition: PartitionId

offset: u64

max_bytes: u32

Append

Append records to a partition (client -> leader -> followers)

Fields

header: RequestHeader

partition: PartitionId

records: Vec<u8>

required_acks: Acks

ReplicaState

Report replica state to leader

Fields

header: RequestHeader

partition: PartitionId

log_end_offset: u64

high_watermark: u64

ElectLeader

Request leader election for a partition

Fields

header: RequestHeader

partition: PartitionId

preferred_leader: Option<NodeId>

Heartbeat

Heartbeat from leader to followers

Fields

header: RequestHeader

partitions: Vec<HeartbeatPartition>

Trait Implementations

impl Clone for ClusterRequest

fn clone(&self) -> ClusterRequest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ClusterRequest

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ClusterRequest

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ClusterRequest

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.