Functions — github.com/ShisoftResearch/bifrost

hub / github.com/ShisoftResearch/bifrost / functions

Functions541 in github.com/ShisoftResearch/bifrost

⨍ Functions 541◇ Types & classes 103

Methodgroup_leader

(&self, group_id: u64)

src/membership/server.rs:801

Methodgroup_leader

( &self, group: &String, )

src/membership/client.rs:62

Methodgroup_members

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

src/membership/server.rs:817

Functionhash_bytes_secondary

(bytes: &[u8])

src/hasher/src/lib.rs:18

Functionhash_ident

(item: TokenStream)

src/plugins/src/lib.rs:11

Methodhave_state_machine

(&self, sm_id: u64)

src/raft/mod.rs:484

Methodhave_state_machine

(&self, sm_id: u64)

src/raft/client.rs:118

Methodhb_online_changed

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

src/membership/server.rs:592

Methodid

(&self)

src/raft/state_machine/configs.rs:107

Methodid

(&self)

src/conshash/weights.rs:49

Methodinitialize

(server: &Arc<Server>)

src/raft/state_machine/callback/client.rs:45

Methodinternal_subscribe

(&self, msg: M, trigger: F)

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

Methodis_leader_for_real

(&self)

src/raft/mod.rs:1997

Methodjoin_group

(&mut self, group_name: String, id: u64)

src/membership/server.rs:706

Methodjoin_group

(&self, group: &String)

src/membership/client.rs:33

src/raft/client.rs:1076

Methodleader_id

(&self)

src/raft/client.rs:1072

Methodleave

(&mut self, id: u64)

src/membership/server.rs:681

Methodleave_group

(&self, group: &String)

src/membership/member.rs:84

Methodleave_group

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

src/membership/server.rs:752

Methodleave_group

(&self, group: &String)

src/membership/client.rs:36

Methodlifecycle_is_stopping

(state: LifecycleState)

src/raft/mod.rs:619

Methodlisten_and_resume

(server: &Arc<Server>)

src/rpc/mod.rs:165

Methodload_snapshot_into_meta

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

src/raft/mod.rs:914

Methodload_snapshot_on_startup

Load snapshot from disk and recover state machine if snapshot exists

src/raft/mod.rs:1580

Methodloaded_type2_planes

Returns only the type-2 plane runtimes that are currently materialized on this host. This is a local runtime-cache view, not an authoritative plane i

src/raft/mod.rs:1334

Functionloaded_type2_planes_only_reports_materialized_type2_runtimes

()

src/raft/mod.rs:3739

Functionlog_replication

examples/graceful_shutdown.rs:15

Functionmulti_server_command

()

src/raft/mod.rs:4724

Functionmulti_server_rpc

src/utils/bindings.rs:18

Methodnew

( server_address: &String, raft_client: &Arc<RaftClient>, raft_service: &Arc<RaftServi

src/membership/member.rs:27

Methodnew

Creates a new Membership service with fresh, empty state. The service will discover members through: - join() commands from members joining the clust

src/membership/server.rs:188

Methodnew

(raft_client: &Arc<RaftClient>)

src/membership/client.rs:46

(client: &Arc<RPCClient>)

(servers: &Vec<String>, service_id: u64)

src/raft/client.rs:154

Methodnew

(service_id: u64)

src/raft/state_machine/configs.rs:137

Methodnew

(service_id: u64)

src/raft/state_machine/master.rs:96

Methodnew

( service_id: u64, plane_id: PlaneId, sm_id: u64, fn_id: u64, pattern_

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

Methodnew

()

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

Methodnew

()

src/vector_clock/mod.rs:50

Methodnew

( group: &str, raft_client: &Arc<RaftClient>, membership_client: &Arc<MembershipClient

src/conshash/mod.rs:144

Methodnew

(raft_service: &Arc<RaftService>)

src/conshash/weights.rs:78

( group: &str, raft_client: &Arc<RaftClient>, membership_client: &Arc<MembershipClient

src/conshash/mod.rs:151

Methodnew_client_with_id

( id: u64, group: &str, raft_client: &Arc<RaftClient>, membership_client: &Arc

src/conshash/mod.rs:158

Methodnew_from_sm

(sm_client: &Arc<SMClient>)

src/membership/client.rs:51

Methodnew_on_plane

(service_id: u64, plane_id: PlaneId)

src/raft/state_machine/master.rs:100

Methodnew_on_plane

( state_machine_id: u64, plane_id: PlaneId, raft_service: Arc<RaftService>, )

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

Methodnew_plane_state

()

src/raft/client.rs:145

Methodnew_server

New server without recovery from registered state machine

src/raft/mod.rs:1680

Methodnew_with_id

( id: u64, group: &str, raft_client: &Arc<RaftClient>, membership_client: &Arc

src/conshash/mod.rs:55

Methodnew_with_id

(id: u64, raft_service: &Arc<RaftService>)

src/conshash/weights.rs:70

Methodnew_with_options

( opts: &Options, term: &mut u64, commit_index: &mut u64, last_applied: &mut u

src/raft/disk.rs:131

Methodnew_with_options_on_plane

( plane_id: PlaneId, opts: &Options, term: &mut u64, commit_index: &mut u64,

src/raft/disk.rs:148

Methodnew_with_service_id

(server_id: u64, client: &Arc<RPCClient>)

src/rpc/mod.rs:348

Methodnodes_count

(&self)

src/conshash/mod.rs:247

Functionnotify

(callback: &Option<SMCallback>, msg: M, data: F)

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

Methodnotify

(&'a self, key: SubKey, data: &'a Vec<u8>)

src/raft/state_machine/callback/client.rs:19

Methodop_type_

(&self, _fn_id: u64)

src/raft/state_machine/master.rs:797

Methodpartial_cmp

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

src/vector_clock/mod.rs:20

Methodping

(&self, id: u64)

src/membership/server.rs:50

Methodplane_id

(&self)

src/raft/client.rs:77

Methodprepare_subscription

(server: &Arc<rpc::Server>)

src/raft/client.rs:212

Functionprimary

()

src/membership/mod.rs:64

Functionprimary

()

src/conshash/mod.rs:418

Methodprobe_servers

( servers: &Vec<String>, server_address: &String, service_id: u64, )

src/raft/client.rs:503

Functionquery_and_command

()

src/raft/mod.rs:4689

Functionquery_counter_locally

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

src/raft/mod.rs:3641

Methodrand_server

(&self)

src/conshash/mod.rs:239

Methodrand_server_id

(&self)

src/conshash/mod.rs:243

Methodrecover

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

src/membership/server.rs:879

Methodrecover

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

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

Methodrecover

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

src/conshash/weights.rs:55

Methodrecover_config_state_from_logs

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

src/raft/mod.rs:993

Methodrecoverable

(&self)

src/membership/server.rs:884

src/raft/state_machine/configs.rs:131

Methodrecoverable

(&self)

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

Methodrecoverable

(&self)

src/conshash/weights.rs:65

Methodremove_service

(&self, service_id: u64)

src/rpc/mod.rs:271

Functionroot_membership_helpers_hide_config_sm_commands

()

src/raft/mod.rs:3867

Methodsend_async

( self: Pin<&Self>, svr_id: u64, data: BytesMut, )

src/rpc/mod.rs:293

Methodsend_follower_heartbeat

( plane_id: PlaneId, commit_index: u64, term: u64, leader_id: u64, las

src/raft/mod.rs:2442

Methodserver_count

(&self)

src/conshash/mod.rs:251

Functionserver_membership

src/utils/bindings.rs:32

Methodset_weight

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

src/conshash/weights.rs:20

Methodshutdown

(&self)

src/membership/server.rs:121

src/membership/server.rs:872

Methodsnapshot

(&self)

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

Methodsnapshot

(&self)

src/conshash/weights.rs:52

← previous next →301–400 of 541, ranked by callers