Package io.vertigo.vega.plugins.ratelimiting.redis

Class RateLimitingRedisStorePlugin

java.lang.Object

io.vertigo.vega.plugins.ratelimiting.redis.RateLimitingRedisStorePlugin

All Implemented Interfaces:

io.vertigo.core.node.component.CoreComponent, io.vertigo.core.node.component.Plugin, RateLimitingStorePlugin

public final class RateLimitingRedisStorePlugin
extends Object
implements RateLimitingStorePlugin

Rate limiting counting redis storage.

Author:

npiedeloup

Constructor Summary

Constructors

Constructor	Description
RateLimitingRedisStorePlugin(Optional<String> connectorNameOpt, List<io.vertigo.connectors.redis.RedisConnector> redisConnectors)

Method Summary

Modifier and Type	Method	Description
void	banishUntil(String userKey, Instant banishUntil)	Set banish until instant for a userKey.
void	cancelAllBanishments()	Cancel all banishments.
void	cancelBanishment(String userKey)	Cancel banishment of a userkey.
void	extendsWindow(String userKey, long newWindowSeconds)
Instant	getBanishInstant(String userKey)	Get banish until instant.
Map<String,Instant>	getBanishments()
long	getFirstHitAgeSecond(String userKey)	Get first hit age for a userKey.
int	incrementBanishCounter(String userKey, long maxBanishSeconds)	Prepare banishment, increment and get banish counter.
long	remainingSeconds(String userKey)	Get remaining seconds in window for a userKey.
long	touch(String userKey, long incrBy, long windowSeconds)	Hit count by userKey, over a window.

Methods inherited from class java.lang.Object

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

Constructor Details

RateLimitingRedisStorePlugin

@Inject
public RateLimitingRedisStorePlugin(Optional<String> connectorNameOpt,
 List<io.vertigo.connectors.redis.RedisConnector> redisConnectors)

Method Details

touch

public long touch(String userKey,
 long incrBy,
 long windowSeconds)

Description copied from interface: RateLimitingStorePlugin

Hit count by userKey, over a window.

Specified by:

touch in interface RateLimitingStorePlugin

Parameters:

userKey - user key (like ip)

incrBy - increment by

windowSeconds - window in seconds

extendsWindow

public void extendsWindow(String userKey,
 long newWindowSeconds)

Specified by:

extendsWindow in interface RateLimitingStorePlugin

getFirstHitAgeSecond

public long getFirstHitAgeSecond(String userKey)

Description copied from interface: RateLimitingStorePlugin

Get first hit age for a userKey.

Specified by:

getFirstHitAgeSecond in interface RateLimitingStorePlugin

Parameters:

userKey - userKey user key (like ip)

Returns:

age in second (-1 if unknown)

remainingSeconds

public long remainingSeconds(String userKey)

Description copied from interface: RateLimitingStorePlugin

Get remaining seconds in window for a userKey.

Specified by:

remainingSeconds in interface RateLimitingStorePlugin

Parameters:

userKey - user key (like ip)

incrementBanishCounter

public int incrementBanishCounter(String userKey,
 long maxBanishSeconds)

Description copied from interface: RateLimitingStorePlugin

Prepare banishment, increment and get banish counter.

Specified by:

incrementBanishCounter in interface RateLimitingStorePlugin

Parameters:

userKey - user key (like ip)

maxBanishSeconds - max seconds counting banishment (each banish reset this time)

Returns:

current banish counter

banishUntil

public void banishUntil(String userKey,
 Instant banishUntil)

Description copied from interface: RateLimitingStorePlugin

Set banish until instant for a userKey.

Specified by:

banishUntil in interface RateLimitingStorePlugin

Parameters:

userKey - userKey user key (like ip)

banishUntil - banish until instant

getBanishInstant

public Instant getBanishInstant(String userKey)

Description copied from interface: RateLimitingStorePlugin

Get banish until instant.

Specified by:

getBanishInstant in interface RateLimitingStorePlugin

Parameters:

userKey - user key (like ip)

Returns:

banish until instant.

cancelBanishment

public void cancelBanishment(String userKey)

Description copied from interface: RateLimitingStorePlugin

Cancel banishment of a userkey.

Specified by:

cancelBanishment in interface RateLimitingStorePlugin

Parameters:

userKey - user key to reset

cancelAllBanishments

public void cancelAllBanishments()

Description copied from interface: RateLimitingStorePlugin

Cancel all banishments.

Specified by:

cancelAllBanishments in interface RateLimitingStorePlugin

getBanishments

public Map<String,Instant> getBanishments()

Specified by:

getBanishments in interface RateLimitingStorePlugin

Returns:

current banished userKey