pipecircuit 0.0.23

Correct. Robust. Fast. Portable. Pick four.
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
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84

//! Duplex commands and publications. Correlation names requests, never a caller
//! selected storage revision. Pending mutation replies retain their receipts.
use super::{Guarantee, StorageFailure, SubscriptionId, TableReply, TableRequest, ViewUpdate};
use core::num::NonZeroU64;

#[derive(Clone, Copy, Debug, Eq, PartialEq)]
#[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
pub struct RequestId(pub NonZeroU64);

#[derive(Debug)]
#[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
pub enum ContinuousRequest<Query, Mutation, View> {
    Command {
        id: RequestId,
        request: TableRequest<Query, Mutation>,
    },
    Subscribe {
        id: RequestId,
        view: View,
        guarantee: Guarantee,
    },
    Unsubscribe {
        id: RequestId,
        subscription: SubscriptionId,
    },
    Resynchronize {
        id: RequestId,
        subscription: SubscriptionId,
    },
}

#[derive(Debug)]
#[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
pub enum ContinuousReply<Value, Outcome, Refusal, Id, Projection> {
    ReplicationInterrupted {
        failure: StorageFailure,
    },
    SubscriptionRefused {
        id: RequestId,
        reason: SubscriptionRefusal,
    },
    Command {
        id: RequestId,
        reply: Result<TableReply<Value, Outcome, Refusal>, StorageFailure>,
    },
    Subscribed {
        id: RequestId,
        subscription: SubscriptionId,
    },
    Unsubscribed {
        id: RequestId,
        subscription: SubscriptionId,
    },
    Resynchronizing {
        id: RequestId,
        subscription: SubscriptionId,
    },
    View {
        subscription: SubscriptionId,
        update: ViewUpdate<Id, Projection>,
    },
}
#[derive(Clone, Copy, Debug, Eq, PartialEq)]
#[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
pub enum SubscriptionRefusal {
    Full,
    Unknown,
    Exhausted,
    Unavailable(super::Error),
}

pub struct ContinuousPipe<Row, Protocol>(core::marker::PhantomData<fn() -> (Row, Protocol)>);
impl<Row: super::PersistentRow, Protocol: super::ViewProtocol<Row>> crate::Pipe
    for ContinuousPipe<Row, Protocol>
{
    type In<'a> = ContinuousRequest<Protocol::Query, Protocol::Mutation, Protocol::View>;
    type Out<'a> = ContinuousReply<
        Protocol::Value,
        Protocol::Outcome,
        Protocol::Refusal,
        Row::Id,
        <Protocol::View as crate::storage::warp_table::observed::ViewDefinition<Row>>::Value,
    >;
}