Struct kitsune_p2p_dht::region::RegionData

pub struct RegionData {
    pub hash: RegionHash,
    pub size: u32,
    pub count: u32,
}

The pertinent data that we care about for each Region. This is what gets sent over gossip so that nodes can discover which Regions are different between them.

The size and count data can also act as heuristics to help us fine-tune the gossip algorithm, although currently they are unused (except for the purpose of disambiguation in the rare case of an XOR hash collision).

Fields

hash: RegionHash

The XOR of hashes of all Ops in this Region

size: u32

The total size of Op data contained in this Region

count: u32

The number of Ops in this Region.

Trait Implementations

impl AccessOpStore<OpData, RegionData> for TestNode

fn query_op_data(&self, region: &RegionCoords) -> Vec<Op>

Query the actual ops inside a region

fn query_region_data(&self, region: &RegionCoords) -> RegionData

Query the RegionData of a region, including the hash of all ops, size, and count

fn fetch_region_set(
    &self,
    coords: RegionCoordSetLtcs
) -> MustBoxFuture<'_, Result<RegionSetLtcs, ()>>

Fetch a set of Regions (the coords and the data) given the set of coords

fn integrate_ops<Ops: Clone + Iterator<Item = Op>>(&mut self, ops: Ops)

Integrate incoming ops, updating the necessary stores

fn topo(&self) -> &Topology

Get the Topology associated with this store

fn gossip_params(&self) -> GossipParams

Get the GossipParams associated with this store

fn integrate_op(&mut self, op: Arc<O>)

Integrate a single op

fn region_set(&self, arq_set: ArqBoundsSet, now: TimeQuantum) -> RegionSet<D>

Get the RegionSet for this node, suitable for gossiping

impl Add<RegionData> for RegionData

type Output = RegionData

The resulting type after applying the + operator.

fn add(self, other: Self) -> Self::Output

Performs the + operation.

impl AddAssign<RegionData> for RegionData

fn add_assign(&mut self, other: Self)

Performs the += operation.

impl Clone for RegionData

fn clone(&self) -> RegionData

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for RegionData

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RegionData

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

Deserialize this value from the given Serde deserializer.

impl From<RegionData> for RegionDataCompact

fn from(d: RegionData) -> Self

Converts to this type from the input type.

impl From<RegionDataCompact> for RegionData

fn from(RegionDataCompact: RegionDataCompact) -> Self

Converts to this type from the input type.

impl OpRegion<RegionData> for OpData

fn loc(&self) -> Loc

The op’s Location

fn timestamp(&self) -> Timestamp

The op’s Timestamp

fn region_data(&self) -> RegionData

The RegionData that would be produced if this op were the only op in the region. The sum of these produces the RegionData for the whole region.

fn bound(timestamp: Timestamp, loc: Loc) -> Self

Create an Op with arbitrary data but that has the given timestamp and location. Used for bounded range queries based on the PartialOrd impl of the op.

fn coords(&self, topo: &Topology) -> SpacetimeQuantumCoords

The quantized space and time coordinates, based on the location and timestamp.

impl PartialEq<RegionData> for RegionData

fn eq(&self, other: &RegionData) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl RegionDataConstraints for RegionData

fn count(&self) -> u32

The number of ops in this region

fn size(&self) -> u32

The size of all ops in this region

impl Serialize for RegionData

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

Serialize this value into the given Serde serializer.

impl Sub<RegionData> for RegionData

type Output = RegionData

The resulting type after applying the - operator.

fn sub(self, other: Self) -> Self::Output

Performs the - operation.

impl SubAssign<RegionData> for RegionData

fn sub_assign(&mut self, other: Self)

Performs the -= operation.

impl Sum<RegionData> for RegionData

fn sum<I: Iterator<Item = Self>>(iter: I) -> Self

Method which takes an iterator and generates Self from the elements by “summing up” the items.

impl Zero for RegionData

fn zero() -> Self

Returns the additive identity element of Self, 0.

fn is_zero(&self) -> bool

Returns true if self is equal to the additive identity.

fn set_zero(&mut self)

Sets self to the additive identity element of Self, 0.

impl Eq for RegionData

impl StructuralEq for RegionData

impl StructuralPartialEq for RegionData