Enum NetworkPacket 

pub enum NetworkPacket {
    Handshake {
        node_id: String,
        address: String,
        token: String,
    },
    Close,
    ReducerCall {
        module_name: String,
        reducer_name: String,
        input: IntersticeValue,
    },
    QueryCall {
        request_id: String,
        module_name: String,
        query_name: String,
        input: IntersticeValue,
    },
    QueryResponse {
        request_id: String,
        result: IntersticeValue,
    },
    RequestSubscription(RequestSubscription),
    RequestUnsubscription(RequestSubscription),
    RequestTableSync {
        module_name: String,
        table_name: String,
    },
    TableSyncResponse {
        module_name: String,
        table_name: String,
        rows: Vec<Row>,
    },
    TableEvent(TableEventInstance),
    ModuleEvent(ModuleEventInstance),
    SchemaRequest {
        request_id: String,
        node_name: String,
    },
    SchemaResponse {
        request_id: String,
        schema: NodeSchema,
    },
    Error(String),
}

Variants

Handshake

Fields

node_id: String

address: String

token: String

Close

ReducerCall

Fields

module_name: String

reducer_name: String

input: IntersticeValue

QueryCall

Fields

request_id: String

module_name: String

query_name: String

input: IntersticeValue

QueryResponse

Fields

request_id: String

result: IntersticeValue

RequestSubscription(RequestSubscription)

RequestUnsubscription(RequestSubscription)

RequestTableSync

Fields

module_name: String

table_name: String

TableSyncResponse

Fields

module_name: String

table_name: String

rows: Vec<Row>

TableEvent(TableEventInstance)

ModuleEvent(ModuleEventInstance)

SchemaRequest

Fields

request_id: String

node_name: String

SchemaResponse

Fields

request_id: String

schema: NodeSchema

Error(String)

Trait Implementations

impl Debug for NetworkPacket

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for NetworkPacket

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for NetworkPacket

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

where __S: Serializer,

Serialize this value into the given Serde serializer.