io.lettuce.core.metrics

Class MicrometerCommandLatencyRecorder

java.lang.Object

io.lettuce.core.metrics.MicrometerCommandLatencyRecorder

All Implemented Interfaces:

CommandLatencyRecorder

public class MicrometerCommandLatencyRecorder
extends Object
implements CommandLatencyRecorder

Micrometer implementation of CommandLatencyRecorder

Since:

6.1

Author:

Steven Sheehy

Constructor Summary

Constructors

Constructor and Description
MicrometerCommandLatencyRecorder(io.micrometer.core.instrument.MeterRegistry meterRegistry, MicrometerOptions options) Create a new MicrometerCommandLatencyRecorder instance given MeterRegistry and MicrometerOptions.

Method Summary

Modifier and Type	Method and Description
protected io.micrometer.core.instrument.Timer	completionTimer(CommandLatencyId commandLatencyId)
protected io.micrometer.core.instrument.Timer	firstResponseTimer(CommandLatencyId commandLatencyId)
boolean	isEnabled() Returns true if the metric collector is enabled.
void	recordCommandLatency(SocketAddress local, SocketAddress remote, ProtocolKeyword commandType, long firstResponseLatency, long completionLatency) Record the command latency per connectionPoint and commandType.
void	recordCommandLatency(SocketAddress local, SocketAddress remote, RedisCommand<?,?,?> redisCommand, long firstResponseLatency, long completionLatency) Record the command latency per connectionPoint and commandType.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.lettuce.core.metrics.CommandLatencyRecorder

disabled

Constructor Detail

MicrometerCommandLatencyRecorder

public MicrometerCommandLatencyRecorder(io.micrometer.core.instrument.MeterRegistry meterRegistry,
                                        MicrometerOptions options)

Create a new MicrometerCommandLatencyRecorder instance given MeterRegistry and MicrometerOptions.

Parameters:

meterRegistry -

options -

Method Detail

recordCommandLatency

public void recordCommandLatency(SocketAddress local,
                                 SocketAddress remote,
                                 RedisCommand<?,?,?> redisCommand,
                                 long firstResponseLatency,
                                 long completionLatency)

Description copied from interface: CommandLatencyRecorder

Record the command latency per connectionPoint and commandType.

Specified by:

recordCommandLatency in interface CommandLatencyRecorder

Parameters:

local - the local address

remote - the remote address

redisCommand - the command

firstResponseLatency - latency value in TimeUnit.NANOSECONDS from send to the first response

completionLatency - latency value in TimeUnit.NANOSECONDS from send to the command completion

recordCommandLatency

public void recordCommandLatency(SocketAddress local,
                                 SocketAddress remote,
                                 ProtocolKeyword commandType,
                                 long firstResponseLatency,
                                 long completionLatency)

Description copied from interface: CommandLatencyRecorder

Record the command latency per connectionPoint and commandType.

Specified by:

recordCommandLatency in interface CommandLatencyRecorder

Parameters:

local - the local address

remote - the remote address

commandType - the command type

firstResponseLatency - latency value in TimeUnit.NANOSECONDS from send to the first response

completionLatency - latency value in TimeUnit.NANOSECONDS from send to the command completion

isEnabled

public boolean isEnabled()

Description copied from interface: CommandLatencyRecorder

Returns true if the metric collector is enabled.

Specified by:

isEnabled in interface CommandLatencyRecorder

Returns:

true if the metric collector is enabled

completionTimer

protected io.micrometer.core.instrument.Timer completionTimer(CommandLatencyId commandLatencyId)

firstResponseTimer

protected io.micrometer.core.instrument.Timer firstResponseTimer(CommandLatencyId commandLatencyId)