Functions — github.com/arthurprs/sucredb

hub / github.com/arthurprs/sucredb / functions

Functions434 in github.com/arthurprs/sucredb

⨍ Functions 434◇ Types & classes 100

↓ 3 callersMethodrespond

(&self, context: &mut Context)

src/command.rs:503

↓ 3 callersMethodrespond_ok

(&self, context: &mut Context)

src/command.rs:517

↓ 3 callersMethodresponse_resp

(&self, token: Token)

↓ 3 callersMethodsatisfied

(&self)

src/vnode.rs:139

↓ 3 callersMethodsave

(&mut self, db: &Database, shutdown: bool)

src/vnode.rs:167

↓ 3 callersMethodsend_next

send (possibly multiple) SyncSend messages and eventual SyncFin (also takes care of expired SyncSend)

src/vnode_sync.rs:382

↓ 3 callersMethodset_status

(&mut self, status: NodeStatus, incarnation: Seq)

src/gossip.rs:157

↓ 3 callersMethodsignal_sync_start

(&self, direction: SyncDirection)

src/database.rs:465

↓ 3 callersMethodstart

(self, *args)

scripts/sanity.py:51

↓ 3 callersMethodstart_connect

(&self, expected_node: Option<NodeId>, addr: SocketAddr)

src/fabric.rs:442

↓ 3 callersMethodsync

(&self)

src/storage.rs:314

↓ 2 callersMethodalive_count

(&self)

src/gossip.rs:703

↓ 2 callersFunctionassume_str

(bytes: &[u8])

src/utils.rs:67

↓ 2 callersMethodbase

(&self)

src/version_vector.rs:119

↓ 2 callersMethodclear_data

(self)

scripts/sanity.py:33

↓ 2 callersMethodcluster_join

(self)

scripts/sanity.py:40

↓ 2 callersMethodcmd_cset

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

src/command.rs:412

↓ 2 callersMethodcmd_del

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

src/command.rs:393

↓ 2 callersMethodcmd_exec

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

src/command.rs:209

↓ 2 callersMethodcmd_hdel

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

src/command.rs:261

↓ 2 callersMethodcmd_hset

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

src/command.rs:238

↓ 2 callersMethodcmd_incrby

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

src/command.rs:446

↓ 2 callersMethodcmd_sadd

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

src/command.rs:290

↓ 2 callersMethodcmd_srem

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

src/command.rs:311

↓ 2 callersFunctioncontains

()

src/version_vector.rs:997

↓ 2 callersMethodcontains_all

(&self, version: Version)

src/version_vector.rs:127

↓ 2 callersMethoddirection

(&self)

src/vnode_sync.rs:609

↓ 2 callersMethoddo_start_sync

(&mut self, db: &Database)

src/vnode.rs:855

↓ 2 callersMethoddo_sync

(&mut self, state: Vec<State<T>>)

src/gossip.rs:608

↓ 2 callersMethoddone

(&self)

src/vnode.rs:135

↓ 2 callersMethodexecute

(self, *args, **kwargs)

scripts/sanity.py:88

↓ 2 callersMethodget_type

(&self)

src/fabric_msg.rs:55

↓ 2 callersMethodhandle_cmd

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

src/command.rs:89

↓ 2 callersMethodhandler_cmd

(&self, mut context: Context)

src/command.rs:81

↓ 2 callersMethodhandler_fabric_msg

(&self, from: NodeId, msg: FabricMsg)

src/database.rs:417

↓ 2 callersFunctionhash_slot

RedisCluster style partitioning

src/hash.rs:6

↓ 2 callersFunctioninto_io_error

(e: E)

src/utils.rs:55

↓ 2 callersMethodis_empty

(&self)

src/version_vector.rs:659

↓ 2 callersMethodis_subsumed

(&self, bvv: &BitmappedVersionVector)

src/cubes.rs:43

↓ 2 callersMethoditerator

(&self)

src/storage.rs:180

↓ 2 callersMethodkill

(self)

scripts/sanity.py:74

↓ 2 callersMethodlog_get

( &self, log_key: (u64, u64), callback: F, )

src/storage.rs:243

↓ 2 callersMethodlog_iterator

(&self, prefix: u64, start: u64)

src/storage.rs:211

↓ 2 callersMethodmembers

(&self)

src/dht.rs:943

↓ 2 callersMethodnext

(&mut self, state: &VNodeState)

src/vnode_sync.rs:116

↓ 2 callersMethodnext

(&mut self)

src/storage.rs:359

↓ 2 callersMethodparse_value

(&mut self)

src/resp.rs:197

↓ 2 callersMethodparse_vv

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

src/command.rs:173

↓ 2 callersMethodprocess_set

( &mut self, db: &Database, cookie: Cookie, response: Result<I, FabricError>,

src/vnode.rs:538

↓ 2 callersMethodread_byte

(&mut self)

src/resp.rs:219

↓ 2 callersMethodread_with_separator

(&mut self, len: usize)

src/resp.rs:238

↓ 2 callersMethodregister_node

(&self, peer: NodeId, peer_addr: SocketAddr)

src/fabric.rs:125

↓ 2 callersMethodsave_ring

(&self)

src/dht.rs:939

↓ 2 callersMethodsend_error_fin

Sending Errors always result in Error

src/vnode_sync.rs:302

↓ 2 callersMethodsend_start

send SyncStart message, only valid for Receivers

src/vnode_sync.rs:264

↓ 2 callersMethodserialize_into

(self, f: &mut W)

src/resp.rs:46

↓ 2 callersMethodserialized_size

(&self)

src/resp.rs:32

↓ 2 callersMethodset_nodes

(&self, it: I)

src/fabric.rs:423

↓ 2 callersFunctionsplit_number_suffix

(s: &str)

src/config.rs:90

↓ 2 callersMethodstorage_set_remote

( &mut self, _db: &Database, writes: Vec<(Bytes, Cube, bool)>, )

src/vnode.rs:1066

↓ 2 callersFunctionstub_aae_converge

(drop: usize)

src/database.rs:1178

↓ 2 callersMethodsyncs_inflight

(&self)

src/database.rs:447

↓ 2 callersMethodtake_response

(&mut self)

src/database.rs:98

↓ 2 callersFunctiontest_reload_stub

(shutdown: bool)

src/database.rs:776

↓ 2 callersMethodvalid_physical_count

(&self, physical: PhysicalNodeId)

src/dht.rs:154

↓ 2 callersMethodwait_fabric

(&self)

src/database.rs:701

↓ 2 callersMethodwait_ready

(self, callback=lambda c: c.ping(), timeout=5, sleep=0.1)

scripts/sanity.py:44

↓ 1 callersMethod_dump_log

(&self)

src/vnode.rs:176

↓ 1 callersMethod_start_sync

(&self, vnode: VNodeNo)

src/database.rs:459

↓ 1 callersFunctionbuild_log_prefix

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

src/storage.rs:45

↓ 1 callersMethodclear

(&mut self)

src/version_vector.rs:273

↓ 1 callersMethodclear

(&mut self)

src/database.rs:111

↓ 1 callersMethodclear

(&self)

src/storage.rs:290

↓ 1 callersMethodcluster_init

(self)

scripts/sanity.py:36

↓ 1 callersMethodcmd_cget

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

src/command.rs:433

↓ 1 callersMethodcmd_cluster

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

src/command.rs:472

↓ 1 callersMethodcmd_config

(&self, context: &mut Context, _args: &[&Bytes])

src/command.rs:226

↓ 1 callersMethodcmd_get

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

src/command.rs:332

↓ 1 callersMethodcmd_hgetall

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

src/command.rs:230

↓ 1 callersMethodcmd_mget

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

src/command.rs:340

↓ 1 callersMethodcmd_multi

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

src/command.rs:202

↓ 1 callersMethodcmd_smembers

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

src/command.rs:282

↓ 1 callersMethodcmd_type

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

src/command.rs:466

↓ 1 callersFunctionconfigure

()

src/main.rs:67

↓ 1 callersMethodconsumed

(&self)

src/resp.rs:182

↓ 1 callersFunctiondecode_values

↓ 1 callersMethoddiscard

(&mut self, vv: &VersionVector)

src/version_vector.rs:669

↓ 1 callersMethoddispatch

(&mut self, req: RespValue)

src/server.rs:86

↓ 1 callersMethoddispatch

(&self, msg: FabricMsg)

src/fabric.rs:182

↓ 1 callersMethoddispatch_next

(&mut self, mut db_context: DbContext)

src/server.rs:100

↓ 1 callersMethoddump_logs

(&self)

src/database.rs:731

↓ 1 callersMethodfinish

(&self)

src/utils.rs:22

↓ 1 callersMethodfor_each_dot

minimum set of dots required to assemble this cube see comment at the bottom

src/cubes.rs:61

↓ 1 callersMethodgenerate_ping_msg

(&mut self)

src/gossip.rs:642

↓ 1 callersMethodget

( &self, context: &mut Context, key: &Bytes, consistency: ConsistencyLevel,

src/database.rs:560

↓ 1 callersMethodget

( &self, key: &[u8], callback: F, )

src/storage.rs:227

↓ 1 callersMethodhandler_dht_change

(&self)

src/database.rs:368

↓ 1 callersMethodhandler_tick

(&self, time: Instant)

src/dht.rs:837

← previous next →101–200 of 434, ranked by callers