第一种方式确保在任何时间点租约都处于锁定状态（有持有者）。第二种方式使您能够在需要时获取和释放锁定。

示例

使用第一种锁定方法的简单示例

use kube::Client;
use kube_lease_manager::{LeaseManagerBuilder, Result};
use std::time::Duration;

#[tokio::main]
async fn main() {
   // Use default Kube client
   let client = Client::try_default().await?;
   // Create the simplest LeaseManager with reasonable defaults using convenient builder.
   // It uses Lease resource called `test-watch-lease`.
   let manager = LeaseManagerBuilder::new(client, "test-watch-lease")
           .build()
           .await?;

   let (mut channel, task) = manager.watch().await;
   // Watch on the channel for lock state changes
   tokio::select! {
        _ = channel.changed() => {
            let lock_state = *channel.borrow_and_update();

            if lock_state {
                // Do something useful as a leader
                println!("Got a luck!");
            }
        }
        _ = tokio::time::sleep(Duration::from_secs(10)) => {
            println!("Unable get lock during 10s");
        }
    }

   // Explicitly close the control channel
   drop(channel);
   // Wait for the finish of the manager and get it back
   let _manager = tokio::join!(task).0.unwrap()?;

   Ok(())
}

请访问 crate 的文档 获取更多示例和用法细节。

待办事项

• 提供一些真实且有用的示例。

致谢

作者受到两个其他提供类似功能的 crate 的启发： kubert 和 kube-leader-election。它们都很棒，感谢作者们。但它们都缺少我项目中的一个东西。因此，这是创建这个的原因。

许可证

本项目根据 MIT 许可证 许可。