Package io.debezium.metrics.activity

Class ActivityMonitoringMeter

java.lang.Object

io.debezium.metrics.activity.ActivityMonitoringMeter

All Implemented Interfaces:

ActivityMonitoringMXBean

public class ActivityMonitoringMeter
extends Object
implements ActivityMonitoringMXBean

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ActivityMonitoringMeter.ActivityCounter

Field Summary

Fields

Modifier and Type	Field	Description
private final ActivityMonitoringMeter.ActivityCounter	createCount
private final ActivityMonitoringMeter.ActivityCounter	deleteCount
private boolean	isPaused
private static final org.slf4j.Logger	LOGGER
private final ActivityMonitoringMeter.ActivityCounter	truncateCount
private final ActivityMonitoringMeter.ActivityCounter	updateCount

Constructor Summary

Constructors

Constructor	Description
ActivityMonitoringMeter()

Method Summary

Modifier and Type	Method	Description
Map<String,Long>	getNumberOfCreateEventsSeen()
Map<String,Long>	getNumberOfDeleteEventsSeen()
Map<String,Long>	getNumberOfTruncateEventsSeen()
Map<String,Long>	getNumberOfUpdateEventsSeen()
void	onEvent(io.debezium.spi.schema.DataCollectionId source, OffsetContext offset, Object key, org.apache.kafka.connect.data.Struct value, Envelope.Operation operation)
void	pause()
void	reset()
void	resume()

Methods inherited from class java.lang.Object

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

Field Details

LOGGER

private static final org.slf4j.Logger LOGGER

createCount

private final ActivityMonitoringMeter.ActivityCounter createCount

updateCount

private final ActivityMonitoringMeter.ActivityCounter updateCount

deleteCount

private final ActivityMonitoringMeter.ActivityCounter deleteCount

truncateCount

private final ActivityMonitoringMeter.ActivityCounter truncateCount

isPaused

private boolean isPaused

Constructor Details

ActivityMonitoringMeter

public ActivityMonitoringMeter()

Method Details

onEvent

public void onEvent(io.debezium.spi.schema.DataCollectionId source,
 OffsetContext offset,
 Object key,
 org.apache.kafka.connect.data.Struct value,
 Envelope.Operation operation)

getNumberOfCreateEventsSeen

public Map<String,Long> getNumberOfCreateEventsSeen()

Specified by:

getNumberOfCreateEventsSeen in interface ActivityMonitoringMXBean

getNumberOfDeleteEventsSeen

public Map<String,Long> getNumberOfDeleteEventsSeen()

Specified by:

getNumberOfDeleteEventsSeen in interface ActivityMonitoringMXBean

getNumberOfUpdateEventsSeen

public Map<String,Long> getNumberOfUpdateEventsSeen()

Specified by:

getNumberOfUpdateEventsSeen in interface ActivityMonitoringMXBean

getNumberOfTruncateEventsSeen

public Map<String,Long> getNumberOfTruncateEventsSeen()

Specified by:

getNumberOfTruncateEventsSeen in interface ActivityMonitoringMXBean

pause

public void pause()

Specified by:

pause in interface ActivityMonitoringMXBean

resume

public void resume()

Specified by:

resume in interface ActivityMonitoringMXBean

reset

public void reset()