Functions — github.com/ShisoftResearch/bifrost

hub / github.com/ShisoftResearch/bifrost / functions

Functions541 in github.com/ShisoftResearch/bifrost

⨍ Functions 541◇ Types & classes 103

↓ 1 callersMethodlarge_query

(&self, req: Option<String>)

src/rpc/mod.rs:521

↓ 1 callersMethodlarge_req

( &self, mut req: Vec<ComplexAnswer>, mut req2: Vec<ComplexAns

src/rpc/mod.rs:533

↓ 1 callersMethodleader_append_log

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

src/raft/mod.rs:2942

↓ 1 callersMethodleader_candidate_available

(&mut self, member: u64)

src/membership/server.rs:575

↓ 1 callersMethodleader_candidate_unavailable

(&mut self, member: u64)

src/membership/server.rs:582

↓ 1 callersMethodmembership

(&self)

src/conshash/mod.rs:361

↓ 1 callersMethodnew_group

(&mut self, name: String)

src/membership/server.rs:759

↓ 1 callersMethodnew_member_

(&mut self, address: String)

src/raft/state_machine/configs.rs:47

↓ 1 callersMethodnotify_for_member_left

(&self, id: u64)

src/membership/server.rs:423

↓ 1 callersMethodnotify_for_member_offline

(&self, id: u64)

src/membership/server.rs:393

↓ 1 callersMethodnotify_for_member_online

(&self, id: u64)

src/membership/server.rs:363

↓ 1 callersMethodnum_members

(&self)

src/raft/mod.rs:1977

↓ 1 callersMethodon_any_member_joined

( &self, f: F, )

src/membership/client.rs:134

↓ 1 callersMethodon_any_member_left

( &self, f: F, )

src/membership/client.rs:155

↓ 1 callersMethodon_any_member_offline

( &self, f: F, )

src/membership/client.rs:92

↓ 1 callersMethodon_any_member_online

( &self, f: F, )

src/membership/client.rs:113

↓ 1 callersMethodon_group_leader_changed

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

src/membership/client.rs:164

↓ 1 callersFunctionoptions_for_plane

(opts: &Options, plane_id: PlaneId)

src/raft/mod.rs:503

↓ 1 callersMethodparse

(input: ParseStream)

src/proc_macro/src/lib.rs:16

↓ 1 callersMethodplane_has_persisted_state

(&self, plane_id: PlaneId)

src/raft/mod.rs:903

↓ 1 callersMethodplane_id

(&self)

src/raft/mod.rs:604

↓ 1 callersMethodplane_member_addresses

(&self, plane_id: PlaneId)

src/raft/mod.rs:1199

↓ 1 callersMethodplane_members_from_seed_nodes

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

src/raft/mod.rs:1181

↓ 1 callersMethodplane_storage_path

(&self, plane_id: PlaneId)

src/raft/mod.rs:894

↓ 1 callersMethodpost_processing

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

src/raft/disk.rs:323

↓ 1 callersMethodpreferred_client_on_plane

(&self, state: &PlaneClientState)

src/raft/client.rs:1086

↓ 1 callersFunctionprepend_u64

(num: u64, data: BytesMut)

src/rpc/mod.rs:285

↓ 1 callersMethodquery_answer

(&self, req: Option<String>)

src/rpc/mod.rs:512

↓ 1 callersMethodquery_on_plane

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

src/raft/client.rs:685

↓ 1 callersMethodquery_server_id

↓ 1 callersMethodread_commit_progress

Read commit progress if available

src/raft/disk.rs:401

↓ 1 callersMethodrecover_after_register_on_plane

( &self, plane_id: PlaneId, )

src/raft/mod.rs:1339

↓ 1 callersMethodrecover_members

(&mut self, snapshot: MemberConfigSnapshot)

src/raft/state_machine/configs.rs:144

↓ 1 callersMethodreelect

(&'a self, plane_id: PlaneId)

src/raft/mod.rs:3480

↓ 1 callersFunctionregister_server

( server_address: &String, callback: &Arc<dyn TcpCallbackFuncShareable>, )

src/tcp/shortcut.rs:17

↓ 1 callersMethodregister_state_machine_on_plane

( &self, plane_id: PlaneId, state_machine: SubStateMachine, )

src/raft/mod.rs:1363

↓ 1 callersMethodrequest_vote

( &self, plane_id: PlaneId, term: u64, candidate_id: u64, last_log_id:

src/raft/mod.rs:3277

↓ 1 callersMethodsend_followers_heartbeat

( &'a self, meta: &mut RwLockWriteGuard<'a, RaftMeta>, log_id: Option<u64>, no

src/raft/mod.rs:2432

↓ 1 callersMethodsend_msg

(&self, msg: TcpReq)

src/tcp/client.rs:97

↓ 1 callersMethodshutdown_handle

(&self)

src/tcp/server.rs:29

↓ 1 callersMethodshutdown_plane

(&self, plane_id: PlaneId)

src/raft/mod.rs:1468

↓ 1 callersMethodsubscriptions_on_plane

( &self, plane_id: PlaneId, )

src/raft/mod.rs:1379

↓ 1 callersMethodto_clock

(&self)

src/vector_clock/mod.rs:292

↓ 1 callersMethodto_server_name

(&self, server_id: u64)

src/conshash/mod.rs:172

↓ 1 callersMethodto_server_name_option

(&self, server_id: Option<u64>)

src/conshash/mod.rs:181

↓ 1 callersMethodtransfer_leadership

(&self)

src/membership/server.rs:100

↓ 1 callersMethodtry_sync_config_to_followers_on_plane

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

src/raft/mod.rs:3051

↓ 1 callersMethodtry_sync_log_to_followers_on_plane

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

src/raft/mod.rs:2980

↓ 1 callersMethodupdate_raft

(&self, online: &Vec<u64>, offline: &Vec<u64>)

src/membership/server.rs:83

↓ 1 callersMethodvalidate_plane_bootstrap

( &self, bootstrap: PlaneBootstrap, )

src/raft/mod.rs:1165

↓ 1 callersMethodwatch_all_actions

(&self, f: F)

src/conshash/mod.rs:261

Methodadd

(&mut self, value: u64)

src/raft/mod.rs:3563

Functionadd_counter_locally

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

src/raft/mod.rs:3661

Functionadjust_caller_identifiers

(input: TokenStream)

src/proc_macro/src/lib.rs:23

Functionadjust_function_signature

(input: TokenStream)

src/proc_macro/src/lib.rs:64

Methodall_groups

(&self)

src/membership/server.rs:863

Methodall_groups

(&self)

src/membership/client.rs:179

Methodall_members

(&self, online_only: bool)

src/membership/server.rs:844

Methodanswer_to_the_universe

(&'a self, name: String)

src/raft/mod.rs:4653

Methodas_raft_plane_client

(self: &Arc<Self>)

src/raft/client.rs:133

Functionavg_scale

(nums: &Vec<u64>)

src/utils/math.rs:19

Functionbroadcast_to_members

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

src/rpc/cluster.rs:13

src/raft/client.rs:567

Methodcanonicalize_member_addresses

(mut members: Vec<String>)

src/raft/mod.rs:1159

Methodcheck_plane

(&self, plane_id: PlaneId)

src/raft/mod.rs:608

Methodclient

(&self)

src/membership/member.rs:87

Methodcmp

(&self, other: &Self)

src/vector_clock/mod.rs:32

Methodconnect

(address: &String)

src/tcp/client.rs:94

Methodconnect_with_timeout

(address: &String, timeout: Duration)

src/tcp/client.rs:34

Methodconservative_bootstrap

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

src/raft/mod.rs:1721

Methoddecode

Decode payload bytes (without the length prefix or CRC — the caller strips those).

src/utils/bindings.rs:37

Methoddel_group

(&mut self, id: u64)

src/membership/server.rs:780

Methoddel_group

(&self, name: &String)

src/membership/client.rs:59

Functionderef_tuple_types

(input: TokenStream)

src/proc_macro/src/lib.rs:108

Methoddispatch_cmd_

( &'a mut self, fn_id: u64, data: &'a Vec<u8>, )

src/raft/state_machine/master.rs:738

Methoddispatch_qry_

( &'a self, fn_id: u64, data: &'a Vec<u8>, )

src/raft/state_machine/master.rs:771

Methoddrop

(&mut self)

src/membership/member.rs:96

Methoddrop

(&mut self)

src/membership/server.rs:174

Functiondummy

()

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

Functiondummy_type2_plane

()

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

Methodecho

(&self, msg: String)

src/rpc/cluster.rs:109

Methodfmt

(&self, f: &mut Formatter<'_>)

src/raft/mod.rs:76

Methodfmt

(&self, f: &mut std::fmt::Formatter<'_>)

src/raft/client.rs:37

Methodfmt

(&self, f: &mut Formatter)

src/raft/state_machine/master.rs:262

src/vector_clock/mod.rs:54

Functiongeneral

()

src/vector_clock/mod.rs:305

Methodget

(&self)

src/utils/bindings.rs:24

Methodget_id

(&self)

src/rpc/cluster.rs:105

Methodget_log_info_

(&self, log: Option<(&u64, &LogEntry)>)

src/raft/mod.rs:2061

Methodget_server_by

(&self, obj: &T)

src/conshash/mod.rs:224

Methodget_server_id

(&self)

src/membership/member.rs:90

Methodget_server_id_by

(&self, obj: &T)

src/conshash/mod.rs:233

Methodget_server_id_by_string

(&self, string: &String)

src/conshash/mod.rs:230

Methodget_weight

(&self, group: u64, id: u64)

src/conshash/weights.rs:36

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