Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/algorealmInc/SwarmNL
/ functions
Functions
233 in github.com/algorealmInc/SwarmNL
⨍
Functions
233
◇
Types & classes
48
↓ 1 callers
Method
with_blacklist
Configure a list of peers to add to blacklist.
swarm-nl/src/setup.rs:65
↓ 1 callers
Method
with_transports
Configure the transports to support.
swarm-nl/src/core/mod.rs:384
Function
bootstrap_config_blacklist_works
()
swarm-nl/src/util.rs:463
Function
bytes_to_shard_image
Deserialize bytes into shard image structure.
swarm-nl/src/util.rs:248
Function
confirmations_with_min_peer_consistency_model
()
swarm-nl/src/core/tests/replication.rs:608
Function
data_forwarding_replication
()
swarm-nl/src/core/tests/sharding.rs:603
Method
default
()
swarm-nl/src/setup.rs:187
Function
default_config_works
()
swarm-nl/src/setup.rs:256
Function
dial_peer_failure_works
()
swarm-nl/src/core/tests/layer_communication.rs:170
Function
dialing_peer_works
()
swarm-nl/src/core/tests/layer_communication.rs:524
Function
echo_for_node1_query_network
()
swarm-nl/src/core/tests/layer_communication.rs:124
Function
echo_for_node1_send_and_receive
()
swarm-nl/src/core/tests/layer_communication.rs:144
Method
eq
(&self, other: &Self)
swarm-nl/src/core/replication.rs:118
Method
fetch_data
(&mut self, key: ByteVector)
examples/sharding/range-based/src/main.rs:76
Method
fetch_data
(&mut self, key: ByteVector)
examples/sharding/hash-based/src/main.rs:86
Method
fetch_data
Important function to implement on shard storage interface to read local shard data and return a response to the requesting node.
swarm-nl/src/core/sharding.rs:36
Method
fetch_data
(&mut self, key: ByteVector)
swarm-nl/src/core/tests/sharding.rs:56
Function
fetching_sharded_data
()
swarm-nl/src/core/tests/sharding.rs:826
Function
file_does_not_exist
()
swarm-nl/src/util.rs:352
Function
file_read_should_panic
()
swarm-nl/src/setup.rs:248
Method
from
(s: &str)
swarm-nl/src/prelude.rs:74
Method
from
(event: ping::Event)
swarm-nl/src/core/mod.rs:91
Method
from_file
Read from a bootstrap config file on disk. # Panics This function will panic if the file is not found at the specified path.
swarm-nl/src/setup.rs:35
Function
generate_keypair_from_protobuf_ecdsa_works
()
swarm-nl/src/setup.rs:425
Function
generate_keypair_from_protobuf_ed25519_works
()
swarm-nl/src/setup.rs:411
Function
generate_keypair_from_protobuf_secp256k1_works
()
swarm-nl/src/setup.rs:439
Function
generate_random_string
Generate a random string of variable length.
swarm-nl/src/util.rs:138
Function
get_network_info_works
()
swarm-nl/src/core/tests/layer_communication.rs:302
Function
gossipsub_blacklist_and_remove_blacklist_works
()
swarm-nl/src/core/tests/layer_communication.rs:355
Function
gossipsub_filter_fn
Event that announces the beginning of the filtering and authentication of the incoming gossip message. It returns a boolean to specify whether the mas
examples/simple-game/src/main.rs:58
Function
gossipsub_filter_fn
Handle gossiping
examples/replication/strong-consistency/src/main.rs:31
Function
gossipsub_filter_fn
Handle gossiping
examples/replication/eventual-consistency/src/main.rs:33
Function
gossipsub_filter_fn
Handle gossiping
examples/replication/peer-cloning/src/main.rs:36
Function
gossipsub_filter_fn
Handle gossiping
examples/http-client/src/main.rs:40
Function
gossipsub_filter_fn
Handle gossiping
examples/ipfs/src/main.rs:43
Function
gossipsub_filter_fn
Handle gossiping
examples/sharding/range-based/src/main.rs:58
Function
gossipsub_filter_fn
Handle gossiping
examples/sharding/hash-based/src/main.rs:59
Function
gossipsub_filter_fn
Handle gossiping
swarm-nl/src/core/tests/sharding.rs:38
Function
gossipsub_filter_fn
Handle gossiping.
swarm-nl/src/core/tests/replication.rs:36
Function
gossipsub_info_works
()
swarm-nl/src/core/tests/layer_communication.rs:382
Function
gossipsub_join_and_exit_network_works
()
swarm-nl/src/core/tests/layer_communication.rs:326
Function
gossipsub_join_exit_itest_works
()
swarm-nl/src/core/tests/layer_communication.rs:720
Function
gossipsub_message_itest_works
()
swarm-nl/src/core/tests/layer_communication.rs:769
Method
handle_async_operations
Handle async operations, which basically involved handling two major data sources: - Streams coming from the application layer. - Events generated by
swarm-nl/src/core/mod.rs:1293
Method
handle_data_confirmation
( &self, mut core: Core, replica_network: String, message_id: String, )
swarm-nl/src/core/replication.rs:388
Method
handle_incoming_repl_data
Handle incoming replicated data. The first element of the incoming data vector contains the name of the replica network.
swarm-nl/src/core/mod.rs:1071
Method
handle_incoming_shard_data
Handle incoming shard data. We will not be doing any internal buffering as the data would be exposed as an event.
swarm-nl/src/core/mod.rs:1109
Method
handle_network_response
Handle the responses coming from the network layer. This is usually as a result of a request from the application layer.
swarm-nl/src/core/mod.rs:1253
Function
join_and_exit_shard_network
()
swarm-nl/src/core/tests/sharding.rs:160
Function
kademlia_get_providers_works
()
swarm-nl/src/core/tests/layer_communication.rs:258
Function
kademlia_get_routing_table_info_works
()
swarm-nl/src/core/tests/layer_communication.rs:281
Function
kademlia_lookup_record_works
()
swarm-nl/src/core/tests/layer_communication.rs:226
Function
kademlia_provider_records_itest_works
()
swarm-nl/src/core/tests/layer_communication.rs:662
Function
kademlia_record_store_itest_works
()
swarm-nl/src/core/tests/layer_communication.rs:600
Function
kademlia_store_records_works
()
swarm-nl/src/core/tests/layer_communication.rs:195
Function
key_pair_is_invalid
()
swarm-nl/src/setup.rs:347
Function
key_type_is_invalid
()
swarm-nl/src/setup.rs:326
Method
locate_shard
Locate the shard corresponding to the given key.
examples/sharding/range-based/src/main.rs:123
Function
main
()
examples/file-sharing-app/src/main.rs:294
Function
main
()
examples/simple-game/src/main.rs:425
Function
main
()
examples/echo-server/src/main.rs:25
Function
main
()
examples/replication/strong-consistency/src/main.rs:200
Function
main
()
examples/replication/eventual-consistency/src/main.rs:216
Function
main
()
examples/replication/peer-cloning/src/main.rs:242
Function
main
()
examples/http-client/src/main.rs:249
Function
main
()
examples/ipfs/src/main.rs:246
Function
main
()
examples/sharding/range-based/src/main.rs:420
Function
main
()
examples/sharding/hash-based/src/main.rs:493
Function
merge_shard_states
Merge two shard network states.
swarm-nl/src/util.rs:232
Function
multi_nodes_confirmations_with_all_consistency_model
()
swarm-nl/src/core/tests/replication.rs:477
Method
network_id
Return the id of the network.
swarm-nl/src/core/mod.rs:389
Method
network_state
Return the state of the shard network.
swarm-nl/src/core/sharding.rs:58
Method
new
Creates a new RangeSharding instance
examples/sharding/range-based/src/main.rs:110
Method
new
Return a new `BootstrapConfig` struct populated by default (empty) values. Must be called first if the config is to be explicitly built without readi
swarm-nl/src/setup.rs:43
Method
new
Generate a new random stream id. Must only be called once.
swarm-nl/src/core/prelude.rs:210
Method
new
Create a new instance of [ReplicaBufferQueue].
swarm-nl/src/core/replication.rs:149
Method
new
Creates a new RangeSharding instance
swarm-nl/src/core/tests/sharding.rs:90
Function
new_config_with_bootnodes_works
()
swarm-nl/src/setup.rs:272
Function
new_config_with_tcp_port_works
()
swarm-nl/src/setup.rs:293
Function
new_config_with_udp_port_works
()
swarm-nl/src/setup.rs:311
Function
new_node_join_and_sync_works
()
swarm-nl/src/core/tests/replication.rs:789
Function
node_custom_behavior_with_network_id_fails
()
swarm-nl/src/core/tests/node_behaviour.rs:144
Function
node_custom_behavior_with_network_id_works
()
swarm-nl/src/core/tests/node_behaviour.rs:121
Function
node_custom_setup_works
()
swarm-nl/src/core/tests/node_behaviour.rs:87
Function
node_default_behavior_works
()
swarm-nl/src/core/tests/node_behaviour.rs:48
Function
node_save_keypair_offline_works_async_std
()
swarm-nl/src/core/tests/node_behaviour.rs:190
Function
node_save_keypair_offline_works_tokio
()
swarm-nl/src/core/tests/node_behaviour.rs:159
Method
partial_cmp
(&self, other: &Self)
swarm-nl/src/core/replication.rs:108
Method
publish_shard_state
Publish the current shard state of the network to the new peer just joining. This will enable the node to have a current view of the network.
swarm-nl/src/core/mod.rs:1050
Method
pull_missing_data
Pull and return missing data requested by a replica node.
swarm-nl/src/core/replication.rs:658
Function
read_ini_file_with_custom_setup_works
()
swarm-nl/src/util.rs:389
Function
read_ini_file_with_default_setup_works
()
swarm-nl/src/util.rs:409
Function
repl_itest_fully_replicate_node
()
swarm-nl/src/core/tests/replication.rs:214
Function
repl_itest_join_and_exit_works
()
swarm-nl/src/core/tests/replication.rs:83
Method
replicate_buffer
Replicate and populate buffer with replica's state.
swarm-nl/src/core/replication.rs:720
Function
rpc_fetch_works
()
swarm-nl/src/core/tests/layer_communication.rs:555
Function
rpc_incoming_message_handler
We need to handle the incoming RPC here What we're going to do is to look in our file system for the file specified in the RPC data and return it's bi
examples/file-sharing-app/src/main.rs:44
Function
rpc_incoming_message_handler
Handle incoming RPC
examples/replication/strong-consistency/src/main.rs:25
Function
rpc_incoming_message_handler
Handle incoming RPC
examples/replication/eventual-consistency/src/main.rs:27
Function
rpc_incoming_message_handler
Handle incoming RPC
examples/replication/peer-cloning/src/main.rs:30
← previous
next →
101–200 of 233, ranked by callers