Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -9,14 +9,14 @@
import io.activej.http.HttpHeaderValue;
import io.activej.http.HttpHeaders;
import io.activej.http.HttpRequest;
import io.opentelemetry.context.propagation.internal.ExtendedTextMapGetter;
import io.opentelemetry.context.propagation.TextMapGetter;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

enum ActivejHttpServerRequestGetter implements ExtendedTextMapGetter<HttpRequest> {
enum ActivejHttpServerRequestGetter implements TextMapGetter<HttpRequest> {
INSTANCE;

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@

import akka.http.javadsl.model.HttpHeader;
import akka.http.scaladsl.model.HttpRequest;
import io.opentelemetry.context.propagation.internal.ExtendedTextMapGetter;
import io.opentelemetry.context.propagation.TextMapGetter;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
Expand All @@ -16,7 +16,7 @@
import java.util.stream.Collectors;
import java.util.stream.StreamSupport;

enum AkkaHttpServerHeaders implements ExtendedTextMapGetter<HttpRequest> {
enum AkkaHttpServerHeaders implements TextMapGetter<HttpRequest> {
INSTANCE;

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,13 +7,13 @@

import com.linecorp.armeria.server.ServiceRequestContext;
import io.netty.util.AsciiString;
import io.opentelemetry.context.propagation.internal.ExtendedTextMapGetter;
import io.opentelemetry.context.propagation.TextMapGetter;
import java.util.Collections;
import java.util.Iterator;
import java.util.stream.Collectors;
import javax.annotation.Nullable;

enum RequestContextGetter implements ExtendedTextMapGetter<ServiceRequestContext> {
enum RequestContextGetter implements TextMapGetter<ServiceRequestContext> {
INSTANCE;

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,11 +5,11 @@

package io.opentelemetry.javaagent.instrumentation.grizzly;

import io.opentelemetry.context.propagation.internal.ExtendedTextMapGetter;
import io.opentelemetry.context.propagation.TextMapGetter;
import java.util.Iterator;
import org.glassfish.grizzly.http.HttpRequestPacket;

enum HttpRequestHeadersGetter implements ExtendedTextMapGetter<HttpRequestPacket> {
enum HttpRequestHeadersGetter implements TextMapGetter<HttpRequestPacket> {
INSTANCE;

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,11 +8,11 @@
import static java.util.Collections.emptyIterator;

import io.grpc.Metadata;
import io.opentelemetry.context.propagation.internal.ExtendedTextMapGetter;
import io.opentelemetry.context.propagation.TextMapGetter;
import java.util.Iterator;
import javax.annotation.Nullable;

enum GrpcRequestGetter implements ExtendedTextMapGetter<GrpcRequest> {
enum GrpcRequestGetter implements TextMapGetter<GrpcRequest> {
INSTANCE;

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,12 +9,12 @@
import static java.util.Collections.emptyList;

import com.sun.net.httpserver.HttpExchange;
import io.opentelemetry.context.propagation.internal.ExtendedTextMapGetter;
import io.opentelemetry.context.propagation.TextMapGetter;
import java.util.Iterator;
import java.util.List;
import javax.annotation.Nullable;

enum JavaHttpServerExchangeGetter implements ExtendedTextMapGetter<HttpExchange> {
enum JavaHttpServerExchangeGetter implements TextMapGetter<HttpExchange> {
INSTANCE;

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,12 +5,12 @@

package io.opentelemetry.javaagent.instrumentation.jetty.v12_0;

import io.opentelemetry.context.propagation.internal.ExtendedTextMapGetter;
import io.opentelemetry.context.propagation.TextMapGetter;
import io.opentelemetry.instrumentation.api.internal.EnumerationUtil;
import java.util.Iterator;
import org.eclipse.jetty.server.Request;

enum Jetty12TextMapGetter implements ExtendedTextMapGetter<Request> {
enum Jetty12TextMapGetter implements TextMapGetter<Request> {
INSTANCE;

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,15 +5,15 @@

package io.opentelemetry.instrumentation.kafkaclients.common.v0_11.internal;

import io.opentelemetry.context.propagation.internal.ExtendedTextMapGetter;
import io.opentelemetry.context.propagation.TextMapGetter;
import java.nio.charset.StandardCharsets;
import java.util.Iterator;
import java.util.stream.Collectors;
import java.util.stream.StreamSupport;
import javax.annotation.Nullable;
import org.apache.kafka.common.header.Header;

enum KafkaConsumerRecordGetter implements ExtendedTextMapGetter<KafkaProcessRequest> {
enum KafkaConsumerRecordGetter implements TextMapGetter<KafkaProcessRequest> {
INSTANCE;

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,10 +6,10 @@
package io.opentelemetry.instrumentation.ktor.v1_0

import io.ktor.request.*
import io.opentelemetry.context.propagation.internal.ExtendedTextMapGetter
import io.opentelemetry.context.propagation.TextMapGetter
import java.util.Collections

internal object ApplicationRequestGetter : ExtendedTextMapGetter<ApplicationRequest> {
internal object ApplicationRequestGetter : TextMapGetter<ApplicationRequest> {
override fun keys(carrier: ApplicationRequest): Iterable<String> = carrier.headers.names()

override fun get(carrier: ApplicationRequest?, name: String): String? = carrier?.headers?.get(name)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,10 +6,10 @@
package io.opentelemetry.instrumentation.ktor.v2_0.common

import io.ktor.server.request.*
import io.opentelemetry.context.propagation.internal.ExtendedTextMapGetter
import io.opentelemetry.context.propagation.TextMapGetter
import java.util.Collections

internal object ApplicationRequestGetter : ExtendedTextMapGetter<ApplicationRequest> {
internal object ApplicationRequestGetter : TextMapGetter<ApplicationRequest> {
override fun keys(carrier: ApplicationRequest): Iterable<String> = carrier.headers.names()

override fun get(carrier: ApplicationRequest?, name: String): String? = carrier?.headers?.get(name)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,10 +5,10 @@

package io.opentelemetry.javaagent.instrumentation.liberty.dispatcher;

import io.opentelemetry.context.propagation.internal.ExtendedTextMapGetter;
import io.opentelemetry.context.propagation.TextMapGetter;
import java.util.Iterator;

enum LibertyDispatcherRequestGetter implements ExtendedTextMapGetter<LibertyRequest> {
enum LibertyDispatcherRequestGetter implements TextMapGetter<LibertyRequest> {
INSTANCE;

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,12 +5,12 @@

package io.opentelemetry.javaagent.instrumentation.netty.v3_8.server;

import io.opentelemetry.context.propagation.internal.ExtendedTextMapGetter;
import io.opentelemetry.context.propagation.TextMapGetter;
import io.opentelemetry.javaagent.instrumentation.netty.v3_8.HttpRequestAndChannel;
import java.util.Iterator;
import javax.annotation.Nullable;

enum NettyHeadersGetter implements ExtendedTextMapGetter<HttpRequestAndChannel> {
enum NettyHeadersGetter implements TextMapGetter<HttpRequestAndChannel> {
INSTANCE;

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@

package io.opentelemetry.instrumentation.netty.common.v4_0.internal.server;

import io.opentelemetry.context.propagation.internal.ExtendedTextMapGetter;
import io.opentelemetry.context.propagation.TextMapGetter;
import io.opentelemetry.instrumentation.netty.common.v4_0.HttpRequestAndChannel;
import java.util.Collections;
import java.util.Iterator;
Expand All @@ -16,7 +16,7 @@
* This class is internal and is hence not for public use. Its APIs are unstable and can change at
* any time.
*/
public enum HttpRequestHeadersGetter implements ExtendedTextMapGetter<HttpRequestAndChannel> {
public enum HttpRequestHeadersGetter implements TextMapGetter<HttpRequestAndChannel> {
INSTANCE;

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@

package io.opentelemetry.javaagent.instrumentation.pekkohttp.v1_0.server;

import io.opentelemetry.context.propagation.internal.ExtendedTextMapGetter;
import io.opentelemetry.context.propagation.TextMapGetter;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
Expand All @@ -16,7 +16,7 @@
import org.apache.pekko.http.javadsl.model.HttpHeader;
import org.apache.pekko.http.scaladsl.model.HttpRequest;

enum PekkoHttpServerHeaders implements ExtendedTextMapGetter<HttpRequest> {
enum PekkoHttpServerHeaders implements TextMapGetter<HttpRequest> {
INSTANCE;

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@

package io.opentelemetry.instrumentation.ratpack.v1_7.internal;

import io.opentelemetry.context.propagation.internal.ExtendedTextMapGetter;
import io.opentelemetry.context.propagation.TextMapGetter;
import java.util.Collections;
import java.util.Iterator;
import javax.annotation.Nullable;
Expand All @@ -15,7 +15,7 @@
* This class is internal and is hence not for public use. Its APIs are unstable and can change at
* any time.
*/
enum RatpackGetter implements ExtendedTextMapGetter<Request> {
enum RatpackGetter implements TextMapGetter<Request> {
INSTANCE;

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,14 +5,14 @@

package io.opentelemetry.instrumentation.restlet.v1_1.internal;

import io.opentelemetry.context.propagation.internal.ExtendedTextMapGetter;
import io.opentelemetry.context.propagation.TextMapGetter;
import java.util.Iterator;
import org.restlet.data.Form;
import org.restlet.data.Message;
import org.restlet.data.Parameter;
import org.restlet.data.Request;

enum RestletHeadersGetter implements ExtendedTextMapGetter<Request> {
enum RestletHeadersGetter implements TextMapGetter<Request> {
INSTANCE;

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@

import static java.util.Collections.emptySet;

import io.opentelemetry.context.propagation.internal.ExtendedTextMapGetter;
import io.opentelemetry.context.propagation.TextMapGetter;
import java.lang.invoke.MethodHandle;
import java.lang.invoke.MethodHandles;
import java.lang.invoke.MethodType;
Expand All @@ -21,7 +21,7 @@
import org.restlet.Request;
import org.restlet.util.Series;

final class RestletHeadersGetter implements ExtendedTextMapGetter<Request> {
final class RestletHeadersGetter implements TextMapGetter<Request> {

private static final MethodHandle GET_ATTRIBUTES;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,11 +5,11 @@

package io.opentelemetry.javaagent.instrumentation.servlet;

import io.opentelemetry.context.propagation.internal.ExtendedTextMapGetter;
import io.opentelemetry.context.propagation.TextMapGetter;
import java.util.Iterator;

public class ServletRequestGetter<REQUEST>
implements ExtendedTextMapGetter<ServletRequestContext<REQUEST>> {
implements TextMapGetter<ServletRequestContext<REQUEST>> {
protected final ServletAccessor<REQUEST, ?> accessor;

public ServletRequestGetter(ServletAccessor<REQUEST, ?> accessor) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,13 +7,13 @@

import static java.util.Collections.emptyIterator;

import io.opentelemetry.context.propagation.internal.ExtendedTextMapGetter;
import io.opentelemetry.context.propagation.TextMapGetter;
import java.util.Iterator;
import java.util.List;
import javax.annotation.Nullable;
import org.springframework.web.server.ServerWebExchange;

enum WebfluxTextMapGetter implements ExtendedTextMapGetter<ServerWebExchange> {
enum WebfluxTextMapGetter implements TextMapGetter<ServerWebExchange> {
INSTANCE;

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,13 +5,13 @@

package io.opentelemetry.instrumentation.spring.webmvc.v5_3;

import io.opentelemetry.context.propagation.internal.ExtendedTextMapGetter;
import io.opentelemetry.context.propagation.TextMapGetter;
import io.opentelemetry.instrumentation.api.internal.EnumerationUtil;
import java.util.Collections;
import java.util.Iterator;
import javax.servlet.http.HttpServletRequest;

enum JavaxHttpServletRequestGetter implements ExtendedTextMapGetter<HttpServletRequest> {
enum JavaxHttpServletRequestGetter implements TextMapGetter<HttpServletRequest> {
INSTANCE;

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,13 +5,13 @@

package io.opentelemetry.instrumentation.spring.webmvc.v6_0;

import io.opentelemetry.context.propagation.internal.ExtendedTextMapGetter;
import io.opentelemetry.context.propagation.TextMapGetter;
import io.opentelemetry.instrumentation.api.internal.EnumerationUtil;
import jakarta.servlet.http.HttpServletRequest;
import java.util.Collections;
import java.util.Iterator;

enum JakartaHttpServletRequestGetter implements ExtendedTextMapGetter<HttpServletRequest> {
enum JakartaHttpServletRequestGetter implements TextMapGetter<HttpServletRequest> {
INSTANCE;

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,13 +5,13 @@

package io.opentelemetry.javaagent.instrumentation.tomcat.common;

import io.opentelemetry.context.propagation.internal.ExtendedTextMapGetter;
import io.opentelemetry.context.propagation.TextMapGetter;
import io.opentelemetry.instrumentation.api.internal.EnumerationUtil;
import java.util.Collections;
import java.util.Iterator;
import org.apache.coyote.Request;

enum TomcatRequestGetter implements ExtendedTextMapGetter<Request> {
enum TomcatRequestGetter implements TextMapGetter<Request> {
INSTANCE;

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,15 +5,15 @@

package io.opentelemetry.javaagent.instrumentation.undertow;

import io.opentelemetry.context.propagation.internal.ExtendedTextMapGetter;
import io.opentelemetry.context.propagation.TextMapGetter;
import io.undertow.server.HttpServerExchange;
import io.undertow.util.HeaderValues;
import io.undertow.util.HttpString;
import java.util.Collections;
import java.util.Iterator;
import java.util.stream.Collectors;

enum UndertowExchangeGetter implements ExtendedTextMapGetter<HttpServerExchange> {
enum UndertowExchangeGetter implements TextMapGetter<HttpServerExchange> {
INSTANCE;

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,15 +5,15 @@

package io.opentelemetry.instrumentation.test.server.http;

import io.opentelemetry.context.propagation.internal.ExtendedTextMapGetter;
import io.opentelemetry.context.propagation.TextMapGetter;
import io.opentelemetry.testing.internal.armeria.server.ServiceRequestContext;
import io.opentelemetry.testing.internal.io.netty.util.AsciiString;
import java.util.Collections;
import java.util.Iterator;
import java.util.stream.Collectors;
import javax.annotation.Nullable;

public enum RequestContextGetter implements ExtendedTextMapGetter<ServiceRequestContext> {
public enum RequestContextGetter implements TextMapGetter<ServiceRequestContext> {
INSTANCE;

@Override
Expand Down