Class ThriftSender
- java.lang.Object
-
- com.broadleafcommerce.common.extension.monitor.ThriftSenderBase
-
- com.broadleafcommerce.common.extension.monitor.ThriftSender
-
- All Implemented Interfaces:
io.jaegertracing.spi.Sender
- Direct Known Subclasses:
CustomizingUdpSender
public abstract class ThriftSender extends ThriftSenderBase implements io.jaegertracing.spi.Sender
Modified from original for compatibility with libthrift 0.14.0
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class com.broadleafcommerce.common.extension.monitor.ThriftSenderBase
ThriftSenderBase.ProtocolType
-
-
Field Summary
-
Fields inherited from class com.broadleafcommerce.common.extension.monitor.ThriftSenderBase
EMIT_BATCH_OVERHEAD, protocolFactory
-
-
Constructor Summary
Constructors Constructor Description ThriftSender(ThriftSenderBase.ProtocolType protocolType, int maxPacketSize)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description int
append(io.jaegertracing.internal.JaegerSpan span)
protected int
calculateProcessSize(io.jaegertracing.thriftjava.Process proc)
protected int
calculateSpanSize(io.jaegertracing.thriftjava.Span span)
int
close()
int
flush()
abstract void
send(io.jaegertracing.thriftjava.Process process, List<io.jaegertracing.thriftjava.Span> spans)
String
toString()
-
Methods inherited from class com.broadleafcommerce.common.extension.monitor.ThriftSenderBase
getMaxSpanBytes, getSize, serialize
-
-
-
-
Constructor Detail
-
ThriftSender
public ThriftSender(ThriftSenderBase.ProtocolType protocolType, int maxPacketSize)
- Parameters:
protocolType
- protocol type (compact or binary)maxPacketSize
- if 0 it will use default value 65000
-
-
Method Detail
-
append
public int append(io.jaegertracing.internal.JaegerSpan span) throws io.jaegertracing.internal.exceptions.SenderException
- Specified by:
append
in interfaceio.jaegertracing.spi.Sender
- Throws:
io.jaegertracing.internal.exceptions.SenderException
-
calculateProcessSize
protected int calculateProcessSize(io.jaegertracing.thriftjava.Process proc) throws io.jaegertracing.internal.exceptions.SenderException
- Throws:
io.jaegertracing.internal.exceptions.SenderException
-
calculateSpanSize
protected int calculateSpanSize(io.jaegertracing.thriftjava.Span span) throws io.jaegertracing.internal.exceptions.SenderException
- Throws:
io.jaegertracing.internal.exceptions.SenderException
-
send
public abstract void send(io.jaegertracing.thriftjava.Process process, List<io.jaegertracing.thriftjava.Span> spans) throws io.jaegertracing.internal.exceptions.SenderException
- Throws:
io.jaegertracing.internal.exceptions.SenderException
-
flush
public int flush() throws io.jaegertracing.internal.exceptions.SenderException
- Specified by:
flush
in interfaceio.jaegertracing.spi.Sender
- Throws:
io.jaegertracing.internal.exceptions.SenderException
-
close
public int close() throws io.jaegertracing.internal.exceptions.SenderException
- Specified by:
close
in interfaceio.jaegertracing.spi.Sender
- Throws:
io.jaegertracing.internal.exceptions.SenderException
-
toString
public String toString()
- Overrides:
toString
in classThriftSenderBase
-
-