Package com.cockroachlabs.data.cdc.metrics

Class MicrometerCDCMetrics

java.lang.Object

com.cockroachlabs.data.cdc.metrics.MicrometerCDCMetrics

All Implemented Interfaces:

CDCMetrics

public class MicrometerCDCMetrics
extends Object
implements CDCMetrics

Nested Class Summary

Nested classes/interfaces inherited from interface com.cockroachlabs.data.cdc.metrics.CDCMetrics

CDCMetrics.InMemory, CDCMetrics.Noop

Constructor Summary

Constructors

Constructor	Description
MicrometerCDCMetrics(io.micrometer.core.instrument.MeterRegistry registry)

Method Summary

Modifier and Type	Method	Description
long	getAuthFailureCount()
double	getAverageProcessingMs()
long	getEventsFailed()
long	getEventsProcessed()
long	getEventsReceived()
long	getResolvedCount()
void	recordAuthFailure(String endpoint)
void	recordEvent(String endpoint, CDCOperationType operation, long processingNanos, boolean success)
void	recordResolved(String endpoint)
void	recordWebhookReceived(String endpoint, int payloadSize)

Methods inherited from class java.lang.Object

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

Constructor Details

MicrometerCDCMetrics

public MicrometerCDCMetrics(io.micrometer.core.instrument.MeterRegistry registry)

Method Details

recordEvent

public void recordEvent(String endpoint,
 CDCOperationType operation,
 long processingNanos,
 boolean success)

Specified by:

recordEvent in interface CDCMetrics

recordWebhookReceived

public void recordWebhookReceived(String endpoint,
 int payloadSize)

Specified by:

recordWebhookReceived in interface CDCMetrics

recordResolved

public void recordResolved(String endpoint)

Specified by:

recordResolved in interface CDCMetrics

recordAuthFailure

public void recordAuthFailure(String endpoint)

Specified by:

recordAuthFailure in interface CDCMetrics

getEventsReceived

public long getEventsReceived()

Specified by:

getEventsReceived in interface CDCMetrics

getEventsProcessed

public long getEventsProcessed()

Specified by:

getEventsProcessed in interface CDCMetrics

getEventsFailed

public long getEventsFailed()

Specified by:

getEventsFailed in interface CDCMetrics

getResolvedCount

public long getResolvedCount()

Specified by:

getResolvedCount in interface CDCMetrics

getAuthFailureCount

public long getAuthFailureCount()

Specified by:

getAuthFailureCount in interface CDCMetrics

getAverageProcessingMs

public double getAverageProcessingMs()

Specified by:

getAverageProcessingMs in interface CDCMetrics