feat: Implements protobuf OpenTelemetry support

Author: andyquinterom

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "dispenser"
-version = "0.14.1"
+version = "0.15.0"
 edition = "2021"
 license = "MIT"
 
@@ -47,3 +47,6 @@ reqwest = { version = "0.12", default-features = false, features = ["json"] }
 x509-parser = "0.18.0"
 http = "1.4.0"
 axum = "0.8.8"
+opentelemetry-proto = { version = "0.31.0", features = ["gen-tonic-messages", "logs", "trace", "metrics", "with-serde"] }
+prost = "0.14.3"
+bytes = "1.11.1"

Cargo.toml

@@ -21,7 +21,7 @@ wget ...
 
 
 ```sh
-sudo apt install ./dispenser-0.14.1-0.x86_64.deb
+sudo apt install ./dispenser-0.15.0-0.x86_64.deb
 ```
 
 You can validate that it was successfully installed by switching to the

INSTALL.deb.md

@@ -23,7 +23,7 @@ wget ...
 
 
 ```sh
-sudo dnf install ./dispenser-0.14.1-0.x86_64.rpm
+sudo dnf install ./dispenser-0.15.0-0.x86_64.rpm
 ```
 
 You can validate that it was successfully installed by switching to the

INSTALL.redhat.md

@@ -42,9 +42,9 @@ Download the latest `.deb` or `.rpm` package from the [releases page](https://gi
 
 ```sh
 # Download the .deb package
-# wget https://github.com/ixpantia/dispenser/releases/download/v0.14.1/dispenser-0.14.1-0.x86_64.deb
+# wget https://github.com/ixpantia/dispenser/releases/download/v0.15.0/dispenser-0.15.0-0.x86_64.deb
 
-sudo apt install ./dispenser-0.14.1-0.x86_64.deb
+sudo apt install ./dispenser-0.15.0-0.x86_64.deb
 ```
 
 ### RHEL / CentOS / Fedora
@@ -53,7 +53,7 @@ sudo apt install ./dispenser-0.14.1-0.x86_64.deb
 # Download the .rpm package
 # wget ...
 
-sudo dnf install ./dispenser-0.14.1-0.x86_64.rpm
+sudo dnf install ./dispenser-0.15.0-0.x86_64.rpm
 ```
 
 The installation process will:

README.md

@@ -75,13 +75,14 @@ Dispenser supports several authentication methods via environment variables:
 Dispenser acts as a sidecar host for your services. When telemetry is enabled, Dispenser starts an **Ingestion Service** listening on.
 
 *   **Endpoint**: `http://0.0.0.0:4318`
-*   **Protocol**: OTLP/HTTP (JSON)
+*   **Protocol**: OTLP/HTTP (Protobuf with JSON fallback)
 
 ### Automatic Environment Variables
 
 Dispenser automatically injects the following environment variables into all managed containers to simplify instrumentation:
 
 *   `OTEL_EXPORTER_OTLP_ENDPOINT="http://host.docker.internal:4318"`
+*   `OTEL_EXPORTER_OTLP_PROTOCOL="http/protobuf"`
 *   `OTEL_SERVICE_NAME="{service_name}"` (The name from your `service.toml`)
 
 Standard OTel SDKs will automatically detect these variables and begin shipping logs and traces to Dispenser without further configuration.
@@ -146,8 +147,8 @@ Stores structured logs emitted by applications via OTel.
 | `body` | `STRING` | The log message. |
 | `trace_id` | `STRING` | Associated trace ID (hex). |
 | `span_id` | `STRING` | Associated span ID (hex). |
-| `attributes` | `MAP<STRING, STRING>` | Flattened log attributes. |
-| `resource` | `MAP<STRING, STRING>` | Resource attributes (pod, node, etc). |
+| `attributes` | `STRING` | JSON string of log attributes. |
+| `resource` | `STRING` | JSON string of resource attributes (pod, node, etc). |
 
 ### Traces Table (`dispenser-traces`)
 
@@ -167,7 +168,8 @@ Stores distributed tracing spans.
 | `status_code` | `STRING` | OK, ERROR. |
 | `status_message` | `STRING` | Error description. |
 | `service` | `STRING` | Service name. |
-| `attributes` | `MAP<STRING, STRING>` | Span attributes. |
+| `attributes` | `STRING` | JSON string of span attributes. |
+| `events` | `ARRAY<STRUCT>` | Span events with `timestamp`, `name`, and `attributes`. |
 
 ### Container Output Table (`dispenser-container-output`)
 

TELEMETRY.md

@@ -56,3 +56,20 @@ static ARGS: OnceLock<Args> = OnceLock::new();
 pub fn get_cli_args() -> &'static Args {
     ARGS.get_or_init(Args::parse)
 }
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+
+    #[test]
+    fn test_signal_conversion() {
+        assert_eq!(
+            nix::sys::signal::Signal::from(Signal::Reload),
+            nix::sys::signal::Signal::SIGHUP
+        );
+        assert_eq!(
+            nix::sys::signal::Signal::from(Signal::Stop),
+            nix::sys::signal::Signal::SIGINT
+        );
+    }
+}