Functions — github.com/arthurprs/sucredb

CodeHub MCPcopy Create free account

hub / github.com/arthurprs/sucredb / functions

Functions434 in github.com/arthurprs/sucredb

⨍ Functions 434◇ Types & classes 100

↓ 1 callersMethodhandler_tick

(&self, time: time::Instant)

src/database.rs:391

↓ 1 callersFunctionis_dir_empty_or_absent

src/utils.rs:71

↓ 1 callersMethodis_exit

src/database.rs:37

↓ 1 callersMethodleave_node

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

↓ 1 callersMethodload

(num: u16, db: &Database, status: VNodeStatus)

src/vnode.rs:961

↓ 1 callersMethodlog_error

(&self, msg: &str)

src/utils.rs:107

↓ 1 callersMethodlog_iterator_all

src/storage.rs:195

↓ 1 callersFunctionloop

Regular debug loop that can be used to test how redis behaves during changes in the cluster.

scripts/simple.py:20

↓ 1 callersFunctionmain

scripts/sanity.py:92

↓ 1 callersMethodmaybe_gossip_alive

(&mut self, now: Instant)

src/gossip.rs:369

↓ 1 callersMethodmaybe_gossip_dead

(&mut self, now: Instant)

src/gossip.rs:404

↓ 1 callersMethodmerge

(&mut self, mut other: Self)

↓ 1 callersMethodmget

( &self, context: &mut Context, keys: &[&Bytes], consistency: ConsistencyLevel

src/database.rs:578

↓ 1 callersMethodmin_versions

src/version_vector.rs:192

↓ 1 callersMethodnext

src/version_vector.rs:157

↓ 1 callersMethodnodes_for_vnode_ex

( &self, vn_no: VNodeNo, include_pending: bool, include_retiring: bool, )

↓ 1 callersMethodon_cancel

called by vnode when node is transition to an incompatible state only valid for Receivers right now

src/vnode_sync.rs:454

↓ 1 callersMethodon_msg_fin

( &mut self, db: &Database, state: &mut VNodeState, msg: MsgSyncFin, )

src/vnode_sync.rs:522

↓ 1 callersMethodon_tick

(&mut self, db: &Database, state: &mut VNodeState)

src/vnode_sync.rs:475

↓ 1 callersMethodon_timer

(self: &mut Inner<T>)

src/gossip.rs:240

↓ 1 callersMethodparse_array

src/resp.rs:281

↓ 1 callersMethodparse_data

src/resp.rs:271

↓ 1 callersMethodparse_error

src/resp.rs:294

↓ 1 callersMethodparse_int

src/resp.rs:267

↓ 1 callersMethodparse_status

src/resp.rs:263

↓ 1 callersMethodprocess_get

src/vnode.rs:493

↓ 1 callersMethodpromote_pending_node

( &mut self, this: NodeId, promoted: NodeId, vn_no: VNodeNo, )

↓ 1 callersFunctionread_config_file

(path: &Path, config: &mut Config)

src/config.rs:163

↓ 1 callersMethodrecover_dots

src/vnode.rs:1007

↓ 1 callersMethodregister_con_handler

(&self, handler: FabricConFn)

src/fabric.rs:395

↓ 1 callersMethodregister_connection

(&self, peer: NodeId, sender: SenderChan)

src/fabric.rs:133

↓ 1 callersMethodregister_seed

(&self, addr: SocketAddr)

src/fabric.rs:399

↓ 1 callersMethodremove

(&mut self, key: &K)

src/inflightmap.rs:31

↓ 1 callersMethodremove_connection

(&self, peer: NodeId, connection_id: usize)

src/fabric.rs:154

↓ 1 callersMethodrequired

(&self, replicas: u8)

src/types.rs:65

↓ 1 callersMethodrespond_ask

(&self, context: &mut Context, vnode: VNodeNo, addr: net::SocketAddr)

src/command.rs:532

↓ 1 callersMethodrespond_cant_coordinate

( &mut self, db: &Database, context: &mut Context, status: VNodeStatus, )

src/vnode.rs:372

↓ 1 callersMethodrespond_moved

(&self, context: &mut Context, vnode: VNodeNo, addr: net::SocketAddr)

src/command.rs:525

↓ 1 callersMethodrestart

scripts/sanity.py:80

↓ 1 callersMethodsave

(&self, shutdown: bool)

src/database.rs:351

↓ 1 callersMethodsend_ping_reqs

(&mut self, seq: Seq, node: SocketAddr)

src/gossip.rs:343

↓ 1 callersMethodsend_sender_success_fin

Senders wait for the Receivers to reply => Continue unless there's no route the peer => Error

src/vnode_sync.rs:349

↓ 1 callersMethodsend_to

(&self, seed: usize, msg: T)

src/workers.rs:95

↓ 1 callersMethodsender

src/workers.rs:79

↓ 1 callersMethodset_callback

(&self, callback: DHTChangeFn)

↓ 1 callersMethodset_flush

src/database.rs:500

↓ 1 callersFunctionsetup_default_logging

src/config.rs:245

↓ 1 callersFunctionsetup_logging

(config_value: &yaml::Value)

src/config.rs:224

↓ 1 callersMethodsignal_sync_end

(&self, direction: SyncDirection)

src/database.rs:485

↓ 1 callersMethodsize_hint

src/version_vector.rs:168

↓ 1 callersMethodslots

↓ 1 callersMethodstart

(&mut self, mut worker_fn_gen: F)

src/workers.rs:50

↓ 1 callersMethodstart_sync_if_ready

(&mut self, db: &Database)

src/vnode.rs:842

↓ 1 callersMethodstorage_set_local

( &mut self, _db: &Database, writes: I, )

src/vnode.rs:1042

↓ 1 callersFunctiontest_all_nodes_complete

scripts/sanity.py:132

↓ 1 callersFunctiontest_converge

src/gossip.rs:729

↓ 1 callersFunctiontimeit

Time how long it take to run a number of set/get:s

scripts/simple.py:51

↓ 1 callersFunctiontimeit_pipeline

Time how long it takes to run a number of set/get:s inside a cluster pipeline

scripts/simple.py:66

↓ 1 callersFunctiontimer_fn

( name: String, interval: time::Duration, mut callback: F, )

src/workers.rs:112

↓ 1 callersMethodtouch_expired

(&mut self, now: T, expire: T)

src/inflightmap.rs:73

↓ 1 callersMethodvnodes_for_node

Returns tuple (vec<vnode with data>, vec<vnodes that should boostrap>)

scripts/sanity.py:70

scripts/sanity.py:20

Method_start_sync

(&mut self, db: &Database)

src/vnode.rs:850

(&mut self, id: Id, bv: &BitmappedVersion)

src/version_vector.rs:297

Functionadd_get

src/version_vector.rs:834

Methodbroadcast

(inner: &Inner<T>)

Methodbroadcast_req

(inner: &Inner<T>)

Methodcall_callback

(inner: &Inner<T>)

src/inflightmap.rs:26

scripts/sanity.py:30

(&self, other: &Pair<T, V>)

src/inflightmap.rs:116

( expected_node: Option<NodeId>, addr: SocketAddr, context: Arc<SharedContext>,

src/fabric.rs:240

Methodconnection

( context: Rc<SharedContext>, token: Token, socket: tokio::net::TcpStream, )

src/server.rs:130

(&mut self, src: &mut BytesMut)

src/server.rs:27

(&mut self, src: &mut BytesMut)

src/fabric.rs:34

(&mut self, addr: &SocketAddr, buf: &[u8])

src/gossip.rs:124

src/config.rs:55

src/utils.rs:15

src/cubes.rs:37

src/version_vector.rs:691

src/version_vector.rs:803

src/version_vector.rs:685

src/inflightmap.rs:92

src/database.rs:744

Methoddeserialize

Functiondeserialize_bitmap

(deserializer: D)

src/version_vector.rs:220

( &mut self, db: &Database, context: &mut Context, consistency: ConsistencyLev

src/vnode.rs:398

src/vnode.rs:309

src/workers.rs:102

src/server.rs:119

src/vnode.rs:886

src/fabric.rs:211

src/database.rs:610

src/gossip.rs:715

src/storage.rs:171

(&mut self, item: Self::Item, dst: &mut BytesMut)

src/server.rs:45

(&mut self, item: Self::Item, dst: &mut BytesMut)

src/fabric.rs:69

(&mut self, addr_msg: Self::Out, buf: &mut Vec<u8>)

src/gossip.rs:135

Methodentry_or_default

(&mut self, id: Id)

src/version_vector.rs:309

← previous next →201–300 of 434, ranked by callers