Functions — github.com/ShisoftResearch/bifrost

hub / github.com/ShisoftResearch/bifrost / functions

Functions541 in github.com/ShisoftResearch/bifrost

⨍ Functions 541◇ Types & classes 103

↓ 3 callersMethodrecoverable

(&self)

src/raft/state_machine/master.rs:81

↓ 3 callersMethodshutdown_managed_runtime

(&self, runtime: Option<Arc<RaftPlaneRuntime>>)

src/raft/mod.rs:806

↓ 3 callersMethodstart_managed_runtime

(self: &Arc<Self>, runtime: Option<Arc<RaftPlaneRuntime>>)

src/raft/mod.rs:644

↓ 3 callersMethodwatch_server_nodes_range_changed

(&self, server: &String, f: F)

src/conshash/mod.rs:268

↓ 3 callersMethodwrite_commit_progress

Persist commit progress atomically to a side file (commit.idx)

src/raft/disk.rs:384

↓ 2 callersMethodc_command

( &'a self, plane_id: PlaneId, entry: LogEntry, )

src/raft/mod.rs:3372

↓ 2 callersMethodc_server_cluster_info

(&self, plane_id: PlaneId)

src/raft/mod.rs:3433

↓ 2 callersMethodchange_leader

(&mut self, group_id: u64, new: Option<u64>)

src/membership/server.rs:504

↓ 2 callersMethodcheck_term_on_plane

check term number, return reject = false if server term is stale

src/raft/mod.rs:2657

↓ 2 callersMethodcluster_info

(&self)

src/raft/client.rs:114

↓ 2 callersMethodcluster_info_on_plane_local

( &self, plane_id: PlaneId, )

src/raft/mod.rs:1394

↓ 2 callersMethodcurrent_leader_client_on_plane

( &self, plane_id: PlaneId, state: &PlaneClientState, )

src/raft/client.rs:1104

↓ 2 callersFunctionensure_direct_leader_term

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

src/raft/mod.rs:1509

↓ 2 callersMethodeq

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

src/vector_clock/mod.rs:43

↓ 2 callersMethodflush_persistence_on_plane

(&self, plane_id: PlaneId)

src/raft/mod.rs:1448

↓ 2 callersMethodgen_log_entry

( &self, state: &PlaneClientState, sm_id: u64, fn_id: u64, data: &Vec<

src/raft/client.rs:1056

↓ 2 callersMethodget_callback

(&self)

src/raft/client.rs:583

↓ 2 callersMethodgroup_leader_candidate_available

(&mut self, group_id: u64, member: u64)

src/membership/server.rs:537

↓ 2 callersMethodgroup_leader_candidate_unavailable

(&mut self, group_id: u64, member: u64)

src/membership/server.rs:554

↓ 2 callersMethodhandle_append_entries_on_meta

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

src/raft/mod.rs:2683

↓ 2 callersMethodhandle_client_command_on_meta

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

src/raft/mod.rs:2835

↓ 2 callersMethodhandle_client_query_on_meta

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

src/raft/mod.rs:2920

↓ 2 callersMethodhandle_install_snapshot_on_meta

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

src/raft/mod.rs:2793

↓ 2 callersMethodhandle_request_vote_on_meta

( &'a self, mut meta: RwLockWriteGuard<'a, RaftMeta>, term: u64, candidate_id:

src/raft/mod.rs:2764

↓ 2 callersMethodhappened_before

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

src/vector_clock/mod.rs:70

↓ 2 callersMethodhas_sub

(&self, id: &u64)

src/raft/state_machine/master.rs:255

↓ 2 callersMethodhave_state_machine_on_plane_local

( &self, plane_id: PlaneId, id: u64, )

src/raft/mod.rs:1424

↓ 2 callersMethodid

(&self)

src/raft/state_machine/master.rs:47

↓ 2 callersMethodid

(&self)

src/raft/state_machine/callback/mod.rs:79

↓ 2 callersMethodinitialize_runtime_meta

( &self, plane_id: PlaneId, leader_flag: &AtomicBool, meta: &mut RwLockWriteGu

src/raft/mod.rs:1027

↓ 2 callersMethodis_leader_on_plane

(&self, plane_id: PlaneId)

src/raft/mod.rs:1440

↓ 2 callersFunctionis_majority

(members: u64, granted: u64)

src/raft/mod.rs:1479

↓ 2 callersMethodleave

(&self)

src/membership/member.rs:77

↓ 2 callersMethodleave

(&self)

src/raft/mod.rs:1845

↓ 2 callersMethodleave_group_

(&mut self, group_id: u64, id: u64, need_notify: bool)

src/membership/server.rs:456

↓ 2 callersMethodlisten

( &self, addr: &String, callback: Arc<dyn Fn(TcpReq) -> TcpRes + Send + Sync>, )

src/tcp/server.rs:33

↓ 2 callersMethodlogs_post_processing

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

src/raft/mod.rs:2968

↓ 2 callersMethodmember_groups

(&self, member: u64)

src/membership/server.rs:483

↓ 2 callersFunctionmin

(nums: &Vec<T>)

src/utils/math.rs:1

↓ 2 callersMethodnotify

( &self, msg: M, message: R, )

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

↓ 2 callersMethodnotify_for_group_member_left

(&self, group: u64, member: &ClientMember)

src/membership/server.rs:447

↓ 2 callersMethodon_group_member_joined

( &self, f: F, group: &str, )

src/membership/client.rs:122

↓ 2 callersMethodon_group_member_left

( &self, f: F, group: &str, )

src/membership/client.rs:143

↓ 2 callersMethodon_group_member_offline

( &self, f: F, group: &str, )

src/membership/client.rs:80

↓ 2 callersMethodon_group_member_online

( &self, f: F, group: &str, )

src/membership/client.rs:101

↓ 2 callersFunctionparse_output

(r: Option<Vec<u8>>)

src/raft/state_machine/master.rs:86

↓ 2 callersFunctionread_u64_head

(mut data: BytesMut)

src/rpc/mod.rs:99

↓ 2 callersMethodreload_leader_meta

( &self, member_map: &HashMap<u64, RaftMember>, leader_meta: &mut RwLockWriteGuard<Lea

src/raft/mod.rs:2084

↓ 2 callersMethodremove_root_member

(&self, address: &String)

src/raft/client.rs:203

↓ 2 callersFunctionserver_changed

(ch: Arc<ConsistentHashing>, member: Member, action: Action, version: u64)

src/conshash/mod.rs:372

↓ 2 callersFunctionserver_joined

(ch: Arc<ConsistentHashing>, member: Member, version: u64)

src/conshash/mod.rs:366

↓ 2 callersFunctionserver_left

(ch: Arc<ConsistentHashing>, member: Member, version: u64)

src/conshash/mod.rs:369

↓ 2 callersMethodshould_take_snapshot

Check if we should take a snapshot based on configuration thresholds

src/raft/mod.rs:3074

↓ 2 callersMethodshutdown

(&self)

src/tcp/server.rs:105

↓ 2 callersMethodsubscribe_on_plane

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

src/raft/client.rs:608

↓ 2 callersMethodtrigger

(&mut self)

src/raft/state_machine/callback/mod.rs:65

↓ 2 callersMethodupdate_info

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

src/raft/client.rs:384

↓ 2 callersMethodupdate_plane_info

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

src/raft/client.rs:469

↓ 1 callersMethodadd_plane_member_via_log

( &self, plane_id: PlaneId, address: String, )

src/raft/mod.rs:1225

↓ 1 callersMethodadd_root_member

(&self, address: &String)

src/raft/client.rs:198

↓ 1 callersMethodaddress

(&self)

src/rpc/mod.rs:274

↓ 1 callersMethodall_members

(&self, online_only: bool)

src/membership/client.rs:77

↓ 1 callersFunctionall_server_ids

( conshash: &Arc<ConsistentHashing>, )

src/rpc/cluster.rs:26

↓ 1 callersMethodappend_entries

( &'a self, plane_id: PlaneId, term: u64, leader_id: u64, prev_log_id:

src/raft/mod.rs:3224

↓ 1 callersMethodbecome_candidate

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

src/raft/mod.rs:2229

↓ 1 callersMethodbecome_follower

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

src/raft/mod.rs:2247

↓ 1 callersMethodbecome_leader

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

src/raft/mod.rs:2276

↓ 1 callersFunctionbroadcast_with_server_ids

( server_ids: I, conshash: &Arc<ConsistentHashing>, func: F, )

src/rpc/cluster.rs:33

↓ 1 callersMethodc_have_state_machine

(&self, plane_id: PlaneId, id: u64)

src/raft/mod.rs:3459

↓ 1 callersMethodc_query

( &'a self, plane_id: PlaneId, entry: &'a LogEntry, )

src/raft/mod.rs:3402

↓ 1 callersFunctioncall

(server_id: u64, data: TcpReq)

src/tcp/shortcut.rs:26

↓ 1 callersMethodcallback

(&self, state_machine_id: u64)

src/raft/mod.rs:459

↓ 1 callersFunctionclient_by_rpc_client

(client: &Arc<RPCClient>)

src/rpc/cluster.rs:77

↓ 1 callersFunctionclient_by_server_id

( conshash: &Arc<ConsistentHashing>, server_id: u64, )

src/rpc/cluster.rs:63

↓ 1 callersMethodcluster_info_on_plane

( &self, plane_id: PlaneId, )

src/raft/client.rs:1160

↓ 1 callersMethodcommand_on_plane

( &self, plane_id: PlaneId, sm_id: u64, fn_id: u64, data: Vec<u8>,

src/raft/client.rs:802

↓ 1 callersMethodcompact_logs_after_snapshot

Compact logs after a snapshot has been created

src/raft/mod.rs:3172

↓ 1 callersMethodcurrent_leader_rpc_client

(&self)

src/raft/client.rs:1152

↓ 1 callersFunctiondecode_res

(res: io::Result<BytesMut>)

src/rpc/mod.rs:81

↓ 1 callersMethoddel_member_

(&mut self, address: String)

src/raft/state_machine/configs.rs:74

↓ 1 callersFunctionduration_to_ms

(duration: Duration)

src/utils/time.rs:13

↓ 1 callersMethodensure_plane_membership

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

src/raft/mod.rs:1281

↓ 1 callersMethodequals

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

src/vector_clock/mod.rs:108

↓ 1 callersMethoderror

(&self, message: String)

src/rpc/mod.rs:394

↓ 1 callersFunctiongen_rand

(lower: i64, higher: i64)

src/raft/mod.rs:178

↓ 1 callersMethodget_server_id

(&self)

src/raft/mod.rs:2007

↓ 1 callersMethodget_sub_key

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

src/raft/client.rs:570

↓ 1 callersMethodget_weights

(&self, group: u64)

src/conshash/weights.rs:29

↓ 1 callersMethodgroup_first_online_member_id

(&self, group: u64)

src/membership/server.rs:490

↓ 1 callersMethodgroup_members

( &self, group: &String, online_only: bool, )

src/membership/client.rs:68

↓ 1 callersMethodhave_state_machine_on_plane

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

src/raft/client.rs:1178

↓ 1 callersMethodid

(&self)

src/membership/server.rs:869

↓ 1 callersMethodinit_callback

(&mut self, raft_service: &Arc<RaftService>)

src/membership/server.rs:360

↓ 1 callersMethodinsert_leader_follower_meta

( &self, leader_meta: &mut RwLockWriteGuard<LeaderMeta>, last_log_id: u64, mem

src/raft/mod.rs:2067

↓ 1 callersFunctionis_local

(server_id: u64)

src/tcp/shortcut.rs:37

↓ 1 callersMethodis_recoverable

Whether a given state machine id should be persisted/recovered.

src/raft/state_machine/master.rs:111

↓ 1 callersFunctionis_reserved_internal_sm_id

(sm_id: u64)

src/raft/state_machine/mod.rs:47

↓ 1 callersMethodis_type2

(self)

src/raft/mod.rs:70

↓ 1 callersMethodjoin

(&mut self, address: String)

src/membership/server.rs:634

↓ 1 callersMethodjump_hash

(&self, slot_count: usize, hash: u64)

src/conshash/mod.rs:200

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