Package com.broadleafcommerce.common.extension.monitor

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

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

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 Details

append

public int append(io.jaegertracing.internal.JaegerSpan span)
           throws io.jaegertracing.internal.exceptions.SenderException

Specified by:

append in interface io.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 interface io.jaegertracing.spi.Sender

Throws:

io.jaegertracing.internal.exceptions.SenderException

close

public int close()
          throws io.jaegertracing.internal.exceptions.SenderException

Specified by:

close in interface io.jaegertracing.spi.Sender

Throws:

io.jaegertracing.internal.exceptions.SenderException

toString

public String toString()

Overrides:

toString in class ThriftSenderBase