ns_game 0.2.26

ns_game lib.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use crate::card_service::replay::IRePlayClickHouseDB;
use crate::static_def::REPLAY_DB;
use crate::timer::Timer;

/// 提交回放数据
pub struct CommitReplayTimer;

#[async_trait::async_trait]
impl Timer for CommitReplayTimer {
    /// 每10秒检查一次
    #[inline]
    async fn init(&self) -> anyhow::Result<(bool, u64)> {
        Ok((false, 5000))
    }

    #[inline]
    async fn run(&self) -> anyhow::Result<()> {
        REPLAY_DB.commit().await?;
        Ok(())
    }
}