awaken-runtime 0.4.0

Phase-based execution engine, plugin system, and agent loop for Awaken
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

//! Internal runtime plugins — state keys for action queues.

use crate::plugins::{Plugin, PluginDescriptor, PluginRegistrar};
use crate::state::StateKeyOptions;
use awaken_contract::StateError;
use awaken_contract::model::{FailedScheduledActions, PendingScheduledActions};

/// Internal plugin that registers runtime queue state keys.
pub(crate) struct RuntimeQueuePlugin;

impl Plugin for RuntimeQueuePlugin {
    fn descriptor(&self) -> PluginDescriptor {
        PluginDescriptor {
            name: "phase-runtime",
        }
    }

    fn register(&self, registrar: &mut PluginRegistrar) -> Result<(), StateError> {
        let runtime_options = StateKeyOptions {
            persistent: true,
            retain_on_uninstall: false,
            scope: crate::state::KeyScope::Run,
        };
        registrar.register_key::<PendingScheduledActions>(runtime_options)?;
        registrar.register_key::<FailedScheduledActions>(runtime_options)?;
        Ok(())
    }
}