Struct holochain::test_utils::network_simulation::MockNetworkData

source · [−]

pub struct MockNetworkData {
    pub authored: HashMap<Arc<AgentPubKey>, Vec<Arc<DhtOpHash>>>,
    pub op_hash_to_kit: HashMap<Arc<DhtOpHash>, Arc<KitsuneOpHash>>,
    pub op_kit_to_hash: HashMap<Arc<KitsuneOpHash>, Arc<DhtOpHash>>,
    pub agent_hash_to_kit: HashMap<Arc<AgentPubKey>, Arc<KitsuneAgent>>,
    pub agent_kit_to_hash: HashMap<Arc<KitsuneAgent>, Arc<AgentPubKey>>,
    pub agent_to_arc: HashMap<Arc<AgentPubKey>, DhtArc>,
    pub agent_to_info: HashMap<Arc<AgentPubKey>, AgentInfoSigned>,
    pub ops_by_loc: BTreeMap<DhtLocation, Vec<Arc<DhtOpHash>>>,
    pub op_to_loc: HashMap<Arc<DhtOpHash>, DhtLocation>,
    pub ops: HashMap<Arc<DhtOpHash>, DhtOpHashed>,
    pub integrity_uuid: String,
    pub coordinator_uuid: String,
}

Expand description

Data to use to simulate a dht network.

Fields

authored: HashMap<Arc<AgentPubKey>, Vec<Arc<DhtOpHash>>>

The hashes authored by each agent.

op_hash_to_kit: HashMap<Arc<DhtOpHash>, Arc<KitsuneOpHash>>

DhtOpHash -> KitsuneOpHash

op_kit_to_hash: HashMap<Arc<KitsuneOpHash>, Arc<DhtOpHash>>

KitsuneOpHash -> DhtOpHash

agent_hash_to_kit: HashMap<Arc<AgentPubKey>, Arc<KitsuneAgent>>

AgentPubKey -> KitsuneAgent

agent_kit_to_hash: HashMap<Arc<KitsuneAgent>, Arc<AgentPubKey>>

KitsuneAgent -> AgentPubKey

agent_to_arc: HashMap<Arc<AgentPubKey>, DhtArc>

Agent storage arcs.

agent_to_info: HashMap<Arc<AgentPubKey>, AgentInfoSigned>

Agents peer info.

ops_by_loc: BTreeMap<DhtLocation, Vec<Arc<DhtOpHash>>>

Hashes ordered by their basis location.

op_to_loc: HashMap<Arc<DhtOpHash>, DhtLocation>

Hash to basis location.

ops: HashMap<Arc<DhtOpHash>, DhtOpHashed>

The DhtOps

integrity_uuid: String

The uuid for the integrity zome (also for the dna).

coordinator_uuid: String

The uuid for the coordinator zome.

Implementations

source

impl MockNetworkData

source

pub fn num_agents(&self) -> usize

Number of agents in this simulation. This doesn’t include any real agents.

source

pub fn agents(&self) -> impl Iterator<Item = &Arc<AgentPubKey>>

The simulated agents.

source

pub fn coverage(&self) -> f64

The coverage of the simulated dht.

source

pub fn agent_info(&self) -> impl Iterator<Item = &AgentInfoSigned>

The agent info of the simulated agents.

source

pub fn hashes_authority_for(&self, agent: &AgentPubKey) -> Vec<Arc<DhtOpHash>>ⓘNotable traits for Vec<u8, A>`impl<A> Write for Vec<u8, A> where A: Allocator,`

Hashes that an agent is an authority for.

Trait Implementations

source

impl Debug for MockNetworkData

source

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

Formats the value using the given formatter. Read more

source

impl<'de> Deserialize<'de> for MockNetworkData

source

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

Deserialize this value from the given Serde deserializer. Read more

source

impl Serialize for MockNetworkData

source

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

Serialize this value into the given Serde serializer. Read more

source

impl TryFrom<&'_ MockNetworkData> for SerializedBytes

type Error = SerializedBytesError

The type returned in the event of a conversion error.

source

fn try_from(
t: &MockNetworkData
) -> Result<SerializedBytes, SerializedBytesError>

Performs the conversion.

source

impl TryFrom<MockNetworkData> for SerializedBytes

type Error = SerializedBytesError

The type returned in the event of a conversion error.

source

fn try_from(t: MockNetworkData) -> Result<SerializedBytes, SerializedBytesError>

Performs the conversion.

source

impl TryFrom<SerializedBytes> for MockNetworkData

type Error = SerializedBytesError

The type returned in the event of a conversion error.

source

fn try_from(
sb: SerializedBytes
) -> Result<MockNetworkData, SerializedBytesError>

Performs the conversion.

Auto Trait Implementations

impl RefUnwindSafe for MockNetworkData

impl Send for MockNetworkData

impl Sync for MockNetworkData

impl Unpin for MockNetworkData

impl UnwindSafe for MockNetworkData

Blanket Implementations

source

impl<T> Any for T where
T: 'static + ?Sized,

source

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Any for T where
T: Any + ?Sized,

fn type_id_compat(&self) -> TypeId

TODO: once 1.33.0 is the minimum supported compiler version, remove Any::type_id_compat and use StdAny::type_id instead. https://github.com/rust-lang/rust/issues/27745 Read more

impl<T> ArchivePointee for T

type ArchivedMetadata = ()

The archived version of the pointer metadata for this type.

fn pointer_metadata(
&<T as ArchivePointee>::ArchivedMetadata
) -> <T as Pointee>::Metadata

Converts some archived metadata to the pointer metadata for itself.

source

impl<T> Borrow<T> for T where
T: ?Sized,

const: unstable · source

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

source

impl<T> BorrowMut<T> for T where
T: ?Sized,

const: unstable · source

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<F, W, T, D> Deserialize<With<T, W>, D> for F where
 W: DeserializeWith<F, T, D>,
 D: Fallible + ?Sized,
 F: ?Sized,

fn deserialize(
&self,
deserializer: &mut D
) -> Result<With<T, W>, <D as Fallible>::Error>

Deserializes using the given deserializer

source

impl<T> From<T> for T

const: unstable · source

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> FutureExt for T

fn with_context(self, otel_cx: Context) -> WithContext<Self>

Attaches the provided Context to this type, returning a WithContext wrapper. Read more

fn with_current_context(self) -> WithContext<Self>

Attaches the current Context to this type, returning a WithContext wrapper. Read more

source

impl<T> Instrument for T

source

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

source

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

source

impl<T> Instrument for T

source

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

source

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

source

impl<T, U> Into for T where
U: From<T>,

const: unstable · source

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T> Pointable for T

const ALIGN: usize = mem::align_of::()

The alignment of pointer.

type Init = T

The type for initializers.

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more

impl<T> Pointee for T

type Metadata = ()

The type for metadata in pointers and references to Self.

source

impl<T> Same<T> for T

type Output = T

Should always be Self

source

impl<T, U> TryFrom for T where
U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

const: unstable · source

fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>

Performs the conversion.

source

impl<T, U> TryInto for T where
U: TryFrom<T>,

type Error = >::Error

The type returned in the event of a conversion error.

const: unstable · source

fn try_into(self) -> Result<U, >::Error>

Performs the conversion.

impl<V, T> VZip<V> for T where
V: MultiLane<T>,

fn vzip(self) -> V

source

impl<T> WithSubscriber for T

source

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

source

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more

source

impl<T> WithSubscriber for T

source

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

source

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more

source

Struct holochain::test_utils::network_simulation::MockNetworkData

Fields

Implementations

impl MockNetworkData

pub fn num_agents(&self) -> usize

pub fn agents(&self) -> impl Iterator<Item = &Arc<AgentPubKey>>

pub fn coverage(&self) -> f64

pub fn agent_info(&self) -> impl Iterator<Item = &AgentInfoSigned>

pub fn hashes_authority_for(&self, agent: &AgentPubKey) -> Vec<Arc<DhtOpHash>>ⓘNotable traits for Vec<u8, A>impl<A> Write for Vec<u8, A> where A: Allocator,

Trait Implementations

impl Debug for MockNetworkData

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

impl<'de> Deserialize<'de> for MockNetworkData

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

impl Serialize for MockNetworkData

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

impl TryFrom<&'_ MockNetworkData> for SerializedBytes

type Error = SerializedBytesError

fn try_from( t: &MockNetworkData) -> Result<SerializedBytes, SerializedBytesError>

impl TryFrom<MockNetworkData> for SerializedBytes

type Error = SerializedBytesError

fn try_from(t: MockNetworkData) -> Result<SerializedBytes, SerializedBytesError>

impl TryFrom<SerializedBytes> for MockNetworkData

type Error = SerializedBytesError

fn try_from( sb: SerializedBytes) -> Result<MockNetworkData, SerializedBytesError>

Auto Trait Implementations

impl RefUnwindSafe for MockNetworkData

impl Send for MockNetworkData

impl Sync for MockNetworkData

impl Unpin for MockNetworkData

impl UnwindSafe for MockNetworkData

Blanket Implementations

impl<T> Any for T where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Any for T where T: Any + ?Sized,

fn type_id_compat(&self) -> TypeId

impl<T> ArchivePointee for T

type ArchivedMetadata = ()

fn pointer_metadata( &<T as ArchivePointee>::ArchivedMetadata) -> <T as Pointee>::Metadata

impl<T> Borrow<T> for T where T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for T where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<F, W, T, D> Deserialize<With<T, W>, D> for F where W: DeserializeWith<F, T, D>, D: Fallible + ?Sized, F: ?Sized,

fn deserialize( &self, deserializer: &mut D) -> Result<With<T, W>, <D as Fallible>::Error>

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FutureExt for T

fn with_context(self, otel_cx: Context) -> WithContext<Self>

fn with_current_context(self) -> WithContext<Self>

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for T where U: From<T>,

fn into(self) -> U

impl<T> Pointable for T

const ALIGN: usize = mem::align_of::()

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T> Pointee for T

type Metadata = ()

impl<T> Same<T> for T

type Output = T

impl<T, U> TryFrom<U> for T where U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for T where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for T where V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

pub fn hashes_authority_for(&self, agent: &AgentPubKey) -> Vec<Arc<DhtOpHash>>ⓘNotable traits for Vec<u8, A>`impl<A> Write for Vec<u8, A> where A: Allocator,`

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

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

fn try_from(
t: &MockNetworkData
) -> Result<SerializedBytes, SerializedBytesError>

fn try_from(
sb: SerializedBytes
) -> Result<MockNetworkData, SerializedBytesError>

impl<T> Any for T where
T: 'static + ?Sized,

impl<T> Any for T where
T: Any + ?Sized,

fn pointer_metadata(
&<T as ArchivePointee>::ArchivedMetadata
) -> <T as Pointee>::Metadata

impl<T> Borrow<T> for T where
T: ?Sized,

impl<T> BorrowMut<T> for T where
T: ?Sized,

impl<F, W, T, D> Deserialize<With<T, W>, D> for F where
W: DeserializeWith<F, T, D>,
D: Fallible + ?Sized,
F: ?Sized,

fn deserialize(
&self,
deserializer: &mut D
) -> Result<With<T, W>, <D as Fallible>::Error>

impl<T, U> Into<U> for T where
U: From<T>,

impl<T, U> TryFrom<U> for T where
U: Into<T>,

impl<T, U> TryInto<U> for T where
U: TryFrom<T>,

impl<V, T> VZip<V> for T where
V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,

impl<T> DeserializeOwned for T where
T: for<'de> Deserialize<'de>,