Package com.atlassian.bamboo.build.monitoring

Class ResultProcessingDelayMonitorImpl

java.lang.Object

com.atlassian.bamboo.build.monitoring.ResultProcessingDelayMonitorImpl

All Implemented Interfaces:

ResultProcessingDelayMonitor

public class ResultProcessingDelayMonitorImpl
extends Object
implements ResultProcessingDelayMonitor

Constructor Summary

Constructors

Constructor	Description
ResultProcessingDelayMonitorImpl()

Method Summary

Modifier and Type	Method	Description
List<ResultKey>	getIncomingResults()
long	getNumberOfIncomingResults()	Current number of results registered as incoming but not yet processed
@NotNull Duration	getProcessingDelayEstimate()	Current estimate of the result processing time.
boolean	isResultArrivalExpected(@NotNull ResultKey resultKey)	Checks if agent notified that the result is coming and if the time since that event exceeded threshold.
void	onTerminateResult(@NotNull ResultKey resultKey)	Called when result processing is finished, regardless of state.
void	purgeStaleEntries(@NotNull Predicate<ResultKey> isStale)	Purges entries older than the time specified internally (1h) by the service iff they fulfill given predicate.
void	registerIncomingResult(@NotNull ResultKey resultKey)	Called by agent to indicate a result is incoming.
void	registerProcessingFinished(@NotNull ResultKey resultKey)	Called when result processing is finished normally.

Methods inherited from class java.lang.Object

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

Constructor Details

ResultProcessingDelayMonitorImpl

public ResultProcessingDelayMonitorImpl()

Method Details

registerProcessingFinished

public void registerProcessingFinished(@NotNull
 @NotNull ResultKey resultKey)

Description copied from interface: ResultProcessingDelayMonitor

Called when result processing is finished normally.

Specified by:

registerProcessingFinished in interface ResultProcessingDelayMonitor

Parameters:

resultKey -

registerIncomingResult

public void registerIncomingResult(@NotNull
 @NotNull ResultKey resultKey)

Description copied from interface: ResultProcessingDelayMonitor

Called by agent to indicate a result is incoming.

Specified by:

registerIncomingResult in interface ResultProcessingDelayMonitor

Parameters:

resultKey -

onTerminateResult

public void onTerminateResult(@NotNull
 @NotNull ResultKey resultKey)

Description copied from interface: ResultProcessingDelayMonitor

Called when result processing is finished, regardless of state.

Specified by:

onTerminateResult in interface ResultProcessingDelayMonitor

Parameters:

resultKey -

isResultArrivalExpected

public boolean isResultArrivalExpected(@NotNull
 @NotNull ResultKey resultKey)

Description copied from interface: ResultProcessingDelayMonitor

Checks if agent notified that the result is coming and if the time since that event exceeded threshold.

Specified by:

isResultArrivalExpected in interface ResultProcessingDelayMonitor

Parameters:

resultKey -

Returns:

true if the service has a record of the result and the wait time is not exceeded.

getProcessingDelayEstimate

@NotNull
public @NotNull Duration getProcessingDelayEstimate()

Description copied from interface: ResultProcessingDelayMonitor

Current estimate of the result processing time.

Specified by:

getProcessingDelayEstimate in interface ResultProcessingDelayMonitor

Returns:

an estimate of the result processing time.

getNumberOfIncomingResults

public long getNumberOfIncomingResults()

Description copied from interface: ResultProcessingDelayMonitor

Current number of results registered as incoming but not yet processed

Specified by:

getNumberOfIncomingResults in interface ResultProcessingDelayMonitor

Returns:

number of results registered as incoming but not yet processed

getIncomingResults

public List<ResultKey> getIncomingResults()

Specified by:

getIncomingResults in interface ResultProcessingDelayMonitor

purgeStaleEntries

public void purgeStaleEntries(@NotNull
 @NotNull Predicate<ResultKey> isStale)

Description copied from interface: ResultProcessingDelayMonitor

Purges entries older than the time specified internally (1h) by the service iff they fulfill given predicate. (Actual use: check if entry is present in CBC or DeploymentInProgress)

Specified by:

purgeStaleEntries in interface ResultProcessingDelayMonitor