host-identity 1.1.1

Stable, collision-resistant host identity resolution across platforms, container runtimes, cloud providers, and Kubernetes
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

//! Hetzner Cloud instance-metadata identity source.
//!
//! `GET http://169.254.169.254/hetzner/v1/metadata/instance-id` — plaintext
//! numeric server ID, no special headers.
//!
//! Authoritative reference:
//! [Hetzner Cloud: Server metadata](https://docs.hetzner.cloud/#server-metadata)
//! — documents the `169.254.169.254` endpoint and the
//! `/hetzner/v1/metadata/instance-id` leaf.

use crate::source::SourceKind;
use crate::sources::cloud::{CloudEndpoint, CloudMetadata};

/// Hetzner Cloud numeric server ID.
pub type HetznerMetadata<T> = CloudMetadata<HetznerEndpoint, T>;

/// Endpoint descriptor for [`HetznerMetadata`].
pub struct HetznerEndpoint;

impl CloudEndpoint for HetznerEndpoint {
    const DEBUG_NAME: &'static str = "HetznerMetadata";
    const DEFAULT_BASE_URL: &'static str = "http://169.254.169.254";
    const PATH: &'static str = "/hetzner/v1/metadata/instance-id";
    const KIND: SourceKind = SourceKind::HetznerMetadata;

    fn headers() -> &'static [(&'static str, &'static str)] {
        &[]
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::source::Source;
    use crate::sources::cloud::test_support::{StubTransport, ok, status};

    #[test]
    fn happy_path_returns_server_id() {
        let source = HetznerMetadata::new(StubTransport::new(vec![ok("42001337")]));
        let probe = source.probe().unwrap().expect("should produce a probe");
        assert_eq!(probe.kind(), SourceKind::HetznerMetadata);
        assert_eq!(probe.value(), "42001337");
    }

    #[test]
    fn hits_expected_path() {
        let (stub, transport) = StubTransport::shared(vec![ok("1")]);
        let source = HetznerMetadata::with_base_url(transport, "http://hz.test");
        assert!(source.probe().unwrap().is_some());

        let requests = stub.requests();
        assert_eq!(requests.len(), 1);
        let (_, uri, _) = &requests[0];
        assert_eq!(uri, "http://hz.test/hetzner/v1/metadata/instance-id");
    }

    #[test]
    fn non_2xx_returns_none() {
        let source = HetznerMetadata::new(StubTransport::new(vec![status(503)]));
        assert!(source.probe().unwrap().is_none());
    }
}