io.github.bucket4j.distributed.proxy.optimization.predictive

Class PredictiveOptimization

java.lang.Object

io.github.bucket4j.distributed.proxy.optimization.predictive.PredictiveOptimization

All Implemented Interfaces:

Optimization

public class PredictiveOptimization
extends Object
implements Optimization

Optimization that can serve requests locally without synchronization with external storage until thresholds are not violated. This optimization is based on top of BatchingOptimization and DelayOptimization, and in additionally this optimization tries to predict aggregated consumption rate in whole cluster in order to reduce the risk of overconsumption that caused by DelayOptimization.

Usage of this optimization can lead to temporal over-consumption because the synchronization with external storage is performed periodically when thresholds are violated, as well as under-consumption in case of the wrong prediction of aggregated consumption rate.

See Also:

DelayParameters, PredictionParameters

Field Summary

Fields inherited from interface io.github.bucket4j.distributed.proxy.optimization.Optimization

NONE_OPTIMIZED

Constructor Summary

Constructors

Constructor and Description
PredictiveOptimization(PredictionParameters predictionParameters, DelayParameters delayParameters, OptimizationListener listener, TimeMeter timeMeter)

Method Summary

Modifier and Type	Method and Description
AsyncCommandExecutor	apply(AsyncCommandExecutor originalExecutor) Decorates command executor in order to apply optimization strategy.
CommandExecutor	apply(CommandExecutor originalExecutor) Decorates command executor in order to apply optimization strategy.
Optimization	withListener(OptimizationListener listener) Specifies the listener for optimization events

Methods inherited from class java.lang.Object

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

Constructor Detail

PredictiveOptimization

public PredictiveOptimization(PredictionParameters predictionParameters,
                              DelayParameters delayParameters,
                              OptimizationListener listener,
                              TimeMeter timeMeter)

Method Detail

withListener

public Optimization withListener(OptimizationListener listener)

Description copied from interface: Optimization

Specifies the listener for optimization events

Specified by:

withListener in interface Optimization

Parameters:

listener - the listener for optimization events

Returns:

the new instance of Optimization with configured listener

apply

public CommandExecutor apply(CommandExecutor originalExecutor)

Description copied from interface: Optimization

Decorates command executor in order to apply optimization strategy.

Specified by:

apply in interface Optimization

Parameters:

originalExecutor - command executor that need to be optimized

Returns:

decorated command executor

apply

public AsyncCommandExecutor apply(AsyncCommandExecutor originalExecutor)

Description copied from interface: Optimization

Decorates command executor in order to apply optimization strategy.

Specified by:

apply in interface Optimization

Parameters:

originalExecutor - command executor that need to be optimized

Returns:

decorated command executor