Push [`StreamId`]s into buffer. Returns `false` if the buffer is full and request cannot be stored.

Perform an atomic `send` and `recieve` to and from the network layer. This function is atomic and blocks until the result of the request is returned f

Join a replica network and get up to speed with the current network data state. If the consistency model is eventual, the node's buffer will almost i

Configure the TCP/IP port. Note: Port must range between [`MIN_PORT`] and [`MAX_PORT`].

Send data to replica nodes.

Create a determininstic node.

Generate a Cryptographic Keypair from a protobuf format. This will override any already set keypair. # Panics This function will panic if the `u8`

Configure the UDP port. Note: Port must range between [`MIN_PORT`] and [`MAX_PORT`]

Return the next event in the network event queue.

Build the [`Core`] data structure. Handles the configuration of the libp2p Swarm structure and the selected transport protocols, behaviours and node

Used to create a detereministic node.

Join a shard network.

Consume data in replication buffer.

Generate a new random stream id, using the current as reference.

Explicitly retrieve the reponse to a request sent to the network layer. This function is decoupled from the [`Core::send_to_network()`] method so as t

Send data to the network layer and recieve a unique `StreamId` to track the request. If the internal stream buffer is full, `None` will be returned.

Configure available bootnodes.

Append an item to the queue.

Remove a [`StreamId`] from the buffer.

Create a determininstic node

Get unix timestamp as string.

Configure the RPC protocol for the network.

Configure the `Gossipsub` protocol for the network. # Panics This function panics if `Gossipsub` cannot be configured properly.

Configure the `Replication` protocol for the network.

Return the node's `PeerId`.

Set up a default node helper

Used to create a node to peer with node_1.

Send data to peers in the appropriate logical shard. It returns the data if the node is a member of the shard after replicating it to fellow nodes in

Return an iterator to the buffered network layer events and consume them.

Pop the front (earliest data) from the queue

Push a new [ReplBufferData] item into the buffer.

Return the configured [`ConsistencyModel`] for data synchronization.

Generate a Cryptographic Keypair for node identity creation and message signing. An RSA keypair cannot be generated on-the-fly. It has to be generate

Return a node's cryptographic keypair.

Read an INI file containing bootstrap config information.

Sample network event for testing.

Serialize keypair to protobuf format and write to config file on disk. This could be useful for saving a keypair for future use when going offline. I

Explicitly configure the network (protocol) id. Note that it must be of the format "/protocol-name/version" otherwise it will default to "/swarmnl/1.

Utility function to append content to a file.

Helper to clean up temp file

Fetch data from the shard network. It returns `None` if the node is a memnber of the shard with the data, meaning the node should read it locally.

Return the inner list we're keeping track of.

Configure the IP address to listen on. If none is specified, the default value is `Ipv4Addr::new(0, 0, 0, 0)`. See: [`DEFAULT_IP_ADDRESS`].

Remove an item from the top of the queue.

Clone a replica node's current buffer image. This is necessary in case of joining a replica network with a strong consistency model.

#[cfg(feature = "first-node")]

#[cfg(feature = "first-node")]

#[cfg(feature = "first-node")]

#[cfg(feature = "first-node")]

#[cfg(feature = "first-node")]

Setup a node using default config

Configure how long to keep a connection alive (in seconds) once it is idling.

Configure the `Sharding` protocol for the network.

Write value into config file.

Return the configured bootnodes for the network.

Used to test saving keypair to file

Helper to create an INI file without a keypair and a valid range for ports.

Exit a shard network.

Handle the arrival of a gossip message.

Setup the necessary preliminaries for the sharding protocol

Leave a replica network. The messages on the internal replica queue are not discarded so as to aid speedy recorvery in case of reconnection.

Locate the shard corresponding to the given key.

Locate the shard corresponding to the given key.

Helper function to populate a queue.

Return the number of replica peers in a network, with the node exclusive.

Parse string into a hashmap.

Parse string into a vector.

Synchronize the data in the buffer queue using eventual consistency.

Unmarshall data recieved as RPC during the execution of the eventual consistency algorithm to fill in missing messages in the node's buffer.

Return the `PeerId`'s of nodes that are to be blacklisted.

Convert a [ByteVector] to a [StringVector].

Helper to create an INI file with keypair

Drain the contents of the queue.

helper to generate RSA keypair files commands taken from https://docs.rs/libp2p-identity/0.2.8/libp2p_identity/struct.Keypair.html#example-generating-

Compute a simple hash for the key.

Initialize a replica networks data buffer. This occurs immediately after joining a new network.

Return the configured ports in a tuple i.e (TCP Port, UDP port).

Reads a file's content from the working directory.

Run node 1.

Run node 1

Run node 2.

Run node 2

Setup first node using default config.

Create a determininstic node

Create a determininstic node

Create a determininstic node

Create a determininstic node

Create a determininstic node

Create a determininstic node

Create a determininstic node

Used to create a detereministic node 1.

Used to create a detereministic node 1.

Setup node 2.

Setup node 2.

Marshall the shard network image into a [ByteVector].

Convert a peer ID string to [`PeerId`].