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

use crate::error::ActionHandlerError;
use actrpc_core::{
    action::{ActionKind, RequestedActionRecord, ResolvedActionRecord},
    interception::InterceptionRequest,
};
use std::{future::Future, pin::Pin};

pub type ActionHandlerResult = Result<ResolvedActionRecord, ActionHandlerError>;

pub type ActionHandlerFuture<'a, T = ActionHandlerResult> =
    Pin<Box<dyn Future<Output = T> + Send + 'a>>;

pub trait ActionHandler: Send + Sync {
    fn kind(&self) -> ActionKind;

    fn handle<'a>(
        &'a self,
        request: &'a InterceptionRequest,
        action: RequestedActionRecord,
    ) -> ActionHandlerFuture<'a>
    where
        Self: 'a;
}