boson-backend-mem 0.1.1

In-memory QueueBackend adapter for tests, CI, and testkit
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

//! Task config persistence helpers for the in-memory backend.

use boson_core::TaskConfig;

use crate::store::Inner;

/// Load task config by name.
pub fn get_task_config(inner: &Inner, task_name: &str) -> Option<TaskConfig> {
    inner.task_configs.get(task_name).cloned()
}

/// Persist task config.
pub fn upsert_task_config(inner: &mut Inner, config: &TaskConfig) {
    inner
        .task_configs
        .insert(config.task_name.clone(), config.clone());
}