Class AbstractRegistry<E,C>

java.lang.Object

io.github.resilience4j.core.registry.AbstractRegistry<E,C>

All Implemented Interfaces:

Registry<E,C>

public class AbstractRegistry<E,C>
extends Object
implements Registry<E,C>

Abstract registry to be shared with all resilience4j registries

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	AbstractRegistry.RegistryEventProcessor

Nested classes/interfaces inherited from interface Registry

Registry.EventPublisher<E>

Field Summary

Fields

Modifier and Type	Field	Description
protected static final String	CONFIG_MUST_NOT_BE_NULL
protected final ConcurrentMap<String,C>	configurations
protected static final String	CONSUMER_MUST_NOT_BE_NULL
protected static final String	DEFAULT_CONFIG
protected final RegistryStore<E>	entryMap
private final AbstractRegistry<E,C>.RegistryEventProcessor	eventProcessor
private static final String	NAME_MUST_NOT_BE_NULL
private static final String	REGISTRY_STORE_MUST_NOT_BE_NULL
protected final Map<String,String>	registryTags	Global tags which must be added to each instance created by this registry.
protected static final String	SUPPLIER_MUST_NOT_BE_NULL
protected static final String	TAGS_MUST_NOT_BE_NULL

Constructor Summary

Constructors

Constructor	Description
AbstractRegistry(C defaultConfig)
AbstractRegistry(C defaultConfig, RegistryEventConsumer<E> registryEventConsumer)
AbstractRegistry(C defaultConfig, RegistryEventConsumer<E> registryEventConsumer, Map<String,String> tags)
AbstractRegistry(C defaultConfig, List<RegistryEventConsumer<E>> registryEventConsumers)
AbstractRegistry(C defaultConfig, List<RegistryEventConsumer<E>> registryEventConsumers, Map<String,String> tags)
AbstractRegistry(C defaultConfig, List<RegistryEventConsumer<E>> registryEventConsumers, Map<String,String> tags, RegistryStore<E> registryStore)
AbstractRegistry(C defaultConfig, Map<String,String> registryTags)

Method Summary

Modifier and Type	Method	Description
void	addConfiguration(String configName, C configuration)	Adds a configuration to the registry
protected E	computeIfAbsent(String name, Supplier<E> supplier)
Optional<E>	find(String name)	Find a named entry in the Registry
protected Map<String,String>	getAllTags(Map<String,String> tags)	Creates map with all tags (registry and instance).
Optional<C>	getConfiguration(String configName)	Get a configuration by name
C	getDefaultConfig()	Get the default configuration
Registry.EventPublisher<E>	getEventPublisher()	Returns an EventPublisher which can be used to register event consumers.
Map<String,String>	getTags()
Optional<E>	remove(String name)	Remove an entry from the Registry
Optional<E>	replace(String name, E newEntry)	Replace an existing entry in the Registry by a new one.

Methods inherited from class Object

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

Field Details

DEFAULT_CONFIG

protected static final String DEFAULT_CONFIG

See Also:

• Constant Field Values

CONFIG_MUST_NOT_BE_NULL

protected static final String CONFIG_MUST_NOT_BE_NULL

See Also:

• Constant Field Values

CONSUMER_MUST_NOT_BE_NULL

protected static final String CONSUMER_MUST_NOT_BE_NULL

See Also:

• Constant Field Values

SUPPLIER_MUST_NOT_BE_NULL

protected static final String SUPPLIER_MUST_NOT_BE_NULL

See Also:

• Constant Field Values

TAGS_MUST_NOT_BE_NULL

protected static final String TAGS_MUST_NOT_BE_NULL

See Also:

• Constant Field Values

NAME_MUST_NOT_BE_NULL

private static final String NAME_MUST_NOT_BE_NULL

See Also:

• Constant Field Values

REGISTRY_STORE_MUST_NOT_BE_NULL

private static final String REGISTRY_STORE_MUST_NOT_BE_NULL

See Also:

• Constant Field Values

entryMap

protected final RegistryStore<E> entryMap

configurations

protected final ConcurrentMap<String,C> configurations

registryTags

protected final Map<String,String> registryTags

Global tags which must be added to each instance created by this registry.

eventProcessor

private final AbstractRegistry<E,C>.RegistryEventProcessor eventProcessor

Constructor Details

AbstractRegistry

public AbstractRegistry(C defaultConfig)

AbstractRegistry

public AbstractRegistry(C defaultConfig,
 Map<String,String> registryTags)

AbstractRegistry

public AbstractRegistry(C defaultConfig,
 RegistryEventConsumer<E> registryEventConsumer)

AbstractRegistry

public AbstractRegistry(C defaultConfig,
 RegistryEventConsumer<E> registryEventConsumer,
 Map<String,String> tags)

AbstractRegistry

public AbstractRegistry(C defaultConfig,
 List<RegistryEventConsumer<E>> registryEventConsumers)

AbstractRegistry

public AbstractRegistry(C defaultConfig,
 List<RegistryEventConsumer<E>> registryEventConsumers,
 Map<String,String> tags)

AbstractRegistry

public AbstractRegistry(C defaultConfig,
 List<RegistryEventConsumer<E>> registryEventConsumers,
 Map<String,String> tags,
 RegistryStore<E> registryStore)

Method Details

computeIfAbsent

protected E computeIfAbsent(String name,
 Supplier<E> supplier)

find

public Optional<E> find(String name)

Description copied from interface: Registry

Find a named entry in the Registry

Specified by:

find in interface Registry<E,C>

Parameters:

name - the name

remove

public Optional<E> remove(String name)

Description copied from interface: Registry

Remove an entry from the Registry

Specified by:

remove in interface Registry<E,C>

Parameters:

name - the name

replace

public Optional<E> replace(String name,
 E newEntry)

Description copied from interface: Registry

Replace an existing entry in the Registry by a new one.

Specified by:

replace in interface Registry<E,C>

Parameters:

name - the existing name

newEntry - a new entry

addConfiguration

public void addConfiguration(String configName,
 C configuration)

Description copied from interface: Registry

Adds a configuration to the registry

Specified by:

addConfiguration in interface Registry<E,C>

Parameters:

configName - the configuration name

configuration - the added configuration

getConfiguration

public Optional<C> getConfiguration(String configName)

Description copied from interface: Registry

Get a configuration by name

Specified by:

getConfiguration in interface Registry<E,C>

Parameters:

configName - the configuration name

Returns:

the found configuration if any

getDefaultConfig

public C getDefaultConfig()

Description copied from interface: Registry

Get the default configuration

Specified by:

getDefaultConfig in interface Registry<E,C>

Returns:

the default configuration

getTags

public Map<String,String> getTags()

Specified by:

getTags in interface Registry<E,C>

Returns:

global configured registry tags

getEventPublisher

public Registry.EventPublisher<E> getEventPublisher()

Description copied from interface: Registry

Returns an EventPublisher which can be used to register event consumers.

Specified by:

getEventPublisher in interface Registry<E,C>

Returns:

an EventPublisher

getAllTags

protected Map<String,String> getAllTags(Map<String,String> tags)

Creates map with all tags (registry and instance). When tags (keys) of the two collide the tags passed with this method will override the tags of the registry.

Parameters:

tags - Tags of the instance.

Returns:

Map containing all tags