MCPcopy Create free account

hub / github.com/datrs/hyperspace-rs / functions

Functions128 in github.com/datrs/hyperspace-rs

⨍ Functions 128◇ Types & classes 29
↓ 36 callersMethodlock
(&'a self)
server/src/rpc/session.rs:98
↓ 20 callersMethodlen
(&self)
client/src/session.rs:130
↓ 16 callersMethodread
(&self)
client/src/session.rs:142
↓ 14 callersMethodget
(&'a mut self, seq: u64)
client/src/session.rs:162
↓ 7 callersMethoditer
(&self)
corestore/src/feed_map.rs:52
↓ 5 callersMethodget_by_key
Get a feed by its public key
corestore/src/corestore.rs:63
↓ 4 callersMethodappend
(&mut self, blocks: Vec<Vec<u8>>)
client/src/session.rs:146
↓ 4 callersMethodinsert
(&mut self, value: V)
client/src/freemap.rs:40
↓ 4 callersMethodopen
(&mut self)
client/src/session.rs:210
↓ 4 callersFunctionreplicate_corestore
Replicate all feeds in a corestore with peers
corestore/src/replicate.rs:7
↓ 3 callersMethodadd_stream
Add a new connection to the replicator
replicator/src/lib.rs:80
↓ 3 callersFunctionget
(mut core: RemoteHypercore, seq: u64)
client/src/stream.rs:17
↓ 3 callersMethodget_by_name
(&self, key: &K)
client/src/freemap.rs:105
↓ 3 callersFunctionget_future
(core: RemoteHypercore, seq: u64)
client/src/stream.rs:43
↓ 3 callersFunctionsocket_path
(socket_name: Option<T>)
common/src/lib.rs:11
↓ 3 callersMethodsubscribe
(&mut self)
client/src/session.rs:202
↓ 3 callersMethodsubscribe
Subscribe to events from this corestore
corestore/src/corestore.rs:58
↓ 2 callersMethodadd_feed
Add a feed to the replicator
replicator/src/lib.rs:57
↓ 2 callersMethodadd_io
(&mut self, reader: R, writer: W, is_initiator: bool)
replicator/src/lib.rs:88
↓ 2 callersFunctionbad_id
()
server/src/rpc/session.rs:42
↓ 2 callersMethodemit
(&mut self, event: HypercoreEvent)
client/src/session.rs:289
↓ 2 callersMethodemit
(&self, event: ReplicatorEvent)
replicator/src/lib.rs:66
↓ 2 callersFunctionexit
(message: T)
client/src/bin.rs:58
↓ 2 callersMethodfeed_path
(&self, dkey: &Key)
corestore/src/corestore.rs:279
↓ 2 callersMethodfeed_storage
(&self, dkey: &Key, name: &str)
corestore/src/corestore.rs:288
↓ 2 callersMethodfeeds
Iterate over all feeds. Note: A lock on the corestore is kept until the iterator is dropped, so don't use this across `await`s. Example: ``` # #[asy
corestore/src/corestore.rs:100
↓ 2 callersFunctiongenerate_key
()
corestore/src/corestore.rs:348
↓ 2 callersMethodgenerate_key_pair
( &self, name: Option<Name>, )
corestore/src/corestore.rs:325
↓ 2 callersMethodget
(&self, id: u64)
client/src/freemap.rs:99
↓ 2 callersMethodget_by_name
Get or create a writable feed by name
corestore/src/corestore.rs:68
↓ 2 callersMethodinsert_with_name
(&mut self, value: V, name: K)
client/src/freemap.rs:50
↓ 2 callersMethodname_storage
(&self, dkey: &Key)
corestore/src/corestore.rs:294
↓ 2 callersMethodon_open
(&mut self)
replicator/src/peer.rs:179
↓ 2 callersMethodopen
Open a corestore from disk
corestore/src/corestore.rs:47
↓ 2 callersMethodopen_feed
(&mut self, key: Option<Key>, name: Option<Name>)
corestore/src/corestore.rs:223
↓ 2 callersFunctionrandom_access_disk
TODO: Make this a callback (for e.g. inmemory).
corestore/src/corestore.rs:356
↓ 2 callersMethodrun_peer
(&mut self, proto: Protocol<IO>)
replicator/src/lib.rs:115
↓ 2 callersMethodsend_have
(&mut self, start: u64, length: Option<u64>)
replicator/src/peer.rs:146
↓ 2 callersMethodset_id
(&mut self, id: u64)
client/src/session.rs:122
↓ 2 callersMethodset_name
(&mut self, id: u64, key: K)
client/src/freemap.rs:56
↓ 2 callersMethodsubscribe
Subscribe to events on the replicator
replicator/src/lib.rs:73
↓ 1 callersFunctionaccept
(path: P, state: S, mut onconnection: Cb)
server/src/rpc/socket.rs:7
↓ 1 callersMethodadd_downloaded
(&mut self, blocks: u64, bytes: u64)
replicator/src/peer.rs:84
↓ 1 callersMethodadd_peer
(&mut self, id: RemotePublicKey, channel: Channel)
replicator/src/peer.rs:31
↓ 1 callersMethodadd_uploaded
(&mut self, blocks: u64, bytes: u64)
replicator/src/peer.rs:88
↓ 1 callersFunctionasync_main
(opts: Opts)
client/src/bin.rs:72
↓ 1 callersFunctionasync_main
()
corestore/examples/demo.rs:39
↓ 1 callersFunctionasync_main
(opts: Opts)
server/src/bin.rs:11
↓ 1 callersMethodconfigure
( &mut self, _request: ConfigureNetworkRequest, )
server/src/rpc/session.rs:181
↓ 1 callersFunctionderive_key
(master_key: &[u8], ns: &[u8], name: &[u8])
corestore/src/corestore.rs:341
↓ 1 callersMethodderive_secret
(&self, namespace: &Name, name: &Name)
corestore/src/corestore.rs:321
↓ 1 callersMethodemit
(&mut self, event: Event)
corestore/src/corestore.rs:169
↓ 1 callersMethodget
(&mut self, req: GetRequest)
server/src/rpc/session.rs:55
↓ 1 callersMethodget_by_dkey
Get a feed by its discovery key This only works if the feed is found on disk
corestore/src/corestore.rs:78
↓ 1 callersMethodget_dkey
(&self, dkey: &Key)
corestore/src/feed_map.rs:33
↓ 1 callersMethodget_key
(&self, key: &Key)
corestore/src/feed_map.rs:30
↓ 1 callersMethodget_name
(&self, name: &Name)
corestore/src/feed_map.rs:27
↓ 1 callersFunctioninit
()
corestore/src/replicate.rs:115
↓ 1 callersMethodinsert
(&mut self, feed: Feed, name: Option<Name>)
corestore/src/feed_map.rs:37
↓ 1 callersMethodjoin_all
Wait for all connections and feeds to close
replicator/src/lib.rs:108
↓ 1 callersFunctionkeys
()
corestore/examples/demo.rs:22
↓ 1 callersFunctionlisten
Open the server and start listening This will run a few things in parallel tasks: - a corestore that stores hypercore feeds - the hyperswarm dht, wai
server/src/lib.rs:39
↓ 1 callersFunctionnotify_loop
(id: u64, feed: ArcFeed, mut client: Client)
server/src/rpc/session.rs:107
↓ 1 callersMethodon_append
(&mut self, req: AppendEvent)
client/src/session.rs:80
↓ 1 callersMethodon_data
(&mut self, data: Data)
replicator/src/peer.rs:262
↓ 1 callersMethodon_download
(&mut self, req: DownloadEvent)
client/src/session.rs:87
↓ 1 callersMethodon_have
(&mut self, have: Have)
replicator/src/peer.rs:183
↓ 1 callersMethodon_request
(&mut self, request: Request)
replicator/src/peer.rs:304
↓ 1 callersMethodon_want
(&mut self, want: Want)
replicator/src/peer.rs:219
↓ 1 callersFunctiononappend_future
(core: RemoteHypercore, seq: u64)
client/src/stream.rs:47
↓ 1 callersFunctiononappend_get
(mut core: RemoteHypercore, seq: u64)
client/src/stream.rs:27
↓ 1 callersMethodopen_by_key
(&mut self, key: Key)
client/src/session.rs:45
↓ 1 callersMethodopen_by_name
(&mut self, name: impl ToString)
client/src/session.rs:58
↓ 1 callersFunctionparse_bitfield
(bitfield: Vec<u8>)
replicator/src/peer.rs:334
↓ 1 callersFunctionpubkey_from_bytes
(bytes: &Key)
corestore/src/corestore.rs:337
↓ 1 callersFunctionread
(mut core: RemoteHypercore, mut writer: impl AsyncWrite + Send + Unpin)
client/src/bin.rs:120
↓ 1 callersMethodread_name
(&self, dkey: &Key)
corestore/src/corestore.rs:298
↓ 1 callersFunctionrun
(mut replicator: Replicator, opts: Opts)
server/src/network.rs:8
↓ 1 callersMethodrun
(&mut self)
replicator/src/peer.rs:110
↓ 1 callersFunctionrun_rpc
(socket_path: P, state: State)
server/src/rpc/mod.rs:13
↓ 1 callersFunctionseek
(mut core: RemoteHypercore, byte_offset: u64)
client/src/stream.rs:22
↓ 1 callersMethodseek
(&mut self, byte_offset: u64)
client/src/session.rs:177
↓ 1 callersFunctionseek_future
(core: RemoteHypercore, byte_offset: usize)
client/src/stream.rs:51
↓ 1 callersMethodsend_wants
(&mut self, index: u64)
replicator/src/peer.rs:157
↓ 1 callersMethodset_notify_task
(&mut self, task: JoinHandle<io::Result<()>>)
server/src/rpc/session.rs:102
↓ 1 callersMethodstats
Get stats on the replication status for each feed
replicator/src/lib.rs:98
↓ 1 callersFunctionswarm_config_from_opts
(opts: Opts)
server/src/network.rs:42
↓ 1 callersFunctiontask_client
(mut replicator: Replicator)
corestore/examples/demo.rs:95
↓ 1 callersFunctiontask_server
(mut replicator: Replicator)
corestore/examples/demo.rs:104
↓ 1 callersFunctiontimeout
(ms: u64)
corestore/examples/demo.rs:116
↓ 1 callersMethodto_stream
(&mut self, start: u64, end: Option<u64>, live: bool)
client/src/session.rs:194
↓ 1 callersFunctionusage
()
corestore/examples/demo.rs:17
↓ 1 callersFunctionwrite
(mut core: RemoteHypercore, mut reader: impl AsyncRead + Send + Unpin)
client/src/bin.rs:131
↓ 1 callersMethodwrite_name_if_empty
(&self, dkey: &Key, name: &Name)
corestore/src/corestore.rs:309
Method_remove
(&mut self, feed: ArcFeed)
corestore/src/feed_map.rs:56
Methodappend
(&mut self, req: AppendRequest)
server/src/rpc/session.rs:63
Methodbyte_length
(&self)
client/src/session.rs:134
Methoddefault
()
server/src/options.rs:43
Methodfmt
(&self, f: &mut std::fmt::Formatter)
client/src/stream.rs:127
Methodfmt
(&self, f: &mut fmt::Formatter<'_>)
client/src/session.rs:102
next →1–100 of 128, ranked by callers