Enum WireCommand 

pub enum WireCommand {
    Prepare {
        invocation: u64,
        operation: String,
        payload: Vec<u8>,
    },
    Initialize {
        invocation: u64,
        context: [u8; 32],
    },
    Attempt {
        invocation: u64,
        context: [u8; 32],
        values: Vec<CallValue>,
    },
    Finalize {
        invocation: u64,
    },
    StreamAttempt {
        invocation: u64,
        epoch: u64,
        context: [u8; 32],
        values: Vec<CallValue>,
    },
    StreamSend {
        invocation: u64,
        epoch: u64,
        payload: Vec<u8>,
    },
    StreamFinish {
        invocation: u64,
        epoch: u64,
    },
    StreamReceive {
        invocation: u64,
        epoch: u64,
    },
    PrepareGrpc {
        invocation: u64,
        operation: String,
        payload: Vec<u8>,
    },
}

Variants

Prepare

Fields

invocation: u64

operation: String

payload: Vec<u8>

Initialize

Fields

invocation: u64

context: [u8; 32]

Attempt

Fields

invocation: u64

context: [u8; 32]

values: Vec<CallValue>

Finalize

Fields

invocation: u64

StreamAttempt

Fields

invocation: u64

epoch: u64

context: [u8; 32]

values: Vec<CallValue>

StreamSend

Fields

invocation: u64

epoch: u64

payload: Vec<u8>

StreamFinish

Fields

invocation: u64

epoch: u64

StreamReceive

Fields

invocation: u64

epoch: u64

PrepareGrpc

Fields

invocation: u64

operation: String

payload: Vec<u8>

Implementations

impl WireCommand

pub fn prepare_encoded_len( invocation: u64, operation: &str, payload: usize, ) -> Result<usize, WireCodecError>

Counts the versioned Prepare envelope without encoding or allocating its payload.

pub fn encode(&self) -> Result<Vec<u8>, WireCodecError>

pub fn decode(bytes: &[u8]) -> Result<WireCommand, WireCodecError>

impl WireCommand

pub const LIMIT: usize = codec::LIMIT

Trait Implementations

impl Debug for WireCommand

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for WireCommand

fn deserialize<__D>( __deserializer: __D, ) -> Result<WireCommand, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for WireCommand

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

where __S: Serializer,

Serialize this value into the given Serde serializer.