rust-eureka 0.2.0

Simple Netflix Eureka Client
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
89
90
91
92
93
94
95
96
97
98
99
100
101
102

use super::Applications;
use serde::{Deserialize, Serialize};

#[derive(Debug, PartialEq, Serialize, Deserialize)]
pub struct ApplicationsResponse {
    pub applications: Applications,
}

impl ApplicationsResponse {
    pub fn new(applications: Applications) -> ApplicationsResponse {
        ApplicationsResponse { applications }
    }
}

#[cfg(test)]
mod tests {
    use super::super::applications::tests::{
        build_test_applications, build_test_applications_json,
    };
    use super::*;
    use serde_json;

    #[test]
    fn test_applications_response_serialization() {
        let applications = build_test_applications();
        let ar = ApplicationsResponse::new(applications);
        let result = serde_json::to_string(&ar).unwrap();
        assert!(result.contains("{\"applications\":"))
    }

    #[test]
    fn test_applications_response_deserialization() {
        let json = build_applications_response_json();
        let applications = build_test_applications();
        let ar = ApplicationsResponse::new(applications);
        let result = serde_json::from_str(&json).unwrap();
        assert_eq!(ar, result);
    }

    #[test]
    fn test_local_eureka_response() {
        let ar = serde_json::from_str::<ApplicationsResponse>(local_eureka_json().as_ref());
        assert!(ar.is_ok())
    }

    fn build_applications_response_json() -> String {
        format!("{{\"applications\":{}}}", build_test_applications_json())
    }

    fn local_eureka_json() -> String {
        r#"{
    "applications": {
        "versions__delta": 1,
        "apps__hashcode": "UP_1_",
        "application": {
            "name": "INTEGRATION_TEST",
            "instance": [{
                "hostName": "localhost",
                "app": "INTEGRATION_TEST",
                "ipAddr": "127.0.0.1",
                "status": "UP",
                "overriddenstatus": "UNKNOWN",
                "port": {
                    "@enabled": "true",
                    "$": "7001"
                },
                "securePort": {
                    "@enabled": "false",
                    "$": "7002"
                },
                "countryId": 1,
                "dataCenterInfo": {
                    "@class": "com.netflix.appinfo.InstanceInfo$DefaultDataCenterInfo",
                    "name": "MyOwn"
                },
                "leaseInfo": {
                    "renewalIntervalInSecs": 30,
                    "durationInSecs": 90,
                    "registrationTimestamp": 1504830481334,
                    "lastRenewalTimestamp": 1504830481334,
                    "evictionTimestamp": 0,
                    "serviceUpTimestamp": 1504830302194
                },
                "metadata": {
                    "@class": "java.util.Collections$EmptyMap"
                },
                "homePageUrl": "http://google.com",
                "statusPageUrl": "http://google.com",
                "healthCheckUrl": "http://google.com",
                "vipAddress": "127.0.0.1",
                "secureVipAddress": "127.0.0.1",
                "isCoordinatingDiscoveryServer": false,
                "lastUpdatedTimestamp": 1504830481334,
                "lastDirtyTimestamp": 1504830480933,
                "actionType": "ADDED"
            }]
        }
    }
}"#
        .to_string()
    }
}