Enum RaftCommand 

pub enum RaftCommand {
    Upsert {
        conn_id: u64,
        txid: u64,
        client_addr: [u8; 16],
        nat_entry: (u16, u16),
        assigned_pod: u32,
    },
    Delete {
        conn_id: u64,
    },
    Cleanup {
        before_timestamp: u64,
    },
    Noop,
}

Raft commands for distributed state machine

Variants

Upsert

Insert or update a connection record

Fields

conn_id: u64

txid: u64

client_addr: [u8; 16]

nat_entry: (u16, u16)

assigned_pod: u32

Delete

Delete a connection record

Fields

conn_id: u64

Cleanup

Cleanup expired connections (TTL based)

Fields

before_timestamp: u64

Noop

No-op for leader election

Trait Implementations

impl Archive for RaftCommand

where u64: Archive, [u8; 16]: Archive, (u16, u16): Archive, u32: Archive,

type Archived = ArchivedRaftCommand

The archived representation of this type.

type Resolver = RaftCommandResolver

The resolver for this type. It must contain all the additional information from serializing needed to make the archived type from the normal type.

fn resolve( &self, resolver: <Self as Archive>::Resolver, out: Place<<Self as Archive>::Archived>, )

Creates the archived version of this value at the given position and writes it to the given output.

const COPY_OPTIMIZATION: CopyOptimization<Self> = _

An optimization flag that allows the bytes of this type to be copied directly to a writer instead of calling serialize.

impl Clone for RaftCommand

fn clone(&self) -> RaftCommand

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RaftCommand

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

Formats the value using the given formatter.

impl<__D: Fallible + ?Sized> Deserialize<RaftCommand, __D> for Archived<RaftCommand>

where u64: Archive, <u64 as Archive>::Archived: Deserialize<u64, __D>, [u8; 16]: Archive, <[u8; 16] as Archive>::Archived: Deserialize<[u8; 16], __D>, (u16, u16): Archive, <(u16, u16) as Archive>::Archived: Deserialize<(u16, u16), __D>, u32: Archive, <u32 as Archive>::Archived: Deserialize<u32, __D>,

fn deserialize( &self, deserializer: &mut __D, ) -> Result<RaftCommand, <__D as Fallible>::Error>

Deserializes using the given deserializer

impl PartialEq<ArchivedRaftCommand> for RaftCommand

where u64: Archive, [u8; 16]: Archive, (u16, u16): Archive, u32: Archive, <u64 as Archive>::Archived: PartialEq<u64>, <[u8; 16] as Archive>::Archived: PartialEq<[u8; 16]>, <(u16, u16) as Archive>::Archived: PartialEq<(u16, u16)>, <u32 as Archive>::Archived: PartialEq<u32>,

fn eq(&self, other: &ArchivedRaftCommand) -> 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 PartialEq<RaftCommand> for ArchivedRaftCommand

where u64: Archive, [u8; 16]: Archive, (u16, u16): Archive, u32: Archive, <u64 as Archive>::Archived: PartialEq<u64>, <[u8; 16] as Archive>::Archived: PartialEq<[u8; 16]>, <(u16, u16) as Archive>::Archived: PartialEq<(u16, u16)>, <u32 as Archive>::Archived: PartialEq<u32>,

fn eq(&self, other: &RaftCommand) -> 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 PartialEq for RaftCommand

fn eq(&self, other: &RaftCommand) -> 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<__S: Fallible + ?Sized> Serialize<__S> for RaftCommand

where u64: Serialize<__S>, [u8; 16]: Serialize<__S>, (u16, u16): Serialize<__S>, u32: Serialize<__S>,

fn serialize( &self, serializer: &mut __S, ) -> Result<<Self as Archive>::Resolver, <__S as Fallible>::Error>

Writes the dependencies for the object and returns a resolver that can create the archived type.

impl StructuralPartialEq for RaftCommand