trellis-rs 0.10.7

Curated public Rust facade for Trellis clients and services.
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
85
86
87
88

use serde::{de::DeserializeOwned, Serialize};

/// Metadata required to mount one typed Trellis RPC handler.
pub trait RpcDescriptor {
    /// Request payload type.
    type Input: DeserializeOwned + Send + 'static;

    /// Success payload type.
    type Output: Serialize + Send + 'static;

    /// Logical contract key for the RPC.
    const KEY: &'static str;

    /// Concrete NATS subject for the RPC.
    const SUBJECT: &'static str;

    /// Capability requirements declared for callers.
    const CALLER_CAPABILITIES: &'static [&'static str] = &[];
}

impl<D> RpcDescriptor for D
where
    D: crate::client::RpcDescriptor,
    D::Input: DeserializeOwned + Send + 'static,
    D::Output: Serialize + Send + 'static,
{
    type Input = D::Input;
    type Output = D::Output;

    const KEY: &'static str = D::KEY;
    const SUBJECT: &'static str = D::SUBJECT;
    const CALLER_CAPABILITIES: &'static [&'static str] = D::CALLER_CAPABILITIES;
}

/// Metadata required to publish one typed Trellis event.
pub trait EventDescriptor {
    /// Event payload type.
    type Event: Serialize + DeserializeOwned + Send + Sync + 'static;

    /// Logical contract key for the event.
    const KEY: &'static str;

    /// Concrete NATS subject for the event.
    const SUBJECT: &'static str;
}

impl<D> EventDescriptor for D
where
    D: crate::client::EventDescriptor,
    D::Event: Serialize + DeserializeOwned + Send + Sync + 'static,
{
    type Event = D::Event;

    const KEY: &'static str = D::KEY;
    const SUBJECT: &'static str = D::SUBJECT;
}

/// Metadata required to mount one typed Trellis feed handler.
pub trait FeedDescriptor {
    /// Feed subscription input type.
    type Input: DeserializeOwned + Send + 'static;

    /// Feed event payload type.
    type Event: Serialize + Send + 'static;

    /// Logical contract key for the feed.
    const KEY: &'static str;

    /// Concrete NATS subject for the feed.
    const SUBJECT: &'static str;

    /// Capability requirements declared for subscribers.
    const SUBSCRIBE_CAPABILITIES: &'static [&'static str] = &[];
}

impl<D> FeedDescriptor for D
where
    D: crate::client::FeedDescriptor,
    D::Input: DeserializeOwned + Send + 'static,
    D::Event: Serialize + Send + 'static,
{
    type Input = D::Input;
    type Event = D::Event;

    const KEY: &'static str = D::KEY;
    const SUBJECT: &'static str = D::SUBJECT;
    const SUBSCRIBE_CAPABILITIES: &'static [&'static str] = D::SUBSCRIBE_CAPABILITIES;
}