Class DefaultDataSyncRegistry

java.lang.Object

eu.cloudnetservice.node.impl.cluster.sync.DefaultDataSyncRegistry

All Implemented Interfaces:

eu.cloudnetservice.node.cluster.sync.DataSyncRegistry

@Singleton
@Provides(eu.cloudnetservice.node.cluster.sync.DataSyncRegistry.class)
public class DefaultDataSyncRegistry
extends Object
implements eu.cloudnetservice.node.cluster.sync.DataSyncRegistry

Field Summary

Fields

Modifier and Type	Field	Description
private final Console	console
private final Map<String, eu.cloudnetservice.node.cluster.sync.DataSyncHandler<?>>	handlers
private final eu.cloudnetservice.driver.language.I18n	i18n
private static final org.slf4j.Logger	LOGGER

Constructor Summary

Constructors

Constructor	Description
DefaultDataSyncRegistry(@NonNull eu.cloudnetservice.driver.language.I18n i18n, @NonNull Console console)

Method Summary

Modifier and Type	Method	Description
@Nullable eu.cloudnetservice.driver.network.buffer.DataBuf	handle(@NonNull eu.cloudnetservice.driver.network.buffer.DataBuf input, boolean force)
boolean	hasHandler(@NonNull String handlerKey)
eu.cloudnetservice.driver.network.buffer.DataBuf.Mutable	prepareClusterData(boolean force, String @NonNull ... selectedHandlers)
eu.cloudnetservice.driver.network.buffer.DataBuf.Mutable	prepareClusterData(boolean force, @NonNull Predicate<eu.cloudnetservice.node.cluster.sync.DataSyncHandler<?>> filter)
protected int	readMergeInput(@NonNull Console console)
void	registerHandler(@NonNull eu.cloudnetservice.node.cluster.sync.DataSyncHandler<?> handler)
protected void	serializeData(@NonNull Object data, @NonNull eu.cloudnetservice.node.cluster.sync.DataSyncHandler<?> handler, eu.cloudnetservice.driver.network.buffer.DataBuf.Mutable target)
void	unregisterHandler(@NonNull eu.cloudnetservice.node.cluster.sync.DataSyncHandler<?> handler)
void	unregisterHandler(@NonNull ClassLoader loader)
void	unregisterHandler(@NonNull String handlerKey)
protected int	waitForCorrectMergeInput(@NonNull Console console)

Methods inherited from class Object

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

Field Details

LOGGER

private static final org.slf4j.Logger LOGGER

i18n

private final eu.cloudnetservice.driver.language.I18n i18n

console

private final Console console

handlers

private final Map<String, eu.cloudnetservice.node.cluster.sync.DataSyncHandler<?>> handlers

Constructor Details

DefaultDataSyncRegistry

@Inject
public DefaultDataSyncRegistry(@NonNull @Service
 @NonNull eu.cloudnetservice.driver.language.I18n i18n,
 @NonNull
 @NonNull Console console)

Method Details

registerHandler

public void registerHandler(@NonNull
 @NonNull eu.cloudnetservice.node.cluster.sync.DataSyncHandler<?> handler)

Specified by:

registerHandler in interface eu.cloudnetservice.node.cluster.sync.DataSyncRegistry

unregisterHandler

public void unregisterHandler(@NonNull
 @NonNull eu.cloudnetservice.node.cluster.sync.DataSyncHandler<?> handler)

Specified by:

unregisterHandler in interface eu.cloudnetservice.node.cluster.sync.DataSyncRegistry

unregisterHandler

public void unregisterHandler(@NonNull
 @NonNull String handlerKey)

Specified by:

unregisterHandler in interface eu.cloudnetservice.node.cluster.sync.DataSyncRegistry

unregisterHandler

public void unregisterHandler(@NonNull
 @NonNull ClassLoader loader)

Specified by:

unregisterHandler in interface eu.cloudnetservice.node.cluster.sync.DataSyncRegistry

hasHandler

public boolean hasHandler(@NonNull
 @NonNull String handlerKey)

Specified by:

hasHandler in interface eu.cloudnetservice.node.cluster.sync.DataSyncRegistry

prepareClusterData

@NonNull
public eu.cloudnetservice.driver.network.buffer.DataBuf.Mutable prepareClusterData(boolean force,
 String @NonNull ... selectedHandlers)

Specified by:

prepareClusterData in interface eu.cloudnetservice.node.cluster.sync.DataSyncRegistry

prepareClusterData

@NonNull
public eu.cloudnetservice.driver.network.buffer.DataBuf.Mutable prepareClusterData(boolean force,
 @NonNull
 @NonNull Predicate<eu.cloudnetservice.node.cluster.sync.DataSyncHandler<?>> filter)

Specified by:

prepareClusterData in interface eu.cloudnetservice.node.cluster.sync.DataSyncRegistry

handle

@Nullable
public @Nullable eu.cloudnetservice.driver.network.buffer.DataBuf handle(@NonNull
 @NonNull eu.cloudnetservice.driver.network.buffer.DataBuf input,
 boolean force)

Specified by:

handle in interface eu.cloudnetservice.node.cluster.sync.DataSyncRegistry

serializeData

protected void serializeData(@NonNull
 @NonNull Object data,
 @NonNull
 @NonNull eu.cloudnetservice.node.cluster.sync.DataSyncHandler<?> handler,
 @NonNull
 eu.cloudnetservice.driver.network.buffer.DataBuf.Mutable target)

waitForCorrectMergeInput

protected int waitForCorrectMergeInput(@NonNull
 @NonNull Console console)

readMergeInput

protected int readMergeInput(@NonNull
 @NonNull Console console)