vgi-rpc 0.1.0

Transport-agnostic RPC framework built on Apache Arrow IPC
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

//! Well-known metadata keys used in the vgi-rpc wire protocol.
//!
//! These keys appear as Arrow IPC `custom_metadata` on record batches.

pub const RPC_METHOD_KEY: &str = "vgi_rpc.method";
pub const REQUEST_VERSION_KEY: &str = "vgi_rpc.request_version";
pub const REQUEST_VERSION: &str = "1";
pub const REQUEST_ID_KEY: &str = "vgi_rpc.request_id";

pub const LOG_LEVEL_KEY: &str = "vgi_rpc.log_level";
pub const LOG_MESSAGE_KEY: &str = "vgi_rpc.log_message";
pub const LOG_EXTRA_KEY: &str = "vgi_rpc.log_extra";

pub const SERVER_ID_KEY: &str = "vgi_rpc.server_id";

pub const STATE_KEY: &str = "vgi_rpc.stream_state#b64";
pub const CANCEL_KEY: &str = "vgi_rpc.cancel";

pub const LOCATION_KEY: &str = "vgi_rpc.location";
pub const LOCATION_SHA256_KEY: &str = "vgi_rpc.location.sha256";
pub const LOCATION_FETCH_MS_KEY: &str = "vgi_rpc.location.fetch_ms";

pub const PROTOCOL_NAME_KEY: &str = "vgi_rpc.protocol_name";
pub const DESCRIBE_VERSION_KEY: &str = "vgi_rpc.describe_version";
pub const PROTOCOL_HASH_KEY: &str = "vgi_rpc.protocol_hash";

pub const SHM_OFFSET_KEY: &str = "vgi_rpc.shm_offset";
pub const SHM_LENGTH_KEY: &str = "vgi_rpc.shm_length";
pub const SHM_SOURCE_KEY: &str = "vgi_rpc.shm_source";
pub const SHM_SEGMENT_NAME_KEY: &str = "vgi_rpc.shm_segment_name";
pub const SHM_SEGMENT_SIZE_KEY: &str = "vgi_rpc.shm_segment_size";

pub const TRACEPARENT_KEY: &str = "traceparent";
pub const TRACESTATE_KEY: &str = "tracestate";

/// Build a single `(key, value)` metadata entry with minimal ceremony.
#[inline]
pub fn md_entry(k: &str, v: impl Into<String>) -> (String, String) {
    (k.to_string(), v.into())
}

/// Fluent builder for a `Metadata` map.
#[derive(Default, Debug)]
pub struct MetadataBuilder {
    entries: std::collections::HashMap<String, String>,
}

impl MetadataBuilder {
    pub fn new() -> Self {
        Self::default()
    }

    /// Insert `(k, v)`.
    pub fn push(mut self, k: &str, v: impl Into<String>) -> Self {
        self.entries.insert(k.to_string(), v.into());
        self
    }

    /// Insert `(k, v)` only when `v` is non-empty.
    pub fn push_if_non_empty(mut self, k: &str, v: impl Into<String>) -> Self {
        let s = v.into();
        if !s.is_empty() {
            self.entries.insert(k.to_string(), s);
        }
        self
    }

    /// Extend from an iterator.
    pub fn extend<I>(mut self, it: I) -> Self
    where
        I: IntoIterator<Item = (String, String)>,
    {
        self.entries.extend(it);
        self
    }

    pub fn build(self) -> std::collections::HashMap<String, String> {
        self.entries
    }
}