Package com.bytedesk.core.socket.connection

Class ConnectionMetrics

java.lang.Object

com.bytedesk.core.socket.connection.ConnectionMetrics

@Component
@ConditionalOnClass(io.micrometer.core.instrument.MeterRegistry.class)
public class ConnectionMetrics
extends Object

Metrics for connection heartbeat & presence performance.

Field Summary

Fields

Modifier and Type	Field	Description
private io.micrometer.core.instrument.DistributionSummary	batchSizeSummary
private io.micrometer.core.instrument.Timer	flushTimer
private io.micrometer.core.instrument.Counter	heartbeatCalls
private io.micrometer.core.instrument.Counter	heartbeatCreated
private io.micrometer.core.instrument.Counter	heartbeatDbWrites
private io.micrometer.core.instrument.Counter	heartbeatSkipped
private final io.micrometer.core.instrument.MeterRegistry	meterRegistry

Constructor Summary

Constructors

Constructor	Description
ConnectionMetrics()

Method Summary

Modifier and Type	Method	Description
void	incCreated()
void	incDbWrite()
void	incHeartbeatCall()
void	incSkipped()
void	init()
void	recordFlush(long nanos, int batchSize)

Methods inherited from class java.lang.Object

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

Field Details

meterRegistry

private final io.micrometer.core.instrument.MeterRegistry meterRegistry

heartbeatCalls

private io.micrometer.core.instrument.Counter heartbeatCalls

heartbeatDbWrites

private io.micrometer.core.instrument.Counter heartbeatDbWrites

heartbeatSkipped

private io.micrometer.core.instrument.Counter heartbeatSkipped

heartbeatCreated

private io.micrometer.core.instrument.Counter heartbeatCreated

flushTimer

private io.micrometer.core.instrument.Timer flushTimer

batchSizeSummary

private io.micrometer.core.instrument.DistributionSummary batchSizeSummary

Constructor Details

ConnectionMetrics

public ConnectionMetrics()

Method Details

init

@PostConstruct
public void init()

incHeartbeatCall

public void incHeartbeatCall()

incDbWrite

public void incDbWrite()

incSkipped

public void incSkipped()

incCreated

public void incCreated()

recordFlush

public void recordFlush(long nanos,
 int batchSize)