io.micronaut.ratelimiter.resilience4j.registry

Class CacheRateLimiterRegistry

java.lang.Object

io.micronaut.ratelimiter.resilience4j.registry.CacheRateLimiterRegistry

All Implemented Interfaces:

io.github.resilience4j.core.Registry<io.github.resilience4j.ratelimiter.RateLimiter,io.github.resilience4j.ratelimiter.RateLimiterConfig>, io.github.resilience4j.ratelimiter.RateLimiterRegistry

@Internal
public class CacheRateLimiterRegistry
extends java.lang.Object
implements io.github.resilience4j.ratelimiter.RateLimiterRegistry

Nested Class Summary

Nested classes/interfaces inherited from interface io.github.resilience4j.core.Registry

io.github.resilience4j.core.Registry.EventPublisher<E>

Constructor Summary

Constructors

Constructor and Description
CacheRateLimiterRegistry(io.micronaut.cache.SyncCache<?> cache, io.github.resilience4j.ratelimiter.RateLimiterConfig defaultConfig)
CacheRateLimiterRegistry(io.micronaut.cache.SyncCache<?> cache, io.github.resilience4j.ratelimiter.RateLimiterConfig defaultConfig, io.vavr.collection.Map<java.lang.String,java.lang.String> registryTags)

Method Summary

Modifier and Type	Method and Description
void	addConfiguration(java.lang.String configName, io.github.resilience4j.ratelimiter.RateLimiterConfig configuration)
void	addRateLimiters(java.util.Map<java.lang.String,io.github.resilience4j.ratelimiter.RateLimiterConfig> rateLimiterMap)
java.util.Optional<io.github.resilience4j.ratelimiter.RateLimiter>	find(java.lang.String name)
io.vavr.collection.Seq<io.github.resilience4j.ratelimiter.RateLimiter>	getAllRateLimiters()
java.util.Optional<io.github.resilience4j.ratelimiter.RateLimiterConfig>	getConfiguration(java.lang.String configName)
io.github.resilience4j.ratelimiter.RateLimiterConfig	getDefaultConfig()
io.github.resilience4j.core.Registry.EventPublisher<io.github.resilience4j.ratelimiter.RateLimiter>	getEventPublisher()
io.github.resilience4j.ratelimiter.RateLimiter	rateLimiter(java.lang.String name)
io.github.resilience4j.ratelimiter.RateLimiter	rateLimiter(java.lang.String name, io.vavr.collection.Map<java.lang.String,java.lang.String> tags)
io.github.resilience4j.ratelimiter.RateLimiter	rateLimiter(java.lang.String name, io.github.resilience4j.ratelimiter.RateLimiterConfig rateLimiterConfig)
io.github.resilience4j.ratelimiter.RateLimiter	rateLimiter(java.lang.String name, io.github.resilience4j.ratelimiter.RateLimiterConfig rateLimiterConfig, io.vavr.collection.Map<java.lang.String,java.lang.String> tags)
io.github.resilience4j.ratelimiter.RateLimiter	rateLimiter(java.lang.String name, java.lang.String configName)
io.github.resilience4j.ratelimiter.RateLimiter	rateLimiter(java.lang.String name, java.lang.String configName, io.vavr.collection.Map<java.lang.String,java.lang.String> tags)
io.github.resilience4j.ratelimiter.RateLimiter	rateLimiter(java.lang.String name, java.util.function.Supplier<io.github.resilience4j.ratelimiter.RateLimiterConfig> rateLimiterConfigSupplier)
io.github.resilience4j.ratelimiter.RateLimiter	rateLimiter(java.lang.String name, java.util.function.Supplier<io.github.resilience4j.ratelimiter.RateLimiterConfig> rateLimiterConfigSupplier, io.vavr.collection.Map<java.lang.String,java.lang.String> tags)
java.util.Optional<io.github.resilience4j.ratelimiter.RateLimiter>	remove(java.lang.String name)
java.util.Optional<io.github.resilience4j.ratelimiter.RateLimiter>	replace(java.lang.String name, io.github.resilience4j.ratelimiter.RateLimiter newEntry)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.github.resilience4j.ratelimiter.RateLimiterRegistry

of, of, of, of, of, of, of, ofDefaults

Constructor Detail

CacheRateLimiterRegistry

public CacheRateLimiterRegistry(io.micronaut.cache.SyncCache<?> cache,
                                io.github.resilience4j.ratelimiter.RateLimiterConfig defaultConfig)

CacheRateLimiterRegistry

public CacheRateLimiterRegistry(io.micronaut.cache.SyncCache<?> cache,
                                io.github.resilience4j.ratelimiter.RateLimiterConfig defaultConfig,
                                io.vavr.collection.Map<java.lang.String,java.lang.String> registryTags)

Method Detail

addRateLimiters

public void addRateLimiters(java.util.Map<java.lang.String,io.github.resilience4j.ratelimiter.RateLimiterConfig> rateLimiterMap)

getAllRateLimiters

public io.vavr.collection.Seq<io.github.resilience4j.ratelimiter.RateLimiter> getAllRateLimiters()

Specified by:

getAllRateLimiters in interface io.github.resilience4j.ratelimiter.RateLimiterRegistry

rateLimiter

public io.github.resilience4j.ratelimiter.RateLimiter rateLimiter(java.lang.String name)

Specified by:

rateLimiter in interface io.github.resilience4j.ratelimiter.RateLimiterRegistry

rateLimiter

public io.github.resilience4j.ratelimiter.RateLimiter rateLimiter(java.lang.String name,
                                                                  io.vavr.collection.Map<java.lang.String,java.lang.String> tags)

Specified by:

rateLimiter in interface io.github.resilience4j.ratelimiter.RateLimiterRegistry

rateLimiter

public io.github.resilience4j.ratelimiter.RateLimiter rateLimiter(java.lang.String name,
                                                                  io.github.resilience4j.ratelimiter.RateLimiterConfig rateLimiterConfig)

Specified by:

rateLimiter in interface io.github.resilience4j.ratelimiter.RateLimiterRegistry

rateLimiter

public io.github.resilience4j.ratelimiter.RateLimiter rateLimiter(java.lang.String name,
                                                                  io.github.resilience4j.ratelimiter.RateLimiterConfig rateLimiterConfig,
                                                                  io.vavr.collection.Map<java.lang.String,java.lang.String> tags)

Specified by:

rateLimiter in interface io.github.resilience4j.ratelimiter.RateLimiterRegistry

rateLimiter

public io.github.resilience4j.ratelimiter.RateLimiter rateLimiter(java.lang.String name,
                                                                  java.util.function.Supplier<io.github.resilience4j.ratelimiter.RateLimiterConfig> rateLimiterConfigSupplier)

Specified by:

rateLimiter in interface io.github.resilience4j.ratelimiter.RateLimiterRegistry

rateLimiter

public io.github.resilience4j.ratelimiter.RateLimiter rateLimiter(java.lang.String name,
                                                                  java.util.function.Supplier<io.github.resilience4j.ratelimiter.RateLimiterConfig> rateLimiterConfigSupplier,
                                                                  io.vavr.collection.Map<java.lang.String,java.lang.String> tags)

Specified by:

rateLimiter in interface io.github.resilience4j.ratelimiter.RateLimiterRegistry

rateLimiter

public io.github.resilience4j.ratelimiter.RateLimiter rateLimiter(java.lang.String name,
                                                                  java.lang.String configName)

Specified by:

rateLimiter in interface io.github.resilience4j.ratelimiter.RateLimiterRegistry

rateLimiter

public io.github.resilience4j.ratelimiter.RateLimiter rateLimiter(java.lang.String name,
                                                                  java.lang.String configName,
                                                                  io.vavr.collection.Map<java.lang.String,java.lang.String> tags)

Specified by:

rateLimiter in interface io.github.resilience4j.ratelimiter.RateLimiterRegistry

addConfiguration

public void addConfiguration(java.lang.String configName,
                             io.github.resilience4j.ratelimiter.RateLimiterConfig configuration)

Specified by:

addConfiguration in interface io.github.resilience4j.core.Registry<io.github.resilience4j.ratelimiter.RateLimiter,io.github.resilience4j.ratelimiter.RateLimiterConfig>

find

public java.util.Optional<io.github.resilience4j.ratelimiter.RateLimiter> find(java.lang.String name)

Specified by:

find in interface io.github.resilience4j.core.Registry<io.github.resilience4j.ratelimiter.RateLimiter,io.github.resilience4j.ratelimiter.RateLimiterConfig>

remove

public java.util.Optional<io.github.resilience4j.ratelimiter.RateLimiter> remove(java.lang.String name)

Specified by:

remove in interface io.github.resilience4j.core.Registry<io.github.resilience4j.ratelimiter.RateLimiter,io.github.resilience4j.ratelimiter.RateLimiterConfig>

replace

public java.util.Optional<io.github.resilience4j.ratelimiter.RateLimiter> replace(java.lang.String name,
                                                                                  io.github.resilience4j.ratelimiter.RateLimiter newEntry)

Specified by:

replace in interface io.github.resilience4j.core.Registry<io.github.resilience4j.ratelimiter.RateLimiter,io.github.resilience4j.ratelimiter.RateLimiterConfig>

getConfiguration

public java.util.Optional<io.github.resilience4j.ratelimiter.RateLimiterConfig> getConfiguration(java.lang.String configName)

Specified by:

getConfiguration in interface io.github.resilience4j.core.Registry<io.github.resilience4j.ratelimiter.RateLimiter,io.github.resilience4j.ratelimiter.RateLimiterConfig>

getDefaultConfig

public io.github.resilience4j.ratelimiter.RateLimiterConfig getDefaultConfig()

Specified by:

getDefaultConfig in interface io.github.resilience4j.core.Registry<io.github.resilience4j.ratelimiter.RateLimiter,io.github.resilience4j.ratelimiter.RateLimiterConfig>

getEventPublisher

public io.github.resilience4j.core.Registry.EventPublisher<io.github.resilience4j.ratelimiter.RateLimiter> getEventPublisher()

Specified by:

getEventPublisher in interface io.github.resilience4j.core.Registry<io.github.resilience4j.ratelimiter.RateLimiter,io.github.resilience4j.ratelimiter.RateLimiterConfig>