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
29
30
31
32
33
34
35
36

//! Reactors are actors that are used to manage workflows for specific stream names. This is a
//! pull mechanism for dynamic workflow capabilities in mmids. When a reactor is asked for a
//! workflow for a stream name, the reactor will reach out to an external service (configured
//! by a reactor executor) to obtain a workflow definition for the requested stream name. If none
//! is returned then that normally means the stream name is not allowed. If a valid workflow
//! definition is returned, the reactor will ensure that the workflow is created so media can be
//! routed to it.

pub mod executors;
pub mod manager;
mod reactor;

use std::collections::HashMap;
use std::time::Duration;

pub use reactor::{start_reactor, ReactorRequest, ReactorWorkflowUpdate};

/// How reactors are defined
#[derive(Clone, Debug)]
pub struct ReactorDefinition {
    /// The name of the reactor. Used by endpoints and workflow steps to identify which workflow
    /// they want to interact with.
    pub name: String,

    /// The name of the query executor this reactor should use to perform queries
    pub executor: String,

    /// How many seconds the reactor should wait before it re-runs the executor and gets the latest
    /// version of the corresponding workflow definition. An update interval of 0 (or a value not
    /// specified) means it will never update.
    pub update_interval: Duration,

    /// Key value pairs used to instruct the reactor's executor. Valid values here are specific
    /// to the executor that was picked.
    pub parameters: HashMap<String, Option<String>>,
}