dope-manifold 0.26.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
50
51

use crate::client::{
    close,
    conn::{ClosePhase, CloseStatus, closing::Packed},
};

pub(in crate::client::conn) struct Quarantine<'a>(pub(in crate::client::conn) &'a mut Packed);
pub(in crate::client::conn) struct RetireState<'a>(pub(in crate::client::conn) &'a mut Packed);
pub(in crate::client::conn) struct RetireRef<'a>(pub(in crate::client::conn) &'a mut Packed);
pub(in crate::client::conn) struct SettledState<'a>(pub(in crate::client::conn) &'a Packed);

impl<'a> Quarantine<'a> {
    pub(in crate::client::conn) fn complete(self) -> RetireState<'a> {
        *self.0 = self.0.with_phase(ClosePhase::Retiring);
        RetireState(self.0)
    }
}

impl<'a> RetireState<'a> {
    pub(in crate::client::conn) fn reborrow(&mut self) -> RetireRef<'_> {
        RetireRef(&mut *self.0)
    }

    pub(in crate::client::conn) const fn reason(&self) -> close::Reason {
        self.0.effective().reason()
    }

    pub(in crate::client::conn) fn settle(self) -> SettledState<'a> {
        *self.0 = self.0.with_phase(ClosePhase::Settled);
        SettledState(self.0)
    }
}

impl RetireRef<'_> {
    pub(in crate::client::conn) fn reborrow(&mut self) -> RetireRef<'_> {
        RetireRef(&mut *self.0)
    }

    pub(in crate::client::conn) fn request(&mut self, rule: close::Directive) {
        self.0.apply(rule);
    }

    pub(in crate::client::conn) const fn status(&self) -> CloseStatus {
        self.0.status()
    }
}

impl SettledState<'_> {
    pub(in crate::client::conn) const fn reason(&self) -> close::Reason {
        self.0.effective().reason()
    }
}