Package org.datadog.jenkins.plugins.datadog.traces.write

Class AgentTraceWriteStrategy

java.lang.Object

org.datadog.jenkins.plugins.datadog.traces.write.AgentTraceWriteStrategy

All Implemented Interfaces:

TraceWriteStrategy

public class AgentTraceWriteStrategy
extends Object
implements TraceWriteStrategy

Trace write strategy that can dynamically switch from using APM track to using EVP Proxy. The switch will happen if an older agent (one that doesn't support EVP Proxy) is replaced with a newer agent.

Field Summary

Fields inherited from interface org.datadog.jenkins.plugins.datadog.traces.write.TraceWriteStrategy

ENABLE_TRACES_BATCHING_ENV_VAR

Constructor Summary

Constructors

Constructor	Description
AgentTraceWriteStrategy(TraceWriteStrategy evpProxyStrategy, TraceWriteStrategy apmStrategy, Supplier<Boolean> checkEvpProxySupport)

Method Summary

Modifier and Type	Method	Description
void	send(Collection<Payload> spans)
Payload	serialize(BuildData buildData, Run<?,?> run)
Payload	serialize(PipelineStepData stepData, Run<?,?> run)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.datadog.jenkins.plugins.datadog.traces.write.TraceWriteStrategy

close

Constructor Detail

AgentTraceWriteStrategy

public AgentTraceWriteStrategy(TraceWriteStrategy evpProxyStrategy,
                               TraceWriteStrategy apmStrategy,
                               Supplier<Boolean> checkEvpProxySupport)

Method Detail

serialize

@Nullable
public Payload serialize(BuildData buildData,
                         Run<?,?> run)

Specified by:

serialize in interface TraceWriteStrategy

serialize

@Nullable
public Payload serialize(PipelineStepData stepData,
                         Run<?,?> run)
                  throws IOException,
                         InterruptedException

Specified by:

serialize in interface TraceWriteStrategy

Throws:

IOException

InterruptedException

send

public void send(Collection<Payload> spans)

Specified by:

send in interface TraceWriteStrategy