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

use crate::{
    interceptor::InterceptorCatalog,
    method::MethodCatalog,
    review::{ReviewProvider, UnavailableReviewProvider},
};
use std::sync::Arc;

#[derive(Clone)]
pub struct OrchestratorResources {
    pub interceptor_catalog: Arc<InterceptorCatalog>,
    pub method_catalog: Arc<MethodCatalog>,
    pub review_provider: Arc<dyn ReviewProvider>,
}

impl OrchestratorResources {
    pub fn new(
        interceptor_catalog: Arc<InterceptorCatalog>,
        method_catalog: Arc<MethodCatalog>,
    ) -> Self {
        Self {
            interceptor_catalog,
            method_catalog,
            review_provider: Arc::new(UnavailableReviewProvider),
        }
    }

    pub fn with_review_provider(
        interceptor_catalog: Arc<InterceptorCatalog>,
        method_catalog: Arc<MethodCatalog>,
        review_provider: Arc<dyn ReviewProvider>,
    ) -> Self {
        Self {
            interceptor_catalog,
            method_catalog,
            review_provider,
        }
    }
}