org.axonframework.micrometer

Class EventProcessorLatencyMonitor.Builder

java.lang.Object

org.axonframework.micrometer.EventProcessorLatencyMonitor.Builder

Enclosing class:

EventProcessorLatencyMonitor

public static class EventProcessorLatencyMonitor.Builder
extends Object

Builder class to instantiate a EventProcessorLatencyMonitor.

The tagsBuilder is defaulted to a Function returning Tags.empty() and the Clock to a a Clock.SYSTEM. The meterNamePrefix and MeterRegistry are hard requirements and as such should be provided.

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
EventProcessorLatencyMonitor	build() Initializes a MessageTimerMonitor as specified through this Builder.
EventProcessorLatencyMonitor.Builder	clock(io.micrometer.core.instrument.Clock clock) Sets the Clock used to define the processing duration of a given message being pushed through this MessageMonitor.
EventProcessorLatencyMonitor.Builder	meterNamePrefix(String meterNamePrefix) Sets the name used to prefix the names of the Gauge instances created by this MessageMonitor.
EventProcessorLatencyMonitor.Builder	meterRegistry(io.micrometer.core.instrument.MeterRegistry meterRegistry) Specifies the MeterRegistry used to registered the Gauge instances to.
EventProcessorLatencyMonitor.Builder	tagsBuilder(Function<Message<?>,Iterable<io.micrometer.core.instrument.Tag>> tagsBuilder) Configures the Function used to deduce what the Tags should be for a message being monitored.
protected void	validate() Validate whether the fields contained in this Builder as set accordingly.

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

Method Detail

meterNamePrefix

public EventProcessorLatencyMonitor.Builder meterNamePrefix(String meterNamePrefix)

Sets the name used to prefix the names of the Gauge instances created by this MessageMonitor.

Parameters:

meterNamePrefix - a String used to prefix the names of the Gauge instances created by this MessageMonitor

Returns:

the current Builder instance, for fluent interfacing

meterRegistry

public EventProcessorLatencyMonitor.Builder meterRegistry(io.micrometer.core.instrument.MeterRegistry meterRegistry)

Specifies the MeterRegistry used to registered the Gauge instances to.

Parameters:

meterRegistry - the MeterRegistry used to registered the Gauge instances to

Returns:

the current Builder instance, for fluent interfacing

clock

public EventProcessorLatencyMonitor.Builder clock(io.micrometer.core.instrument.Clock clock)

Sets the Clock used to define the processing duration of a given message being pushed through this MessageMonitor. Defaults to the Clock.SYSTEM.

Parameters:

clock - the Clock used to define the processing duration of a given message

Returns:

the current Builder instance, for fluent interfacing

tagsBuilder

public EventProcessorLatencyMonitor.Builder tagsBuilder(Function<Message<?>,Iterable<io.micrometer.core.instrument.Tag>> tagsBuilder)

Configures the Function used to deduce what the Tags should be for a message being monitored. Defaults to a Function returning Tags.empty().

Parameters:

tagsBuilder - a Function used to deduce what the Tags should be for a message being monitored

Returns:

the current Builder instance, for fluent interfacing

build

public EventProcessorLatencyMonitor build()

Initializes a MessageTimerMonitor as specified through this Builder.

Returns:

a MessageTimerMonitor as specified through this Builder

validate

protected void validate()

Validate whether the fields contained in this Builder as set accordingly.

Throws:

AxonConfigurationException - if one field is asserted to be incorrect according to the Builder's specifications