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 encode(&self) -> Result<Vec<u8>, WireCodecError>

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

impl WireCommand

pub const LIMIT: usize = codec::LIMIT

Trait Implementations

impl Debug for WireCommand

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

Formats the value using the given formatter.

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

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::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::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.