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 ofUdpSender
that works in conjunction with theThriftSender
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 int
DEFAULT_AGENT_UDP_COMPACT_PORT
static 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 6831CustomizingUdpSender(String host, int port, int maxPacketSize, MetricVisualizationLinkProcessor linkProcessor)
-
Method Summary
All Methods Instance Methods Concrete Methods 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
-
-
-
-
Field Detail
-
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 Detail
-
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. 6831maxPacketSize
- if 0 it will use 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
- Overrides:
append
in classThriftSender
- 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 classThriftSender
- Throws:
io.jaegertracing.internal.exceptions.SenderException
-
close
public int close() throws io.jaegertracing.internal.exceptions.SenderException
- Specified by:
close
in interfaceio.jaegertracing.spi.Sender
- Overrides:
close
in classThriftSender
- Throws:
io.jaegertracing.internal.exceptions.SenderException
-
toString
public String toString()
- Overrides:
toString
in classThriftSender
-
-