LogDB OpenTelemetry Collector examples.

receivers:
  otlp/http_to_http:
    protocols:
      http:
        endpoint: ${env:LOGDB_COLLECTOR_HTTP_INPUT_ENDPOINT}
  otlp/http_to_grpc:
    protocols:
      http:
        endpoint: ${env:LOGDB_COLLECTOR_GRPC_INPUT_ENDPOINT}

exporters:
  otlphttp/logdb:
    endpoint: ${env:LOGDB_COLLECTOR_LOGDB_HTTP_ENDPOINT}
    headers:
      x-logdb-tenant: local
      authorization: Bearer local-dev-token
  otlp/logdb:
    endpoint: ${env:LOGDB_COLLECTOR_LOGDB_GRPC_ENDPOINT}
    tls:
      insecure: true
    headers:
      x-logdb-tenant: local
      authorization: Bearer local-dev-token

service:
  telemetry:
    logs:
      level: error
  pipelines:
    logs/http:
      receivers: [otlp/http_to_http]
      exporters: [otlphttp/logdb]
    traces/http:
      receivers: [otlp/http_to_http]
      exporters: [otlphttp/logdb]
    logs/grpc:
      receivers: [otlp/http_to_grpc]
      exporters: [otlp/logdb]
    traces/grpc:
      receivers: [otlp/http_to_grpc]
      exporters: [otlp/logdb]

#!/usr/bin/env bash
set -euo pipefail

# Service terminal: keep this script running while using the workflow terminal.
cd "${LOGDB_SOURCE_DIR:?Set LOGDB_SOURCE_DIR to your LogDB source directory.}/LogDB"
cargo build --locked --bin logdb --target-dir "$LOGDB_SOURCE_DIR/LogDB/target"
export LOGDB_BIND_ADDRESS=127.0.0.1:4318
export LOGDB_OTLP_GRPC_BIND_ADDRESS=127.0.0.1:4317
export LOGDB_DATA_DIR
LOGDB_DATA_DIR="$(mktemp -d "${TMPDIR:-/tmp}/logdb-collector.XXXXXX")"
readonly LOGDB_DATA_DIR

# Stop the owned service before deleting this script's temporary data.
service_pid=
cleanup() {
  trap '' INT TERM
  if [ -n "$service_pid" ]; then
    kill -TERM "$service_pid" 2>/dev/null || true
    for attempt in 1 2 3 4 5; do
      kill -0 "$service_pid" 2>/dev/null || break
      sleep 1
    done
    if kill -0 "$service_pid" 2>/dev/null; then
      kill -KILL "$service_pid" 2>/dev/null || true
    fi
    wait "$service_pid" 2>/dev/null || true
  fi
  rm -rf -- "$LOGDB_DATA_DIR"
}
trap cleanup EXIT
trap 'exit 130' INT
trap 'exit 143' TERM
printf 'Temporary tutorial data: %s\n' "$LOGDB_DATA_DIR"
"$LOGDB_SOURCE_DIR/LogDB/target/debug/logdb" &
service_pid=$!
wait "$service_pid"

#!/usr/bin/env bash
set -euo pipefail

# Workflow terminal: the service must already be running in its own terminal.
cd "${LOGDB_SOURCE_DIR:?Set LOGDB_SOURCE_DIR to your LogDB source directory.}/LogDB"
export LOGDB_COLLECTOR_SMOKE_OTELCOL_BIN="${LOGDB_COLLECTOR_SMOKE_OTELCOL_BIN:?Set this to your otelcol binary path.}"
export LOGDB_COLLECTOR_SMOKE_LOGDB_HTTP_ENDPOINT=http://127.0.0.1:4318
export LOGDB_COLLECTOR_SMOKE_LOGDB_GRPC_ENDPOINT=127.0.0.1:4317
export LOGDB_COLLECTOR_SMOKE_CONFIG=collector/otelcol-logdb-smoke.yaml

curl -fsS "$LOGDB_COLLECTOR_SMOKE_LOGDB_HTTP_ENDPOINT/health"
cargo run --locked --bin logdb-collector-smoke

#!/usr/bin/env bash
set -euo pipefail

export LOGDB_ENDPOINT="${LOGDB_ENDPOINT:-http://127.0.0.1:4318}"
export LOGDB_TENANT="${LOGDB_TENANT:-local}"
export LOGDB_TOKEN="${LOGDB_TOKEN:-local-dev-token}"
export LOGDB_DATASET="${LOGDB_DATASET:-checkout}"

curl -fsS -X POST "$LOGDB_ENDPOINT/v1/otlp/logs" \
  -H "content-type: application/json" \
  -H "x-logdb-tenant: $LOGDB_TENANT" \
  -H "authorization: Bearer $LOGDB_TOKEN" \
  --data @- <<JSON
{
    "resourceLogs": [{
      "resource": {
        "attributes": [
          {"key": "tenant_id", "value": {"stringValue": "$LOGDB_TENANT"}},
          {"key": "service.name", "value": {"stringValue": "$LOGDB_DATASET"}}
        ]
      },
      "scopeLogs": [{
        "logRecords": [{
          "timeUnixNano": "1783947600000000000",
          "body": {"stringValue": "collector example log"}
        }]
      }]
    }]
  }
JSON

#!/usr/bin/env bash
set -euo pipefail

export LOGDB_ENDPOINT="${LOGDB_ENDPOINT:-http://127.0.0.1:4318}"
export LOGDB_TENANT="${LOGDB_TENANT:-local}"
export LOGDB_TOKEN="${LOGDB_TOKEN:-local-dev-token}"
export LOGDB_DATASET="${LOGDB_DATASET:-checkout}"
export LOGDB_TRACE_ID="${LOGDB_TRACE_ID:-4bf92f3577b34da6a3ce929d0e0e4736}"

curl -fsS -X POST "$LOGDB_ENDPOINT/v1/otlp/traces" \
  -H "content-type: application/json" \
  -H "x-logdb-tenant: $LOGDB_TENANT" \
  -H "authorization: Bearer $LOGDB_TOKEN" \
  --data @- <<JSON
{
    "resourceSpans": [{
      "resource": {
        "attributes": [
          {"key": "tenant_id", "value": {"stringValue": "$LOGDB_TENANT"}},
          {"key": "service.name", "value": {"stringValue": "$LOGDB_DATASET"}}
        ]
      },
      "scopeSpans": [{
        "spans": [{
          "traceId": "$LOGDB_TRACE_ID",
          "spanId": "00f067aa0ba902b7",
          "name": "collector example span",
          "startTimeUnixNano": "1783947600000000000"
        }]
      }]
    }]
  }
JSON

curl -fsS -X POST "$LOGDB_ENDPOINT/v1/query" \
  -H "content-type: application/json" \
  -H "x-logdb-tenant: $LOGDB_TENANT" \
  -H "authorization: Bearer $LOGDB_TOKEN" \
  --data @- <<JSON
{
  "dataset": "$LOGDB_DATASET",
  "filter": {
    "trace_id": "$LOGDB_TRACE_ID"
  },
  "page": {
    "limit": 10
  }
}
JSON

#!/usr/bin/env bash
set -euo pipefail

export LOGDB_ENDPOINT="${LOGDB_ENDPOINT:-http://127.0.0.1:4318}"

# This request deliberately omits tenant and authorization headers.
# Keep the rejected HTTP response body visible for inspection.
curl -sS -X POST "$LOGDB_ENDPOINT/v1/query" \
  -H "content-type: application/json" \
  --data '{"dataset":"checkout"}'