Resilience4j 2.3.0 · io.github.resilience4j.core.registry.AbstractRegistry

Modifier and Type	Class and Description
private class	AbstractRegistry.RegistryEventProcessor

Field Summary

Modifier and Type	Field and 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

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

Method Summary

Modifier and Type	Method and Description
public void	addConfiguration(String the configuration name configName, C the added configuration configuration) Implements io.github.resilience4j.core.Registry.addConfiguration. Adds a configuration to the registry
protected E	computeIfAbsent(String name, Supplier<E> supplier)
public Optional<E>	find(String the name name) Implements io.github.resilience4j.core.Registry.find. Find a named entry in the Registry
protected Map<String, String>	Returns: Map containing all tags getAllTags(Map<String, String> Tags of the instance. tags) Creates map with all tags (registry and instance).
public Optional<C>	getConfiguration(String the configuration name configName) Implements io.github.resilience4j.core.Registry.getConfiguration. Get a configuration by name
public C	getDefaultConfig() Implements io.github.resilience4j.core.Registry.getDefaultConfig. Get the default configuration
public Registry.EventPublisher<E>	getEventPublisher() Implements io.github.resilience4j.core.Registry.getEventPublisher. Returns an EventPublisher which can be used to register event consumers.
public Map<String, String>	getTags() Implements io.github.resilience4j.core.Registry.getTags.
public Optional<E>	remove(String the name name) Implements io.github.resilience4j.core.Registry.remove. Remove an entry from the Registry
public C	removeConfiguration(String configName) Implements io.github.resilience4j.core.Registry.removeConfiguration. + * Removes a configuration from the registry + * + * @param configName the configuration name + * @return configuration mapped to the configName.
public Optional<E>	replace(String the existing name name, E a new entry newEntry) Implements io.github.resilience4j.core.Registry.replace. Replace an existing entry in the Registry by a new one.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

CONFIG_MUST_NOT_BE_NULL	back to summary
protected static final String CONFIG_MUST_NOT_BE_NULL

configurations	back to summary
protected final ConcurrentMap<String, C> configurations

CONSUMER_MUST_NOT_BE_NULL	back to summary
protected static final String CONSUMER_MUST_NOT_BE_NULL

DEFAULT_CONFIG	back to summary
protected static final String DEFAULT_CONFIG

entryMap	back to summary
protected final RegistryStore<E> entryMap

eventProcessor	back to summary
private final AbstractRegistry<E, C>.RegistryEventProcessor eventProcessor

NAME_MUST_NOT_BE_NULL	back to summary
private static final String NAME_MUST_NOT_BE_NULL

REGISTRY_STORE_MUST_NOT_BE_NULL	back to summary
private static final String REGISTRY_STORE_MUST_NOT_BE_NULL

registryTags	back to summary
protected final Map<String, String> registryTags Global tags which must be added to each instance created by this registry.

SUPPLIER_MUST_NOT_BE_NULL	back to summary
protected static final String SUPPLIER_MUST_NOT_BE_NULL

TAGS_MUST_NOT_BE_NULL	back to summary
protected static final String TAGS_MUST_NOT_BE_NULL

Constructor Detail

AbstractRegistry	back to summary
public AbstractRegistry(C defaultConfig)

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

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

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

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

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

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

Method Detail

addConfiguration	back to summary
public void addConfiguration(String configName, C configuration) Implements io.github.resilience4j.core.Registry.addConfiguration. Doc from io.github.resilience4j.core.Registry.addConfiguration. Adds a configuration to the registry Parameters configName:String the configuration name configuration:C the added configuration Annotations @Override

addConfiguration

back to summary

public void addConfiguration(String configName, C configuration)

Implements io.github.resilience4j.core.Registry.addConfiguration.

Doc from io.github.resilience4j.core.Registry.addConfiguration.

Adds a configuration to the registry

Parameters

configName:String: the configuration name
configuration:C: the added configuration

Annotations

@Override

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

find	back to summary
public Optional<E> find(String name) Implements io.github.resilience4j.core.Registry.find. Doc from io.github.resilience4j.core.Registry.find. Find a named entry in the Registry Parameters name:String the name Annotations @Override

find

back to summary

public Optional<E> find(String name)

Implements io.github.resilience4j.core.Registry.find.

Doc from io.github.resilience4j.core.Registry.find.

Find a named entry in the Registry

Parameters

name:String: the name

Annotations

@Override

getAllTags	back to summary
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:Map<String, String> Tags of the instance. Returns:Map<String, String> Map containing all tags

getAllTags

back to summary

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:Map<String, String>: Tags of the instance.

Returns:Map<String, String>

Map containing all tags

getConfiguration	back to summary
public Optional<C> getConfiguration(String configName) Implements io.github.resilience4j.core.Registry.getConfiguration. Doc from io.github.resilience4j.core.Registry.getConfiguration. Get a configuration by name Parameters configName:String the configuration name Returns:Optional<C> the found configuration if any Annotations @Override

getConfiguration

back to summary

public Optional<C> getConfiguration(String configName)

Implements io.github.resilience4j.core.Registry.getConfiguration.

Doc from io.github.resilience4j.core.Registry.getConfiguration.

Get a configuration by name

Parameters

configName:String: the configuration name

Returns:Optional<C>

the found configuration if any

Annotations

@Override

getDefaultConfig	back to summary
public C getDefaultConfig() Implements io.github.resilience4j.core.Registry.getDefaultConfig. Doc from io.github.resilience4j.core.Registry.getDefaultConfig. Get the default configuration Returns:C the default configuration Annotations @Override

getDefaultConfig

back to summary

public C getDefaultConfig()

Implements io.github.resilience4j.core.Registry.getDefaultConfig.

Doc from io.github.resilience4j.core.Registry.getDefaultConfig.

Get the default configuration

Returns:C

the default configuration

Annotations

@Override

getEventPublisher	back to summary
public Registry.EventPublisher<E> getEventPublisher() Implements io.github.resilience4j.core.Registry.getEventPublisher. Doc from io.github.resilience4j.core.Registry.getEventPublisher. Returns an EventPublisher which can be used to register event consumers. Returns:Registry.EventPublisher<E> an EventPublisher Annotations @Override

getEventPublisher

back to summary

public Registry.EventPublisher<E> getEventPublisher()

Implements io.github.resilience4j.core.Registry.getEventPublisher.

Doc from io.github.resilience4j.core.Registry.getEventPublisher.

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

Returns:Registry.EventPublisher<E>

an EventPublisher

Annotations

@Override

getTags	back to summary
public Map<String, String> getTags() Implements io.github.resilience4j.core.Registry.getTags. Returns:Map<String, String> Doc from io.github.resilience4j.core.Registry.getTags. global configured registry tags Annotations @Override

getTags

back to summary

public Map<String, String> getTags()

Implements io.github.resilience4j.core.Registry.getTags.

Returns:Map<String, String>

Doc from io.github.resilience4j.core.Registry.getTags.

global configured registry tags

Annotations

@Override

remove	back to summary
public Optional<E> remove(String name) Implements io.github.resilience4j.core.Registry.remove. Doc from io.github.resilience4j.core.Registry.remove. Remove an entry from the Registry Parameters name:String the name Annotations @Override

remove

back to summary

public Optional<E> remove(String name)

Implements io.github.resilience4j.core.Registry.remove.

Doc from io.github.resilience4j.core.Registry.remove.

Remove an entry from the Registry

Parameters

name:String: the name

Annotations

@Override

removeConfiguration	back to summary
public C removeConfiguration(String configName) Implements io.github.resilience4j.core.Registry.removeConfiguration. Doc from io.github.resilience4j.core.Registry.removeConfiguration. + * Removes a configuration from the registry + * + * @param configName the configuration name + * @return configuration mapped to the configName. + Annotations @Override

removeConfiguration

back to summary

public C removeConfiguration(String configName)

Implements io.github.resilience4j.core.Registry.removeConfiguration.

Doc from io.github.resilience4j.core.Registry.removeConfiguration.

+ * Removes a configuration from the registry + * + * @param configName the configuration name + * @return configuration mapped to the configName. +

Annotations

@Override

replace	back to summary
public Optional<E> replace(String name, E newEntry) Implements io.github.resilience4j.core.Registry.replace. Doc from io.github.resilience4j.core.Registry.replace. Replace an existing entry in the Registry by a new one. Parameters name:String the existing name newEntry:E a new entry Annotations @Override

replace

back to summary

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

Implements io.github.resilience4j.core.Registry.replace.

Doc from io.github.resilience4j.core.Registry.replace.

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

Parameters

name:String: the existing name
newEntry:E: a new entry

Annotations

@Override

public Class AbstractRegistry<E, C>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class AbstractRegistry.RegistryEventProcessor

Constructor Summary

Method Summary

Constructor Detail

Method Detail

Access	Constructor and Description
private	RegistryEventProcessor()
private	RegistryEventProcessor(List<RegistryEventConsumer<E>> registryEventConsumers)

Modifier and Type	Method and Description
public void	consumeEvent(RegistryEvent event) Implements io.github.resilience4j.core.EventConsumer.consumeEvent.
public Registry.EventPublisher<E>	onEntryAdded(EventConsumer<EntryAddedEvent<E>> onSuccessEventConsumer) Implements io.github.resilience4j.core.Registry.EventPublisher.onEntryAdded.
public Registry.EventPublisher<E>	onEntryRemoved(EventConsumer<EntryRemovedEvent<E>> onErrorEventConsumer) Implements io.github.resilience4j.core.Registry.EventPublisher.onEntryRemoved.
public Registry.EventPublisher<E>	onEntryReplaced(EventConsumer<EntryReplacedEvent<E>> onStateTransitionEventConsumer) Implements io.github.resilience4j.core.Registry.EventPublisher.onEntryReplaced.