Kube Coordinate
Kube Coordinate builds upon the kube-rs ecosystem, and implements a streamlined version of the client-go leader election system. This implementation uses only Lease objects for coordination.
// Spawn a leader elector task, and get a handle to the state channel.
let handle = LeaderElector::spawn(/* ... */);
let state_chan = handle.state();
// Before taking action as a leader, just check the channel to ensure
// the lease is currently held by this process.
if state_chan.borrow().is_leader() {
// Only perform leader actions if in leader state.
}
// Or, for a more sophisticated pattern, watch the state channel for changes,
// and use it to drive your application's state machine.
let state_stream = tokio_stream::wrappers::WatchStream::new(state_chan);
loop {
tokio::select! {
Some(state) = state_stream.next() => match state {
LeaderState::Leader => (), // Leader tasks.
_ => (), // Non-leader tasks.
},
}
}
Install
cargo add kube-coordinate
License
kube-coordinate is licensed under the terms of the MIT License or the Apache License 2.0, at your choosing.
4 Jun 14, 2023
1.6k Jan 4, 2023
91 Jan 1, 2023
915 Jan 4, 2023
103 Dec 29, 2022
8 Feb 10, 2022
1.8k Jan 8, 2023
4 Mar 4, 2022
650 Dec 29, 2022
12 Apr 27, 2022
3 Nov 10, 2022
244 Dec 17, 2022
9.2k Jan 1, 2023
1 Jan 22, 2022
6 Nov 8, 2022
63 Dec 17, 2022
10 Nov 17, 2022
13 Nov 5, 2023
33 Dec 29, 2022
4 Aug 11, 2023
3 Feb 26, 2024
168 Dec 19, 2022
16 Nov 12, 2022
11 May 1, 2024
448 Jan 2, 2023
5 Nov 17, 2022
5 Aug 15, 2022