Skip to content
Snippets Groups Projects
Commit 1fd24a68 authored by Simon Künzel's avatar Simon Künzel
Browse files

Fix OTLP typo

parent b37a611f
No related branches found
No related tags found
No related merge requests found
......@@ -131,5 +131,5 @@ INTERNAL_IP_RANGES = ["127.0.0.0/8", "192.168.155.0/24", "fd78:4d90:6fe4::/48"]
# Only for debugging. In percent, from 0 to 100. With this you need luck to make a request
# API_ROULETTE_MODE = 0
# OPEN_TELEMETRY_OLTP_ENDPOINT = "http://localhost:4318"
# OPEN_TELEMETRY_OTLP_ENDPOINT = "http://localhost:4318"
OPEN_TELEMETRY_TRACE_FILTER_ONLY_HTTP_HEADER = "X-Trace-Me"
......@@ -17,7 +17,7 @@ _API_GLOBAL_RATE_LIMITERS = create_configured_host_rate_limiters("global", api.c
_DEFAULT_CACHE_CONTROL_MAX_AGE_SECONDS = api.config["DEFAULT_CACHE_CONTROL_MAX_AGE_SECONDS"]
def _init_open_telemetry_tracer(oltp_endpoint: str) -> "Tracer":
def _init_open_telemetry_tracer(otlp_endpoint: str) -> "Tracer":
from opentelemetry.exporter.otlp.proto.http.trace_exporter import OTLPSpanExporter
from opentelemetry.sdk.trace import TracerProvider
from opentelemetry.sdk.trace.export import BatchSpanProcessor, SpanExportResult
......@@ -28,19 +28,19 @@ def _init_open_telemetry_tracer(oltp_endpoint: str) -> "Tracer":
})
provider = TracerProvider(resource=resource)
exporter = OTLPSpanExporter(endpoint=f"{oltp_endpoint}/v1/traces")
exporter = OTLPSpanExporter(endpoint=f"{otlp_endpoint}/v1/traces")
provider.add_span_processor(BatchSpanProcessor(exporter))
if exporter.export([]) != SpanExportResult.SUCCESS:
print(f"Warning: Test span export to {oltp_endpoint} failed. Tracing might not work")
print(f"Warning: Test span export to {otlp_endpoint} failed. Tracing might not work")
tracer = provider.get_tracer("videoag.api")
return tracer
open_telemetry_tracer = None
if "OPEN_TELEMETRY_OLTP_ENDPOINT" in api.config:
open_telemetry_tracer = _init_open_telemetry_tracer(api.config["OPEN_TELEMETRY_OLTP_ENDPOINT"])
if "OPEN_TELEMETRY_OTLP_ENDPOINT" in api.config:
open_telemetry_tracer = _init_open_telemetry_tracer(api.config["OPEN_TELEMETRY_OTLP_ENDPOINT"])
def check_client_int(value: int, name: str, min_value: int = MIN_VALUE_UINT32, max_value: int = MAX_VALUE_UINT32):
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment