Class MoverTracing

java.lang.Object

ecmwf.common.telemetry.MoverTracing

public final class MoverTracing
extends Object

SDK-free capture and bounded, retrying transport of sampled Mover spans.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	MoverTracing.Attempt
static interface	MoverTracing.Sender

Method Summary

Modifier and Type	Method	Description
static void	accept(List<TransferSpan> spans)	Relay admission is all-or-nothing; failure must be propagated to the caller.
static void	copy(DataTransfer source, DataTransfer target)
static MoverTracing.Attempt	execution(DataTransfer transfer)
static MoverTracing.Attempt	retrieval(DataFile file, Host source)
static void	shutdown()	Does not wait for a sender which may be blocked in a remote invocation.
static void	start(MoverTracing.Sender sender, String instance)

Methods inherited from class Object

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

Method Details

start

public static void start(MoverTracing.Sender sender,
 String instance)

shutdown

public static void shutdown()

Does not wait for a sender which may be blocked in a remote invocation.

accept

public static void accept(List<TransferSpan> spans)

Relay admission is all-or-nothing; failure must be propagated to the caller.

copy

public static void copy(DataTransfer source,
 DataTransfer target)

execution

public static MoverTracing.Attempt execution(DataTransfer transfer)

retrieval

public static MoverTracing.Attempt retrieval(DataFile file,
 Host source)