 Jing Yang
|
f9d2a15e8e
Remove "me" from the raft peers array.
|
пре 3 година |
|
Jing Yang
|
10ac3235eb
Make run_election_timer() a simple function.
|
пре 3 година |
|
Jing Yang
|
7329e47622
Add rpc_client and beat_ticker to the context.
|
пре 3 година |
|
Jing Yang
|
ff45298c67
Replace term marker with a static remote context.
|
пре 3 година |
|
Jing Yang
|
8ba3253faf
Minor code rearrangement.
|
пре 3 година |
|
Jing Yang
|
91f0b0138b
Remove the special logging treatment for the start() API.
|
пре 3 година |
|
Jing Yang
|
914409a197
Add documentation for RaftJoinHandler::join().
|
пре 3 година |
|
Jing Yang
|
4161b3f24d
Remove the clone requirement of daemon_env.
|
пре 3 година |
|
Jing Yang
|
a959f7a175
Construct a join handle upfront.
|
пре 3 година |
|
Jing Yang
|
9796a49bdc
Move election.rs to the new standalone daemon_watch.
|
пре 3 година |
|
Jing Yang
|
2a2e55a7bb
Move verify_authority.rs to using the new standalone daemon_watch.
|
пре 3 година |
|
Jing Yang
|
24715e57e3
Move snapshot.rs to using the new standalone daemon_watch.
|
пре 3 година |
|
Jing Yang
|
0a93a0d6a5
Move sync_log_entries.rs to using the new standalone daemon_watch.
|
пре 3 година |
|
Jing Yang
|
496ad0d7d7
Move apply_command.rs to using the standalone daemon_watch.
|
пре 3 година |
|
Jing Yang
|
c71fd0fa03
Move the join logic to a standalone handler.
|
пре 3 година |
|
Jing Yang
|
5fe90f62fe
Refactor: move DaemonWatch out of DaemonEnv.
|
пре 3 година |
|
Jing Yang
|
89d892c17c
Address clippy warnings.
|
пре 3 година |
|
Jing Yang
|
e026ab6803
Move next_index and current_step out of RaftState.
|
пре 3 година |
|
Jing Yang
|
2f66c3fa08
Create an explicit enum for sync log entry events.
|
пре 3 година |
|
Jing Yang
|
0b29f77341
Wrap data of the sync log entries daemon in opaque structs.
|
пре 3 година |
|
Jing Yang
|
ca59d5b7ac
Replace SeqCst ordering with more relaxed ones in keep_running.
|
пре 3 година |
|
Jing Yang
|
27a9165052
Create a const for shutdown timeout.
|
пре 3 година |
|
Jing Yang
|
6d22246e50
Merge stop_wait_group into daemon env.
|
пре 3 година |
|
Jing Yang
|
28082ff335
Replace Arc<Runtime> with a custom thread pool holder.
|
пре 3 година |
|
Jing Yang
|
4ff6966997
Use concreate type when initializing raft.
|
пре 3 година |
|
Jing Yang
|
26321803c4
Minor refactor: set keep_running to true at creation.
|
пре 3 година |
|
Jing Yang
|
7d8b309287
Explicitly list the requirement for commands.
|
пре 3 година |
|
Jing Yang
|
66cccb5847
Make HEARTBEAT_INTERVAL a Duration.
|
пре 3 година |
|
Jing Yang
|
baf22fec60
Use `IndexTerm` in public API.
|
пре 3 година |
|
Jing Yang
|
69c1c1565e
Split lib.rs into messages.rs and raft.rs.
|
пре 3 година |
