risingwave_meta/rpc/election/
mod.rs

1// Copyright 2025 RisingWave Labs
2//
3// Licensed under the Apache License, Version 2.0 (the "License");
4// you may not use this file except in compliance with the License.
5// You may obtain a copy of the License at
6//
7//     http://www.apache.org/licenses/LICENSE-2.0
8//
9// Unless required by applicable law or agreed to in writing, software
10// distributed under the License is distributed on an "AS IS" BASIS,
11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12// See the License for the specific language governing permissions and
13// limitations under the License.
14
15pub mod dummy;
16pub mod sql;
17
18use serde::Serialize;
19use tokio::sync::watch::Receiver;
20
21use crate::MetaResult;
22
23const META_ELECTION_KEY: &str = "__meta_election_";
24
25#[derive(Debug, Serialize)]
26pub struct ElectionMember {
27    pub id: String,
28    pub is_leader: bool,
29}
30
31#[async_trait::async_trait]
32pub trait ElectionClient: Send + Sync + 'static {
33    async fn init(&self) -> MetaResult<()> {
34        Ok(())
35    }
36
37    fn id(&self) -> MetaResult<String>;
38    /// Run the long-running election process.
39    ///
40    /// Returns when the leader status is lost, or the stop signal is received.
41    async fn run_once(&self, ttl: i64, stop: Receiver<()>) -> MetaResult<()>;
42    fn subscribe(&self) -> Receiver<bool>;
43    async fn leader(&self) -> MetaResult<Option<ElectionMember>>;
44    async fn get_members(&self) -> MetaResult<Vec<ElectionMember>>;
45    fn is_leader(&self) -> bool;
46}
risingwave_meta/rpc/election/mod.rs

risingwave_meta/rpc/election/
mod.rs
