Top Fields Constructors Methods

io.vertx.core.spi.cluster.impl.selector

public Class Selectors

Class Inheritance

extends Object

java.lang.Object
io.vertx.core.spi.cluster.impl.selector.Selectors

Imports

io.vertx.core.Promise, io.vertx.core.eventbus.Message, io.vertx.core.spi.cluster.ClusterManager, .RegistrationInfo, java.util.ArrayList, .Collections, .List, java.util.concurrent.ConcurrentHashMap, .ConcurrentMap, java.util.function.BiConsumer

Author: Thomas Segismont

Field Summary

Modifier and Type	Field and Description
private final ClusterManager	clusterManager
private final ConcurrentMap<String, SelectorEntry>	map

Constructor Summary

Access	Constructor and Description
public	Selectors(ClusterManager clusterManager)

Method Summary

Modifier and Type	Method and Description
private List<String>	computeAccessible(List<RegistrationInfo> registrations)
public void	dataLost()
public void	dataReceived(String address, List<RegistrationInfo> registrations, boolean isUpdate)
public boolean	hasEntryFor(String address)
private void	initialize(String address)
private boolean	isAccessible(RegistrationInfo registrationInfo) References Deprecated `RegistrationInfo` is deprecated or references (maybe indirectly) at least one deprecated element.
public <T> void	withSelector(Message<?> message, Promise<T> promise, BiConsumer<Promise<T>, RoundRobinSelector> task)

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

Field Detail

clusterManager	back to summary
private final ClusterManager clusterManager

map	back to summary
private final ConcurrentMap<String, SelectorEntry> map

Constructor Detail

Selectors	back to summary
public Selectors(ClusterManager clusterManager)

Method Detail

computeAccessible	back to summary
private List<String> computeAccessible(List<RegistrationInfo> registrations)

dataLost	back to summary
public void dataLost()

dataReceived	back to summary
public void dataReceived(String address, List<RegistrationInfo> registrations, boolean isUpdate)

hasEntryFor	back to summary
public boolean hasEntryFor(String address)

initialize	back to summary
private void initialize(String address)

isAccessible	back to summary
private boolean isAccessible(RegistrationInfo registrationInfo) References Deprecated `RegistrationInfo` is deprecated or references (maybe indirectly) at least one deprecated element. See corresponding docs for further information.

withSelector	back to summary
public <T> void withSelector(Message<?> message, Promise<T> promise, BiConsumer<Promise<T>, RoundRobinSelector> task)