Package ch.tocco.nice2.metrics.impl.query

Class MetricsRecorderServiceImpl

java.lang.Object

ch.tocco.nice2.metrics.impl.query.MetricsRecorderServiceImpl

All Implemented Interfaces:

MetricsRecorderService

@Component
public class MetricsRecorderServiceImpl
extends Object
implements MetricsRecorderService

This is a threaded service so we can simply cache the MetricsData for the current thread.

Constructor Summary

Constructors

Constructor	Description
MetricsRecorderServiceImpl(org.slf4j.Logger logger, SpyLoggerService spyLoggerService, SystemActivityService systemActivityService)

Method Summary

Modifier and Type	Method	Description
boolean	recordingInProgress()
void	setEnabled(boolean enabled)
MetricsData	startRecording(ActivityType activityType, Supplier<String> name, Supplier<String> details, Supplier<CategoryData> categoryData)	Start collecting metrics for the current thread.
MetricsData	startRecording(ActivityType activityType, Supplier<String> name, Supplier<String> details, Supplier<CategoryData> categoryData, @Nullable String requestOrigin)
void	threadDidDiscardService()
void	updateCategoryOfActiveRecording(Supplier<CategoryData> categoryData)	Change the CategoryData of the currently active recording
void	updateExceptionOfActiveRecording(Exception exception)	Update the exception of the currently active recording

Methods inherited from class java.lang.Object

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

Constructor Details

MetricsRecorderServiceImpl

public MetricsRecorderServiceImpl(org.slf4j.Logger logger,
 SpyLoggerService spyLoggerService,
 SystemActivityService systemActivityService)

Method Details

setEnabled

@Value("${nice2.metrics.enabled}")
public void setEnabled(boolean enabled)

startRecording

public MetricsData startRecording(ActivityType activityType,
 Supplier<String> name,
 Supplier<String> details,
 Supplier<CategoryData> categoryData)

Description copied from interface: MetricsRecorderService

Start collecting metrics for the current thread. MetricsData.close() must be called to stop the recording.

Specified by:

startRecording in interface MetricsRecorderService

startRecording

public MetricsData startRecording(ActivityType activityType,
 Supplier<String> name,
 Supplier<String> details,
 Supplier<CategoryData> categoryData,
 @Nullable
 @Nullable String requestOrigin)

Specified by:

startRecording in interface MetricsRecorderService

updateCategoryOfActiveRecording

public void updateCategoryOfActiveRecording(Supplier<CategoryData> categoryData)

Description copied from interface: MetricsRecorderService

Change the CategoryData of the currently active recording

Specified by:

updateCategoryOfActiveRecording in interface MetricsRecorderService

updateExceptionOfActiveRecording

public void updateExceptionOfActiveRecording(Exception exception)

Description copied from interface: MetricsRecorderService

Update the exception of the currently active recording

Specified by:

updateExceptionOfActiveRecording in interface MetricsRecorderService

recordingInProgress

public boolean recordingInProgress()

Specified by:

recordingInProgress in interface MetricsRecorderService

Returns:

true if metrics are already being collected for the current thread

threadDidDiscardService

@PreDestroy
public void threadDidDiscardService()