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.
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
27 Sep 8, 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
448 Jan 2, 2023
5 Nov 17, 2022
5 Aug 15, 2022
4 Jun 14, 2023