Class SlowOperationDetector

java.lang.Object

com.loomcache.server.observability.SlowOperationDetector

All Implemented Interfaces:

AutoCloseable

public final class SlowOperationDetector
extends Object
implements AutoCloseable

Diagnostic plugin that samples active operation threads and records commands whose execution exceeds a configured threshold.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
final class	SlowOperationDetector.OperationScope
static final record	SlowOperationDetector.SlowOperationRecord

Method Summary

Modifier and Type	Method	Description
int	activeOperationCount()
void	close()
static @NonNull SlowOperationDetector	create(SlowOperationDetectorConfig config, String nodeId, @Nullable io.micrometer.core.instrument.MeterRegistry meterRegistry)
long	detectedCount()
static @NonNull SlowOperationDetector	disabled()
boolean	isEnabled()
@NonNull List<SlowOperationDetector.SlowOperationRecord>	recentOperations(int limit)
void	start()
void	stop()
@NonNull SlowOperationDetector.OperationScope	track(Message message, ConnectionContext connection)
@NonNull SlowOperationDetector.OperationScope	track(Message message, String peerId)
@NonNull SlowOperationDetector.OperationScope	track(CommandContext context)

Methods inherited from class Object

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

Method Details

create

public static @NonNull SlowOperationDetector create(SlowOperationDetectorConfig config,
 String nodeId,
 @Nullable io.micrometer.core.instrument.MeterRegistry meterRegistry)

disabled

public static @NonNull SlowOperationDetector disabled()

isEnabled

public boolean isEnabled()

detectedCount

public long detectedCount()

activeOperationCount

public int activeOperationCount()

start

public void start()

track

public @NonNull SlowOperationDetector.OperationScope track(CommandContext context)

track

public @NonNull SlowOperationDetector.OperationScope track(Message message,
 ConnectionContext connection)

track

public @NonNull SlowOperationDetector.OperationScope track(Message message,
 String peerId)

recentOperations

public @NonNull List<SlowOperationDetector.SlowOperationRecord> recentOperations(int limit)

close

public void close()

Specified by:

close in interface AutoCloseable

stop

public void stop()