Enum EntryOperation 

pub enum EntryOperation {
    Overwrite(Entry),
    Extend(Entry),
    Touch(Entry),
    JoinSubring(String, Did),
    Tombstone(Entry),
}

Operations supported by a DHT storage entry.

Variants

Overwrite(Entry)

Create or update an Entry.

Extend(Entry)

Extend data to a Data kind Entry. This operation will create an Entry if it does not exist.

Touch(Entry)

Extend data to a Data kind Entry uniquely. If any element is already existed, move it to the end of the data vector. This operation will create an Entry if it does not exist.

JoinSubring(String, Did)

Join subring.

Tombstone(Entry)

Tombstone observed relay-message payloads in a two-phase set.

The payload identifies the relay-message carrier and the values to remove. If CRDT dots are present, those dots are the remove witnesses; otherwise the receiver tombstones currently observed dots with matching payload bytes.

Implementations

impl EntryOperation

pub fn stamped(self, actor: Did) -> Result<Self>

Return this operation with CRDT versions assigned at the operation boundary.

Existing CRDT witnesses are preserved so forwarded operations keep the origin’s dot/version instead of being reissued by every routing hop.

pub fn did(&self) -> Result<Did>

Extract the did of target Entry.

pub fn kind(&self) -> EntryKind

Extract the kind of target Entry.

pub fn gen_default_entry(self) -> Result<Entry>

Generate a target Entry when it is not existed.

Trait Implementations

impl Clone for EntryOperation

fn clone(&self) -> EntryOperation

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EntryOperation

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for EntryOperation

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for EntryOperation

impl HandleMsg<EntryOperation> for MessageHandler

fn handle<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ctx: &'life1 MessagePayload, msg: &'life2 EntryOperation, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Message handler.

impl PartialEq for EntryOperation

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

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for EntryOperation