Struct Health

pub struct Health {
    config: HealthConfig,
    wakeup_list_check: Vec<NaiveTime>,
    wakeup_list_tweet: Vec<NaiveTime>,
    history: VecDeque<HistoryEntry>,
}

ヘルスチェックシステムモジュール。

Fields

config: HealthConfig

設定データ。

wakeup_list_check: Vec<NaiveTime>

定期実行の時刻リスト。

wakeup_list_tweet: Vec<NaiveTime>

定期実行の時刻リスト。

history: VecDeque<HistoryEntry>

測定データの履歴。最大サイズは HISTORY_QUEUE_SIZE。

Implementations

impl Health

pub fn new( wakeup_list_check: Vec<NaiveTime>, wakeup_list_tweet: Vec<NaiveTime>, ) -> Result<Self>

コンストラクタ。

設定の読み込みのみ行い、async task の初期化は Self::on_start で行う。

async fn check_task(&mut self, _ctrl: &Control) -> Result<()>

測定タスク。 Self::history に最新データを追加する。

async fn tweet_task(&self, ctrl: &Control) -> Result<()>

ツイートタスク。 Self::history の最新データが存在すればツイートする。

async fn check_task_entry(ctrl: Control) -> Result<()>

Self::check_task のエントリ関数。 モジュールをロックしてメソッド呼び出しを行う。

async fn tweet_task_entry(ctrl: Control) -> Result<()>

Self::tweet_task のエントリ関数。 モジュールをロックしてメソッド呼び出しを行う。

Trait Implementations

impl SystemModule for Health

fn on_start(&mut self, ctrl: &Control)

SystemModule の初期化時には [crate::sys::taskserver::TaskServer] がまだ存在しないので タスクの登録はこのタイミングまで遅延させる。