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 Details

  • Method Details

    • options

      public HttpSenderOptions options()

    • encoding

      public zipkin2.reporter.Encoding encoding()
      Specified by:
      encoding in interface zipkin2.reporter.BytesMessageSender
      Overrides:
      encoding in class zipkin2.reporter.BytesMessageSender.Base

    • messageMaxBytes

      public int messageMaxBytes()
      Specified by:
      messageMaxBytes in interface zipkin2.reporter.BytesMessageSender
      Overrides:
      messageMaxBytes in class zipkin2.reporter.BaseHttpSender<RequestOptions, Buffer>

    • messageSizeInBytes

      public int messageSizeInBytes(List<byte[]> encodedSpans)
      Specified by:
      messageSizeInBytes in interface zipkin2.reporter.BytesMessageSender
      Overrides:
      messageSizeInBytes in class zipkin2.reporter.BytesMessageSender.Base

    • newEndpoint

      protected RequestOptions newEndpoint(String endpoint)
      Specified by:
      newEndpoint in class zipkin2.reporter.BaseHttpSender<RequestOptions, Buffer>

    • newBody

      protected Buffer newBody(List<byte[]> encodedSpans)
      Specified by:
      newBody in class zipkin2.reporter.BaseHttpSender<RequestOptions, Buffer>

    • postSpans

      protected void postSpans(RequestOptions requestOptions, Buffer body) throws IOException
      Specified by:
      postSpans in class zipkin2.reporter.BaseHttpSender<RequestOptions, Buffer>
      Throws:
      IOException

    • doClose

      public void doClose()
      Overrides:
      doClose in class zipkin2.reporter.BaseHttpSender<RequestOptions, Buffer>