Class OperationalEvents

java.lang.Object

ecmwf.ecpds.master.OperationalEvents

public final class OperationalEvents
extends Object

Independent legacy-file and native OpenTelemetry outputs for operational events.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	OperationalEvents.Field

Method Summary

Modifier and Type	Method	Description
void	emit(DataTransfer transfer, String category, OperationalEvents.Field... fields)
void	emit(io.opentelemetry.context.Context context, String retrievalId, String category, OperationalEvents.Field... fields)
void	emit(String category, OperationalEvents.Field... fields)
static OperationalEvents.Field	field(String name, Object value)
static OperationalEvents	getInstance()
boolean	isEnabled()
static OperationalEventJournalStatus	journalStatus(ECpdsBase database, boolean includeQueue)
static void	setCollectionPaused(boolean paused)
static void	setDeliveryPaused(boolean paused)
static void	shutdown()
static void	start()	Configure once at Master startup, before event-producing schedulers start.
static void	start(ECpdsBase database)

Methods inherited from class Object

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

Method Details

getInstance

public static OperationalEvents getInstance()

start

public static void start()

Configure once at Master startup, before event-producing schedulers start.

start

public static void start(ECpdsBase database)

journalStatus

public static OperationalEventJournalStatus journalStatus(ECpdsBase database,
 boolean includeQueue)

setCollectionPaused

public static void setCollectionPaused(boolean paused)

setDeliveryPaused

public static void setDeliveryPaused(boolean paused)

shutdown

public static void shutdown()

isEnabled

public boolean isEnabled()

field

public static OperationalEvents.Field field(String name,
 Object value)

emit

public void emit(String category,
 OperationalEvents.Field... fields)

emit

public void emit(DataTransfer transfer,
 String category,
 OperationalEvents.Field... fields)

emit

public void emit(io.opentelemetry.context.Context context,
 String retrievalId,
 String category,
 OperationalEvents.Field... fields)