floria 0.0.5

Floria data system for cloud orchestration
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
29
30
31
32
33
34
35
36
37
38
39
40
41
42

use super::{
    super::super::{
        super::{errors::*, plugins, store::*},
        expression::*,
    },
    call::*,
};

use kutil::std::error::*;

impl Call {
    /// Dispatch.
    pub fn dispatch<StoreT, ErrorReceiverT>(
        self,
        call_site: &plugins::CallSite,
        library: &mut plugins::Library<StoreT>,
        errors: &mut ErrorReceiverT,
    ) -> Result<Option<Expression>, FloriaError>
    where
        StoreT: Clone + Send + Store,
        ErrorReceiverT: ErrorReceiver<FloriaError>,
    {
        tracing::debug!("call: {}", self);

        let mut arguments = Vec::with_capacity(self.arguments.len());
        for argument in self.arguments {
            let argument = argument.evaluate(call_site, library, errors)?.unwrap_or_default();
            arguments.push(argument);
        }

        let plugin = library.dispatch_plugin(&self.plugin)?;
        let mut plugin = plugin.lock().map_err(plugins::PluginError::from)?;

        Ok(match plugin.dispatch(&self.function, arguments, call_site) {
            Ok(expression) => expression,
            Err(error) => {
                errors.give(error)?;
                None
            }
        })
    }
}