Class TransferTracing

java.lang.Object

ecmwf.common.telemetry.TransferTracing

public final class TransferTracing
extends Object

Optional, sampled traces for dissemination, retrieval and incoming portal transfers.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	TransferTracing.Attempt
static final class	TransferTracing.Retrieval
static final class	TransferTracing.RetrievalAttempt

Method Summary

Modifier and Type	Method	Description
static void	accept(List<TransferSpan> spans)	Validate, detach and enqueue only: no collector I/O on the RMI/REST thread.
static TransferTracing.Attempt	completion(DataTransfer transfer)
static io.opentelemetry.context.Context	context(DataTransfer transfer)
static void	copy(DataTransfer source, DataTransfer target)
static TransferTracing.Attempt	dispatch(DataTransfer transfer)
static TransferTracing.Attempt	execution(DataTransfer transfer)
static boolean	isStale(DataTransfer local, DataTransfer incoming)	Only compare known attempt IDs, preserving interoperability with uninstrumented services.
static io.opentelemetry.context.Context	portalTransfer(DataTransfer transfer, boolean upload, String protocol, String server, long startTime, long durationMillis, long bytes, boolean successful)
static io.opentelemetry.context.Context	portalTransfer(DataTransfer transfer, ProxyEvent event, boolean successful)	Records the protocol-reported duration of a completed incoming transfer and returns its log context.
static TransferTracing.Retrieval	retrieval(DataFile file, DataTransfer transfer, Host source)
static void	shutdown()
static void	start(String role)

Methods inherited from class Object

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

Method Details

start

public static void start(String role)

accept

public static void accept(List<TransferSpan> spans)

Validate, detach and enqueue only: no collector I/O on the RMI/REST thread.

shutdown

public static void shutdown()

dispatch

public static TransferTracing.Attempt dispatch(DataTransfer transfer)

execution

public static TransferTracing.Attempt execution(DataTransfer transfer)

completion

public static TransferTracing.Attempt completion(DataTransfer transfer)

retrieval

public static TransferTracing.Retrieval retrieval(DataFile file,
 DataTransfer transfer,
 Host source)

portalTransfer

public static io.opentelemetry.context.Context portalTransfer(DataTransfer transfer,
 ProxyEvent event,
 boolean successful)

Records the protocol-reported duration of a completed incoming transfer and returns its log context.

portalTransfer

public static io.opentelemetry.context.Context portalTransfer(DataTransfer transfer,
 boolean upload,
 String protocol,
 String server,
 long startTime,
 long durationMillis,
 long bytes,
 boolean successful)

context

public static io.opentelemetry.context.Context context(DataTransfer transfer)

copy

public static void copy(DataTransfer source,
 DataTransfer target)

isStale

public static boolean isStale(DataTransfer local,
 DataTransfer incoming)

Only compare known attempt IDs, preserving interoperability with uninstrumented services.