actrpc-orchestrator 0.1.0

Configuration and orchestration utilities for ActRPC.
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

use crate::{
    action::available_actions, config::OrchestratorConfig, error::OrchestratorError,
    interceptor::InterceptorCatalog, method::MethodCatalog, review::ReviewProvider,
    runtime::OrchestratorResources,
};
use actrpc_transport::{JsonRpcClient, JsonRpcClientProvider, TransportError};
use std::sync::Arc;

impl OrchestratorConfig {
    pub async fn build_resources<P>(
        self,
        provider: &P,
        review_provider: Arc<dyn ReviewProvider>,
    ) -> Result<OrchestratorResources, OrchestratorError>
    where
        P: JsonRpcClientProvider<
                Client = Arc<dyn JsonRpcClient<Error = TransportError>>,
                Error = TransportError,
            > + Send
            + Sync,
    {
        let method_catalog = MethodCatalog::from_configs(self.methods, provider).await?;

        let interceptor_catalog = InterceptorCatalog::build_from_configs(
            self.interceptors,
            self.pipelines.outbound,
            self.pipelines.inbound,
            &available_actions(),
            provider,
        )
        .await?;

        Ok(OrchestratorResources::with_review_provider(
            Arc::new(interceptor_catalog),
            Arc::new(method_catalog),
            review_provider,
        ))
    }
}