Functions — github.com/ShisoftResearch/bifrost

hub / github.com/ShisoftResearch/bifrost / functions

Functions541 in github.com/ShisoftResearch/bifrost

⨍ Functions 541◇ Types & classes 103

↓ 53 callersMethodregister_service

(&self, service: &Arc<T>)

src/rpc/mod.rs:264

↓ 51 callersMethodjoin

(&self, servers: &Vec<String>)

src/raft/mod.rs:1766

↓ 44 callersFunctionasync_wait_secs

()

src/utils/time.rs:22

↓ 42 callersMethodbootstrap

(&self)

src/raft/mod.rs:1713

↓ 38 callersFunctionhash_str

(text: &'a str)

src/hasher/src/lib.rs:12

↓ 35 callersMethodregister_state_machine

( &self, state_machine: SubStateMachine, )

src/raft/mod.rs:463

↓ 27 callersFunctionserialize

(obj: &T)

src/utils/serde.rs:5

↓ 26 callersFunctionasync_wait

(duration: Duration)

src/utils/time.rs:18

↓ 26 callersMethodget

(&self, addr: &String)

src/rpc/mod.rs:320

↓ 23 callersFunctionget_time

()

src/utils/time.rs:5

↓ 22 callersMethodget

(&self)

src/raft/client.rs:1245

↓ 22 callersMethodregister

(&mut self, smc: SubStateMachine)

src/raft/state_machine/master.rs:122

↓ 20 callersMethodshutdown

(&self)

src/rpc/mod.rs:229

↓ 17 callersMethodrecover_after_register

(&self)

src/raft/mod.rs:472

↓ 16 callersMethodnew_member

(&mut self, address: String)

src/raft/state_machine/configs.rs:158

↓ 16 callersMethodshutdown

(&self)

src/raft/mod.rs:498

↓ 15 callersFunctiondeserialize

(data: &'a [u8])

src/utils/serde.rs:16

↓ 15 callersMethodwrite_meta

(&'a self)

src/raft/mod.rs:2094

↓ 13 callersMethodcommit_cmd

(&mut self, entry: &LogEntry)

src/raft/state_machine/master.rs:158

↓ 13 callersMethodencode

Encode to deterministic binary format with CRC32 checksum. On-disk record layout (written by `append_logs`): [8 bytes] record length (= 4 + payload

src/raft/disk.rs:74

↓ 13 callersMethodplane

(self: &Arc<Self>, plane_id: PlaneId)

src/raft/mod.rs:1270

↓ 12 callersMethodjoin_group

(&self, group: &String)

src/membership/member.rs:81

↓ 12 callersFunctionswap_when_greater

(atomic: &AtomicU64, value: u64)

src/raft/client.rs:1198

↓ 11 callersMethodcompose_client_member

(&self, id: u64)

src/membership/server.rs:351

↓ 11 callersMethodinc

(&mut self, server: S)

src/vector_clock/mod.rs:58

↓ 11 callersMethodtake_a_shot

(&mut self, num: i32)

src/raft/mod.rs:4657

↓ 10 callersFunctioncheck_commit

(meta: &mut RwLockWriteGuard<'_, RaftMeta>)

src/raft/mod.rs:561

↓ 10 callersMethodexec_qry

(&self, entry: &LogEntry)

src/raft/state_machine/master.rs:205

↓ 10 callersMethodget

(&self)

src/raft/mod.rs:3568

↓ 10 callersMethodget_shot

(&self)

src/raft/mod.rs:4662

↓ 10 callersMethodnum_logs

(&self)

src/raft/mod.rs:1983

↓ 9 callersMethodresolve_plane_runtime

( &self, plane_id: PlaneId, allow_create_if_missing: bool, bootstrap_if_fresh:

src/raft/mod.rs:1106

↓ 9 callersMethodruntime_for_plane

( &self, plane_id: PlaneId, )

src/raft/mod.rs:1150

↓ 7 callersMethodensure_plane

( self: &Arc<Self>, spec: PlaneSpec, )

src/raft/mod.rs:1253

↓ 7 callersMethodexecute

(&self, sm_id: u64, msg: M)

src/raft/client.rs:81

↓ 7 callersFunctionhash_bytes

(bytes: &[u8])

src/hasher/src/lib.rs:6

↓ 7 callersMethodregister_service_with_id

(&self, service_id: u64, service: &Arc<T>)

src/rpc/mod.rs:243

↓ 6 callersMethoddel_member

(&mut self, address: String)

src/raft/state_machine/configs.rs:161

↓ 6 callersMethodensure_plane_from_seeds

Materialize a type-2 plane using the current type-1 membership discovered from one or more root seed nodes.

↓ 6 callersMethodis_leader

(&self)

src/raft/mod.rs:490

↓ 6 callersMethodnew_group

(&self, name: &String)

src/membership/client.rs:56

↓ 6 callersMethodprobe_and_join

(&self, servers: &Vec<String>)

src/raft/mod.rs:1689

↓ 6 callersMethodread_snapshot

Read and validate snapshot from disk

src/raft/disk.rs:460

↓ 6 callersMethodrecover_registered_snapshots

(&mut self)

src/raft/state_machine/master.rs:134

↓ 6 callersMethodreset_last_checked

(&self, meta: &mut RwLockWriteGuard<RaftMeta>)

src/raft/mod.rs:2672

↓ 6 callersMethodset_weight

(&self, server_name: &String, weight: u64)

src/conshash/mod.rs:254

↓ 6 callersMethodwrite_snapshot

Write snapshot to disk using atomic write pattern (temp file + rename)

src/raft/disk.rs:417

↓ 5 callersMethodget_server_by_string

(&self, string: &String)

src/conshash/mod.rs:221

↓ 5 callersMethodinit_table

(&self)

src/conshash/mod.rs:296

↓ 5 callersMethodleader_id

(&self)

src/raft/mod.rs:1993

↓ 5 callersMethodmember_address

(&self)

src/raft/state_machine/configs.rs:81

↓ 5 callersMethodplane_state

(&self, plane_id: PlaneId)

src/raft/client.rs:168

↓ 5 callersMethodread_meta

(&self)

src/raft/mod.rs:2098

↓ 5 callersMethodrecover

(&mut self, _: Vec<u8>)

src/raft/mod.rs:3584

↓ 5 callersMethodrecover

(&mut self, data: Vec<u8>)

src/raft/state_machine/master.rs:63

↓ 5 callersMethodroot_member_addresses

(&self)

src/raft/client.rs:208

↓ 5 callersMethodsnapshot

(&self)

src/raft/mod.rs:3580

↓ 5 callersMethodsnapshot

(&self)

src/raft/state_machine/master.rs:50

↓ 5 callersFunctionwait_for_plane

(service: &Arc<RaftService>, plane_id: PlaneId)

src/raft/mod.rs:3631

↓ 4 callersMethodappend_logs

( &mut self, meta: &'a RwLockWriteGuard<'a, RaftMeta>, logs: &'a RwLockWriteGuard<'a,

src/raft/disk.rs:277

↓ 4 callersMethodbecome_follower_on_plane

( &self, leader_flag: &AtomicBool, meta: &mut RwLockWriteGuard<RaftMeta>, term

src/raft/mod.rs:2234

↓ 4 callersMethodbecome_leader_on_plane

( &self, leader_flag: &AtomicBool, meta: &mut RwLockWriteGuard<'_, RaftMeta>,

src/raft/mod.rs:2251

↓ 4 callersFunctionencode_res

(res: Result<BytesMut, RPCRequestError>)

src/rpc/mod.rs:67

↓ 4 callersMethodexecute_on_plane

( &self, plane_id: PlaneId, sm_id: u64, msg: M, )

src/raft/client.rs:540

↓ 4 callersMethodflush_persistence

(&self)

src/raft/mod.rs:494

↓ 4 callersMethodflush_wal

Ensure WAL file is fully synced to disk.

src/raft/disk.rs:371

↓ 4 callersMethodget_server_id

(&self, hash: u64)

src/conshash/mod.rs:189

↓ 4 callersFunctionhash

(obj: &T)

src/utils/serde.rs:64

↓ 4 callersMethodhello

(&self, name: String)

src/rpc/mod.rs:391

↓ 4 callersFunctionis_leader

(meta: &RwLockWriteGuard<RaftMeta>)

src/raft/mod.rs:1496

↓ 4 callersMethodis_type1

(self)

src/raft/mod.rs:66

↓ 4 callersMethodleader_client_on_plane

(&self, state: &PlaneClientState)

src/raft/client.rs:1094

↓ 4 callersFunctionmax

(nums: &Vec<T>)

src/utils/math.rs:10

↓ 4 callersMethodrelation

(&self, clock_b: &VectorClock<S>)

src/vector_clock/mod.rs:150

↓ 4 callersMethodremove_subscriber

(&mut self, suber_id: u64)

src/raft/state_machine/callback/server.rs:108

↓ 4 callersMethodremove_subscription

(&mut self, id: u64)

src/raft/state_machine/callback/server.rs:122

↓ 4 callersMethodsend_followers_heartbeat_on_plane

( &self, plane_id: PlaneId, meta: &mut RwLockWriteGuard<'a, RaftMeta>, log_id:

src/raft/mod.rs:2281

↓ 4 callersMethodsnapshot

(&self)

src/raft/state_machine/configs.rs:110

↓ 4 callersMethodsubscribe

( &self, sm_id: u64, msg: M, f: F, )

src/raft/client.rs:91

↓ 4 callersMethodswitch_membership

(&self, meta: &mut RwLockWriteGuard<RaftMeta>, membership: Membership)

src/raft/mod.rs:2057

↓ 4 callersMethodtake_snapshot

Create and persist a snapshot

src/raft/mod.rs:3111

↓ 3 callersFunctionalter_term

(meta: &mut RwLockWriteGuard<RaftMeta>, term: u64)

src/raft/mod.rs:1502

↓ 3 callersMethodany_known_client

(&self)

src/raft/client.rs:1081

↓ 3 callersFunctionapply_committed_entry

( meta: &'a RwLockWriteGuard<'a, RaftMeta>, entry: &'a LogEntry, )

src/raft/mod.rs:1489

↓ 3 callersMethodbecome_candidate_on_plane

( &'a self, plane_id: PlaneId, leader_flag: &'a AtomicBool, meta: &'a mut RwLo

src/raft/mod.rs:2102

↓ 3 callersMethodclear_subs

(&mut self)

src/raft/state_machine/master.rs:252

↓ 3 callersMethodclose

(&self)

src/membership/member.rs:74

↓ 3 callersMethodcluster_info

(&self)

src/raft/mod.rs:478

↓ 3 callersFunctiongen_timeout

()

src/raft/mod.rs:183

↓ 3 callersMethodget_by_id

(&self, server_id: u64, addr_fn: F)

src/rpc/mod.rs:326

↓ 3 callersMethodget_server

(&self, hash: u64)

src/conshash/mod.rs:218

↓ 3 callersMethodinstall_snapshot

( &self, plane_id: PlaneId, term: u64, leader_id: u64, last_included_i

src/raft/mod.rs:3322

↓ 3 callersMethodlearn_from

(&mut self, clock_b: &VectorClock<S>)

src/vector_clock/mod.rs:210

↓ 3 callersMethodlisten

(server: &Arc<Server>)

src/rpc/mod.rs:115

↓ 3 callersMethodmember_existed

(&self, id: u64)

src/raft/state_machine/configs.rs:164

↓ 3 callersMethodmembers

(&self)

src/raft/state_machine/master.rs:154

↓ 3 callersMethodmerge_with

(&mut self, clock_b: &VectorClock<S>)

src/vector_clock/mod.rs:163

↓ 3 callersMethodplane

(self: &Arc<Self>, plane_id: PlaneId)

src/raft/client.rs:187

↓ 3 callersMethodrecover

(&mut self, data: Vec<u8>)

src/raft/state_machine/configs.rs:119

next →1–100 of 541, ranked by callers