Enum Operations

pub enum Operations {
    ItemGet(ItemGet),
    ItemSet(ItemSet),
    ItemList(ItemList),
    TablePrepare(TablePrepare),
    TableCommit(TableCommit),
    TableDelete(TableDelete),
    GossipSync(GossipSync),
    GossipFind(GossipFind),
}

All known RPCs.

Variants

ItemGet(ItemGet)

ItemSet(ItemSet)

ItemList(ItemList)

TablePrepare(TablePrepare)

TableCommit(TableCommit)

TableDelete(TableDelete)

GossipSync(GossipSync)

GossipFind(GossipFind)

Implementations

impl Operations

fn name(&self) -> &'static str

Returns the RPC name for debugging purposes.

pub async fn listener( listener: TcpListener, token: CancellationToken, ) -> Result<()>

Runs the RPC listener.

Waits for incoming requests, deserializes them and executes the appropriate action.

Trait Implementations

impl Debug for Operations

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Operations

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<GossipFind> for Operations

fn from(value: GossipFind) -> Self

Converts to this type from the input type.

impl From<GossipSync> for Operations

fn from(value: GossipSync) -> Self

Converts to this type from the input type.

impl From<ItemGet> for Operations

fn from(value: ItemGet) -> Self

Converts to this type from the input type.

impl From<ItemList> for Operations

fn from(value: ItemList) -> Self

Converts to this type from the input type.

impl From<ItemSet> for Operations

fn from(value: ItemSet) -> Self

Converts to this type from the input type.

impl From<TableCommit> for Operations

fn from(value: TableCommit) -> Self

Converts to this type from the input type.

impl From<TableDelete> for Operations

fn from(value: TableDelete) -> Self

Converts to this type from the input type.

impl From<TablePrepare> for Operations

fn from(value: TablePrepare) -> Self

Converts to this type from the input type.

impl Serialize for Operations

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

where __S: Serializer,

Serialize this value into the given Serde serializer.