xds-api 0.2.0

Protocol buffer types for working with Envoy's xDS APIs.
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

#[cfg(test)]
mod any {
    use xds_api::pb::{
        envoy::{
            config::{
                cluster::v3 as xds_cluster, listener::v3 as xds_listener, route::v3 as xds_route,
            },
            extensions::clusters::aggregate::v3::ClusterConfig as AggregateClusterConfig,
            extensions::filters::network::http_connection_manager::v3::{
                http_connection_manager::RouteSpecifier, HttpConnectionManager,
            },
        },
        google::protobuf,
    };

    #[test]
    fn roundtrip_cluster() {
        use xds_cluster::cluster::ring_hash_lb_config::HashFunction;

        assert_roundtrip(xds_cluster::Cluster {
            name: "hello".to_string(),
            lb_config: Some(xds_cluster::cluster::LbConfig::RingHashLbConfig(
                xds_cluster::cluster::RingHashLbConfig {
                    hash_function: HashFunction::XxHash.into(),
                    ..Default::default()
                },
            )),
            ..Default::default()
        });
    }

    #[test]
    fn roundtrip_aggregate_cluster() {
        assert_roundtrip(AggregateClusterConfig {
            clusters: vec!["foo".to_string(), "bar".to_string()],
        })
    }

    #[test]
    fn roundtrip_http_connection_manager() {
        assert_roundtrip(HttpConnectionManager {
            route_specifier: Some(RouteSpecifier::RouteConfig(xds_route::RouteConfiguration {
                name: "test_route".to_string(),
                ..Default::default()
            })),
            ..Default::default()
        })
    }

    #[test]
    fn roundtrip_listener() {
        let connection_manager = HttpConnectionManager {
            route_specifier: Some(RouteSpecifier::RouteConfig(xds_route::RouteConfiguration {
                name: "test_route".to_string(),
                ..Default::default()
            })),
            ..Default::default()
        };

        assert_roundtrip(xds_listener::Listener {
            name: "cool_listener".to_string(),
            api_listener: Some(xds_listener::ApiListener {
                api_listener: Some(protobuf::Any::from_msg(&connection_manager).unwrap()),
            }),
            ..Default::default()
        })
    }

    fn assert_roundtrip<M: prost::Name + Clone + Default + PartialEq>(m: M) {
        let initial_val = m.clone();
        let as_any = protobuf::Any::from_msg(&m).unwrap();
        let round_tripped = as_any.to_msg().unwrap();

        assert_eq!(
            initial_val, round_tripped,
            "message should round-trip to itself"
        );
    }
}