io.github.bucket4j.distributed.expiration

Class BasedOnTimeForRefillingBucketUpToMaxExpirationAfterWriteStrategy

java.lang.Object

io.github.bucket4j.distributed.expiration.BasedOnTimeForRefillingBucketUpToMaxExpirationAfterWriteStrategy

All Implemented Interfaces:

ExpirationAfterWriteStrategy, ComparableByContent<BasedOnTimeForRefillingBucketUpToMaxExpirationAfterWriteStrategy>

public class BasedOnTimeForRefillingBucketUpToMaxExpirationAfterWriteStrategy
extends Object
implements ExpirationAfterWriteStrategy, ComparableByContent<BasedOnTimeForRefillingBucketUpToMaxExpirationAfterWriteStrategy>

Field Summary

Fields

Modifier and Type	Field and Description
static SerializationHandle<BasedOnTimeForRefillingBucketUpToMaxExpirationAfterWriteStrategy>	SERIALIZATION_HANDLE

Constructor Summary

Constructors

Constructor and Description
BasedOnTimeForRefillingBucketUpToMaxExpirationAfterWriteStrategy(Duration keepAfterRefillDuration)

Method Summary

Modifier and Type	Method and Description
long	calculateTimeToLiveMillis(RemoteBucketState state, long currentTimeNanos) Calculates the time to live for bucket that is going to be persisted to the remote storage
boolean	equalsByContent(BasedOnTimeForRefillingBucketUpToMaxExpirationAfterWriteStrategy other)
SerializationHandle<ExpirationAfterWriteStrategy>	getSerializationHandle()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.github.bucket4j.distributed.ExpirationAfterWriteStrategy

basedOnTimeForRefillingBucketUpToMax, deserialize, fixedTimeToLive, fromJsonCompatibleSnapshot, none, serialize, toJsonCompatibleSnapshot

Methods inherited from interface io.github.bucket4j.util.ComparableByContent

equals

Field Detail

SERIALIZATION_HANDLE

public static final SerializationHandle<BasedOnTimeForRefillingBucketUpToMaxExpirationAfterWriteStrategy> SERIALIZATION_HANDLE

Constructor Detail

BasedOnTimeForRefillingBucketUpToMaxExpirationAfterWriteStrategy

public BasedOnTimeForRefillingBucketUpToMaxExpirationAfterWriteStrategy(Duration keepAfterRefillDuration)

Method Detail

calculateTimeToLiveMillis

public long calculateTimeToLiveMillis(RemoteBucketState state,
                                      long currentTimeNanos)

Description copied from interface: ExpirationAfterWriteStrategy

Calculates the time to live for bucket that is going to be persisted to the remote storage

Specified by:

calculateTimeToLiveMillis in interface ExpirationAfterWriteStrategy

Parameters:

state - the state of bucket that is going to be persisted to the remote storage

currentTimeNanos - the time of operation

Returns:

time to live for bucket in milliseconds, negative value must be considered that bucket should be stored forever without expiration

getSerializationHandle

public SerializationHandle<ExpirationAfterWriteStrategy> getSerializationHandle()

Specified by:

getSerializationHandle in interface ExpirationAfterWriteStrategy

equalsByContent

public boolean equalsByContent(BasedOnTimeForRefillingBucketUpToMaxExpirationAfterWriteStrategy other)

Specified by:

equalsByContent in interface ComparableByContent<BasedOnTimeForRefillingBucketUpToMaxExpirationAfterWriteStrategy>