dope-manifold 0.22.0

Owned application and service composition for dope
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
43
44
45
46
47
48
49

use dope_core::driver::route::Identity;
use o3::base::cell::region;

use crate::{
    client::attempt,
    service::{
        self, discover,
        pool::{dials, members},
        sync,
    },
};

impl<'q, 'h, 'd, T, R, I, const N: usize, F, ID: Identity> attempt::Peer<'d, T, ID>
    for service::Pool<'q, 'h, 'd, ID, T, R, I, N, F>
where
    T: dope_net::Transport,
    R: sync::Policy,
    I: Eq,
    F: discover::Eligibility<'d, I>,
{
    type Target = I;

    fn attach<O>(
        &mut self,
        key: attempt::Id<'d, ID>,
        token: &region::Token<region::Identity<'d, 1>>,
        map: impl FnOnce(&Self::Target) -> O,
    ) -> attempt::Connection<O> {
        let dials::Connection::Pending(connect) = self.dials.connection(key) else {
            return attempt::Connection::Stale;
        };
        let output = match self.membership.recover(connect.target(), |endpoint| {
            self.feedback.is_retained(endpoint, token)
        }) {
            members::Peer::Ready { target, output } => {
                let output = map(output);
                connect.commit(target);
                output
            }
            members::Peer::Missing => {
                return attempt::Connection::Retired;
            }
            members::Peer::Disabled => return attempt::Connection::Disabled,
            members::Peer::Exhausted => return attempt::Connection::Exhausted,
        };
        self.refresh();
        attempt::Connection::Applied(output)
    }
}