Struct Core 

pub struct Core {
    pub graph: Graph,
    pub packages: Vec<Package>,
    pub request_channel: (UnboundedSender<Request>, UnboundedReceiver<Request>),
    pub event_map: HashMap<(String, String), Vec<NodeRef>>,
}

Fields

graph: Graph

packages: Vec<Package>

request_channel: (UnboundedSender<Request>, UnboundedReceiver<Request>)

event_map: HashMap<(String, String), Vec<NodeRef>>

Implementations

impl Core

pub fn new() -> Self

pub fn register_package(&mut self, package: Package)

pub fn package(&self, name: &str) -> Option<&Package>

pub async fn start_engines(&self)

pub fn create_node(&mut self, package: &str, schema: &str) -> Option<NodeRef>

pub fn connect_io( &mut self, output_node: i32, output: &str, input_node: i32, input: &str, ) -> Result<(), ConnectIOError>

pub async fn start(&mut self)

pub async fn handle_event(&self, event: Event)