Functions — github.com/arthurprs/sucredb

hub / github.com/arthurprs/sucredb / functions

Functions434 in github.com/arthurprs/sucredb

⨍ Functions 434◇ Types & classes 100

↓ 137 callersMethodlen

(&self)

src/cubes.rs:186

↓ 85 callersMethodclone

(&self)

src/workers.rs:20

↓ 60 callersMethodinto

(self)

src/command.rs:37

↓ 53 callersMethodparse

parses a single value out of the stream. If there are multiple values you can call this multiple times.

src/resp.rs:188

↓ 52 callersMethoditer

(&'a mut self)

src/storage.rs:348

↓ 48 callersMethoddo_cmd

(&self, token: Token, args: &[&[u8]])

src/database.rs:723

↓ 36 callersMethodadd

(&mut self, version: Version)

src/version_vector.rs:82

↓ 31 callersMethodget

(&self)

src/cubes.rs:139

↓ 30 callersMethodinsert

(&mut self, node: Id, version: Version, item: Bytes)

src/cubes.rs:221

↓ 28 callersMethodinsert

(&mut self, id: Id, version: Version, value: T)

src/version_vector.rs:673

↓ 26 callersMethodentry

(&mut self, key: K)

src/inflightmap.rs:40

↓ 25 callersMethodis_empty

(&self)

src/storage.rs:321

↓ 22 callersFunctionjoin_u64

(hi: u32, lo: u32)

src/utils.rs:63

↓ 22 callersMethodread

(&mut self, len: usize)

src/resp.rs:230

↓ 21 callersMethodget_mut

(&mut self, id: Id)

src/version_vector.rs:301

↓ 21 callersMethodwait_syncs

(&self)

src/database.rs:692

↓ 20 callersMethodwrite

(&mut self, bytes: &[u8])

src/utils.rs:27

↓ 19 callersMethodevent

(&mut self, id: Id)

src/version_vector.rs:326

↓ 18 callersFunctioncheck_arg_count

(count: usize, min: usize, max: usize)

src/command.rs:56

↓ 18 callersMethodremove

(&mut self, node: Id, version: Version, item: &[u8])

src/cubes.rs:231

↓ 17 callersMethodopen

(&self, db_num: u16)

src/storage.rs:156

↓ 16 callersMethodcontains

(&self, version: Version)

src/version_vector.rs:123

↓ 16 callersMethodnode

(&self)

src/dht.rs:852

↓ 16 callersMethodset

(&mut self, node: Id, version: Version, value: Option<Bytes>, vv: &VersionVector)

src/cubes.rs:190

↓ 15 callersFunctioncheck_key_len

(key_len: usize)

src/command.rs:64

↓ 15 callersMethodparse_consistency

( &self, try: bool, args: &[&Bytes], i: usize, )

src/command.rs:186

↓ 15 callersMethodrebalance

(&mut self, this: NodeId)

src/dht.rs:428

↓ 14 callersMethodresponse_values

(&self, token: Token)

src/database.rs:719

↓ 14 callersMethodsend_msg

TODO: take msgs as references and buffer serialized bytes instead

src/fabric.rs:451

↓ 14 callersFunctionsleep_ms

(ms: u64)

src/utils.rs:80

↓ 13 callersMethodinto_iter

(self)

src/version_vector.rs:677

↓ 13 callersMethodjoin_node

( &mut self, this: NodeId, node: NodeId, addr: SocketAddr, meta: T,

src/dht.rs:179

↓ 13 callersMethodrespond_resp

(&self, context: &mut Context, resp: RespValue)

src/command.rs:508

↓ 12 callersMethodsend

(&mut self, to: SocketAddr, msg: Message<T>)

src/gossip.rs:632

↓ 10 callersMethoditer_mut

(&mut self)

src/version_vector.rs:349

↓ 10 callersMethodsend

(&self, msg: T)

src/workers.rs:90

↓ 9 callersMethodadd_all

(&mut self, version: Version)

src/version_vector.rs:96

↓ 8 callersMethodclear

(&mut self)

src/vnode.rs:903

↓ 8 callersMethoddescends

(&self, other: &Self)

src/version_vector.rs:585

↓ 8 callersMethodget

(&self, id: Id)

src/version_vector.rs:305

↓ 8 callersMethodlog_set

(&mut self, key: (u64, u64), value: &[u8])

src/storage.rs:332

↓ 8 callersMethodmerge

(&mut self, other: &Self)

src/version_vector.rs:74

↓ 8 callersFunctionreplace_default

(subject: &mut T)

src/utils.rs:51

↓ 7 callersMethodbatch_new

(&self, reserve: usize)

src/storage.rs:279

↓ 7 callersMethodbatch_write

(&self, batch: SendableStorageBatch)

src/storage.rs:165

↓ 7 callersMethodclear

(&mut self, node: Id, version: Version)

src/cubes.rs:151

↓ 7 callersFunctionencode_vv

↓ 7 callersMethodpropose

(&self, proposal: C)

src/dht.rs:1042

↓ 6 callersFunctionbuild_key

(buffer: &'a mut [u8], num: u16, key: &[u8])

src/storage.rs:26

↓ 6 callersMethodconnections

(&self)

src/fabric.rs:414

↓ 6 callersMethoditer

(&self)

src/version_vector.rs:353

↓ 6 callersMethodset

(&self, key: &[u8], value: &[u8])

src/storage.rs:267

↓ 6 callersMethodset_status

(&mut self, db: &Database, new: VNodeStatus)

src/vnode.rs:912

↓ 6 callersMethodstatus

(&self)

src/vnode.rs:171

↓ 5 callersMethodbroadcast

(&mut self, msg: Message<T>)

src/gossip.rs:636

↓ 5 callersMethoddel

(&mut self, id: Id, version: Version, vv: &VersionVector)

src/cubes.rs:80

↓ 5 callersMethodfinish_rebalance

(&mut self, this: NodeId)

src/dht.rs:548

↓ 5 callersMethodforce_syncs

(&self)

src/database.rs:683

↓ 5 callersMethodinc

(&mut self, node: Id, version: Version, by: i64)

src/cubes.rs:143

↓ 5 callersMethodnodes_for_vnode

TODO: split into read_ and write_

src/dht.rs:889

↓ 5 callersMethodnorm

(&mut self)

src/version_vector.rs:106

↓ 5 callersMethodregister_msg_handler

(&self, msg_type: FabricMsgType, handler: FabricMsgFn)

src/fabric.rs:387

↓ 5 callersMethodreplace_node

( &mut self, this: NodeId, old: NodeId, new: NodeId, addr: SocketAddr,

src/dht.rs:265

↓ 5 callersMethodrespond_error

(&self, context: &mut Context, error: CommandError)

src/command.rs:521

↓ 5 callersMethodset

( &self, context: &mut Context, key: &Bytes, mutator_fn: MutatorFn, co

src/database.rs:531

↓ 5 callersFunctionsplit_u64

(uint: u64)

src/utils.rs:59

↓ 5 callersMethodstart_bootstrap

(&mut self, db: &Database)

src/vnode.rs:801

↓ 5 callersMethodstorage_get

STORAGE

src/vnode.rs:1032

↓ 5 callersMethodvalid_nodes_count

(&self)

src/dht.rs:150

↓ 4 callersFunctioncheck_value_len

(value_len: usize)

src/command.rs:72

↓ 4 callersMethodcmd_set

( &self, context: &mut Context, args: &[&Bytes], reply_result: bool, )

src/command.rs:357

↓ 4 callersMethodcontained

(&self, bvv: &BitmappedVersionVector)

src/version_vector.rs:540

↓ 4 callersMethodgen_cookie

(&self)

src/vnode.rs:198

↓ 4 callersMethodget_candidates

(&self, alive: bool, limit: usize)

src/gossip.rs:319

↓ 4 callersMethodget_vec

(&self, key: &[u8])

src/storage.rs:259

↓ 4 callersMethodis_empty

(&self)

src/cubes.rs:332

↓ 4 callersMethodjoin

(&mut self, seeds: &[SocketAddr])

src/gossip.rs:659

↓ 4 callersMethodkey_vnode

(&self, key: &[u8])

src/dht.rs:865

↓ 4 callersMethodmerge

(self, other: Self)

src/cubes.rs:92

↓ 4 callersMethodon_message

(&mut self, sender: SocketAddr, msg: Message<T>)

src/gossip.rs:427

↓ 4 callersFunctionparse

(slice: &[u8])

src/resp.rs:303

↓ 4 callersMethodpop_expired

(&mut self, now: T)

src/inflightmap.rs:60

↓ 4 callersMethodsender

Gets a Sender handle that allows sending work to the database worker pool

src/database.rs:364

↓ 3 callersMethodaddr

(&self)

src/fabric.rs:365

↓ 3 callersFunctionbuild_log_key

(buffer: &'a mut [u8], num: u16, log_key: (u64, u64))

src/storage.rs:33

↓ 3 callersMethoddelta

self - other

src/version_vector.rs:132

↓ 3 callersMethodgenerate_sync_state

(&mut self)

src/gossip.rs:589

↓ 3 callersMethodhandle_bootstrap_result

(&mut self, db: &Database, result: SyncResult)

src/vnode.rs:772

↓ 3 callersMethodis_valid

(&self)

src/dht.rs:566

↓ 3 callersMethodon_remove

called by vnode as soon as the sync is unregistered

src/vnode_sync.rs:464

↓ 3 callersMethodon_start

called by vnode as soon as the sync is registered (after creation)

src/vnode_sync.rs:515

↓ 3 callersFunctionparse_int

( try: bool, args: &[&Bytes], i: usize, )

src/command.rs:42

↓ 3 callersMethodpartitions

(&self)

src/dht.rs:856

↓ 3 callersMethodread_int_line

(&mut self)

src/resp.rs:255

↓ 3 callersMethodread_line

(&mut self)

src/resp.rs:247

↓ 3 callersMethodrefute

(&mut self, incarnation: Seq)

src/gossip.rs:309

↓ 3 callersMethodremove

(&mut self, key: &Q)

src/version_vector.rs:732

↓ 3 callersMethodremove_node

(&mut self, this: NodeId, removed: NodeId)

src/dht.rs:216

↓ 3 callersFunctionresp

(aa)

scripts/simple.py:12

next →1–100 of 434, ranked by callers