Package io.vertx.tracing.zipkin
Class VertxSender
- java.lang.Object
-
- zipkin2.reporter.BytesMessageSender.Base
-
- zipkin2.reporter.BaseHttpSender<RequestOptions,Buffer>
-
- io.vertx.tracing.zipkin.VertxSender
-
- All Implemented Interfaces:
Closeable,AutoCloseable,zipkin2.reporter.BytesMessageSender
public class VertxSender extends zipkin2.reporter.BaseHttpSender<RequestOptions,Buffer>
An HTTP sender using Vert.x HttpClient, only JSON encoding is supported.- Author:
- Julien Viet
-
-
Constructor Summary
Constructors Constructor Description VertxSender(HttpSenderOptions options)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voiddoClose()zipkin2.reporter.Encodingencoding()intmessageMaxBytes()intmessageSizeInBytes(List<byte[]> encodedSpans)protected BuffernewBody(List<byte[]> encodedSpans)protected RequestOptionsnewEndpoint(String endpoint)HttpSenderOptionsoptions()protected voidpostSpans(RequestOptions requestOptions, Buffer body)
-
-
-
Constructor Detail
-
VertxSender
public VertxSender(HttpSenderOptions options)
-
-
Method Detail
-
options
public HttpSenderOptions options()
-
encoding
public zipkin2.reporter.Encoding encoding()
- Specified by:
encodingin interfacezipkin2.reporter.BytesMessageSender- Overrides:
encodingin classzipkin2.reporter.BytesMessageSender.Base
-
messageMaxBytes
public int messageMaxBytes()
- Specified by:
messageMaxBytesin interfacezipkin2.reporter.BytesMessageSender- Overrides:
messageMaxBytesin classzipkin2.reporter.BaseHttpSender<RequestOptions,Buffer>
-
messageSizeInBytes
public int messageSizeInBytes(List<byte[]> encodedSpans)
- Specified by:
messageSizeInBytesin interfacezipkin2.reporter.BytesMessageSender- Overrides:
messageSizeInBytesin classzipkin2.reporter.BytesMessageSender.Base
-
newEndpoint
protected RequestOptions newEndpoint(String endpoint)
- Specified by:
newEndpointin classzipkin2.reporter.BaseHttpSender<RequestOptions,Buffer>
-
newBody
protected Buffer newBody(List<byte[]> encodedSpans)
- Specified by:
newBodyin classzipkin2.reporter.BaseHttpSender<RequestOptions,Buffer>
-
postSpans
protected void postSpans(RequestOptions requestOptions, Buffer body) throws IOException
- Specified by:
postSpansin classzipkin2.reporter.BaseHttpSender<RequestOptions,Buffer>- Throws:
IOException
-
doClose
public void doClose()
- Overrides:
doClosein classzipkin2.reporter.BaseHttpSender<RequestOptions,Buffer>
-
-