Package com.broadleafcommerce.common.extension.monitor

Class CustomizingUdpSender

java.lang.Object

com.broadleafcommerce.common.extension.monitor.ThriftSenderBase

com.broadleafcommerce.common.extension.monitor.ThriftSender

com.broadleafcommerce.common.extension.monitor.CustomizingUdpSender

All Implemented Interfaces:

io.jaegertracing.spi.Sender

public class CustomizingUdpSender
extends ThriftSender

Implementation of UdpSender that works in conjunction with the ThriftSender and can embellish a span before emitting it.

Nested Class Summary

Nested classes/interfaces inherited from class com.broadleafcommerce.common.extension.monitor.ThriftSenderBase

ThriftSenderBase.ProtocolType

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_AGENT_UDP_COMPACT_PORT
static final String	DEFAULT_AGENT_UDP_HOST

Fields inherited from class com.broadleafcommerce.common.extension.monitor.ThriftSenderBase

EMIT_BATCH_OVERHEAD, protocolFactory

Constructor Summary

Constructors

Constructor	Description
CustomizingUdpSender()	This constructor expects Jaeger running running on "localhost" and port 6831
CustomizingUdpSender(String host, int port, int maxPacketSize, MetricVisualizationLinkProcessor linkProcessor)

Method Summary

Modifier and Type	Method	Description
int	append(io.jaegertracing.internal.JaegerSpan span)
int	close()
void	send(io.jaegertracing.thriftjava.Process process, List<io.jaegertracing.thriftjava.Span> spans)
String	toString()

Methods inherited from class com.broadleafcommerce.common.extension.monitor.ThriftSender

calculateProcessSize, calculateSpanSize, flush

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

Field Details

DEFAULT_AGENT_UDP_HOST

public static final String DEFAULT_AGENT_UDP_HOST

See Also:

• Constant Field Values

DEFAULT_AGENT_UDP_COMPACT_PORT

public static final int DEFAULT_AGENT_UDP_COMPACT_PORT

See Also:

• Constant Field Values

Constructor Details

CustomizingUdpSender

public CustomizingUdpSender()

This constructor expects Jaeger running running on "localhost" and port 6831

CustomizingUdpSender

public CustomizingUdpSender(String host,
 int port,
 int maxPacketSize,
 MetricVisualizationLinkProcessor linkProcessor)

Parameters:

host - host e.g. "localhost"

port - port e.g. 6831

maxPacketSize - if 0 it will use 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

Overrides:

append in class ThriftSender

Throws:

io.jaegertracing.internal.exceptions.SenderException

send

public void send(io.jaegertracing.thriftjava.Process process,
 List<io.jaegertracing.thriftjava.Span> spans)
          throws io.jaegertracing.internal.exceptions.SenderException

Specified by:

send in class ThriftSender

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

Overrides:

close in class ThriftSender

Throws:

io.jaegertracing.internal.exceptions.SenderException

toString

public String toString()

Overrides:

toString in class ThriftSender