Package zipkin2
Class SpanBytesDecoderDetector
java.lang.Object
zipkin2.SpanBytesDecoderDetector
public final class SpanBytesDecoderDetector extends Object
Detecting decoder used in transports which don't include means to identify the type of the data.
For example, we can identify the encoding and also the format in http via the request path and content-type. However, in Kafka it could be that folks send mixed Zipkin data without identifying its format. For example, Kafka historically has no content-type and users don't always segregate different queues by instrumentation format.
-
Method Summary
Modifier and Type Method Description static BytesDecoder<Span>
decoderForListMessage(byte[] spans)
static BytesDecoder<Span>
decoderForListMessage(ByteBuffer spans)
static BytesDecoder<Span>
decoderForMessage(byte[] span)
-
Method Details
-
decoderForMessage
- Throws:
IllegalArgumentException
- if the input isn't a v1 json or thrift single-span message
-
decoderForListMessage
- Throws:
IllegalArgumentException
- if the input isn't a json, proto3 or thrift list message.
-
decoderForListMessage
-