Class PlatformBridgeManagement<P,I>

java.lang.Object

eu.cloudnetservice.modules.bridge.platform.PlatformBridgeManagement<P,I>

All Implemented Interfaces:

BridgeManagement

Direct Known Subclasses:

BukkitBridgeManagement, BungeeCordBridgeManagement, FabricBridgeManagement, LimboLoohpBridgeManagement, MinestomBridgeManagement, NukkitBridgeManagement, SpongeBridgeManagement, VelocityBridgeManagement, WaterDogPEBridgeManagement

public abstract class PlatformBridgeManagement<P,I>
extends Object
implements BridgeManagement

Field Summary

Fields

Modifier and Type	Field	Description
protected final BridgeServiceHelper	bridgeServiceHelper
protected final Map<UUID,eu.cloudnetservice.driver.service.ServiceInfoSnapshot>	cachedServices
protected Consumer<eu.cloudnetservice.driver.service.ServiceInfoSnapshot>	cacheRegisterListener
protected Predicate<eu.cloudnetservice.driver.service.ServiceInfoSnapshot>	cacheTester
protected Consumer<eu.cloudnetservice.driver.service.ServiceInfoSnapshot>	cacheUnregisterListener
protected BridgeConfiguration	configuration
protected static final Predicate<eu.cloudnetservice.driver.service.ServiceInfoSnapshot>	CONNECTED_SERVICE_TESTER
protected ProxyFallbackConfiguration	currentFallbackConfiguration
protected final eu.cloudnetservice.driver.event.EventManager	eventManager
protected final com.github.benmanes.caffeine.cache.LoadingCache<UUID,FallbackProfile>	fallbackProfiles
protected final NetworkServiceInfo	ownNetworkServiceInfo
protected final PlayerManager	playerManager
protected eu.cloudnetservice.driver.service.ServiceTask	selfTask
protected final eu.cloudnetservice.driver.network.rpc.RPCSender	sender
protected final eu.cloudnetservice.wrapper.holder.ServiceInfoHolder	serviceInfoHolder
protected final eu.cloudnetservice.driver.provider.CloudServiceProvider	serviceProvider
protected final eu.cloudnetservice.driver.provider.ServiceTaskProvider	taskProvider
protected final eu.cloudnetservice.wrapper.configuration.WrapperConfiguration	wrapperConfig

Fields inherited from interface eu.cloudnetservice.modules.bridge.BridgeManagement

BRIDGE_CHANNEL_NAME, BRIDGE_PLAYER_CHANNEL_NAME, BRIDGE_PLAYER_DB_NAME, BRIDGE_PLAYER_EXECUTOR_CHANNEL_NAME

Constructor Summary

Constructors

Constructor

Description

PlatformBridgeManagement(@NonNull eu.cloudnetservice.driver.network.rpc.factory.RPCFactory rpcFactory, @NonNull eu.cloudnetservice.driver.event.EventManager eventManager, @NonNull eu.cloudnetservice.driver.network.NetworkClient networkClient, @NonNull eu.cloudnetservice.driver.provider.ServiceTaskProvider taskProvider, @NonNull BridgeServiceHelper serviceHelper, @NonNull eu.cloudnetservice.wrapper.holder.ServiceInfoHolder serviceInfoHolder, @NonNull eu.cloudnetservice.driver.provider.CloudServiceProvider serviceProvider, @NonNull eu.cloudnetservice.wrapper.configuration.WrapperConfiguration wrapperConfig)

Method Summary

Modifier and Type	Method	Description
protected @NonNull Optional<eu.cloudnetservice.driver.service.ServiceInfoSnapshot>	anyTaskService(@NonNull String task, @NonNull FallbackProfile profile, @Nullable String currentServerName)
void	appendServiceInformation(@NonNull eu.cloudnetservice.wrapper.event.ServiceInfoPropertiesConfigureEvent configureEvent)
@NonNull Optional<eu.cloudnetservice.driver.service.ServiceInfoSnapshot>	cachedService(@NonNull UUID uniqueId)
@NonNull Optional<eu.cloudnetservice.driver.service.ServiceInfoSnapshot>	cachedService(@NonNull Predicate<eu.cloudnetservice.driver.service.ServiceInfoSnapshot> filter)
@NonNull Collection<eu.cloudnetservice.driver.service.ServiceInfoSnapshot>	cachedServices()
@NonNull BridgeConfiguration	configuration()	Gets the bridge configuration that is currently loaded and applied.
void	configuration(@NonNull BridgeConfiguration configuration)	Sets the bridge configuration for every connected component in the cluster that is running the bridge.
void	configurationSilently(@NonNull BridgeConfiguration configuration)
abstract I	createPlayerInformation(P player)
abstract @NonNull PlayerExecutor	directPlayerExecutor(@NonNull UUID uniqueId)
@NonNull Optional<eu.cloudnetservice.driver.service.ServiceInfoSnapshot>	fallback(@NonNull UUID playerId, @Nullable String currentServerName, @Nullable String virtualHost, @NonNull Function<String,Boolean> permissionTester)
abstract @NonNull Optional<eu.cloudnetservice.driver.service.ServiceInfoSnapshot>	fallback(P player)
abstract @NonNull Optional<eu.cloudnetservice.driver.service.ServiceInfoSnapshot>	fallback(P player, @Nullable String currServer)
void	handleFallbackConnectionSuccess(@NonNull UUID uniqueId)
abstract void	handleFallbackConnectionSuccess(P player)
void	handleServiceUpdate(@NonNull eu.cloudnetservice.driver.service.ServiceInfoSnapshot snapshot)
void	handleTaskUpdate(@NonNull String name, @Nullable eu.cloudnetservice.driver.service.ServiceTask task)
boolean	isOnAnyFallbackInstance(@Nullable String currentServerName, @Nullable String virtualHost, @NonNull Function<String,Boolean> permissionTester)
abstract boolean	isOnAnyFallbackInstance(P player)
@NonNull NetworkServiceInfo	ownNetworkServiceInfo()
abstract @NonNull BiFunction<P,String,Boolean>	permissionFunction()
@NonNull Stream<ProxyFallback>	possibleFallbacks(@Nullable String currentServerName, @Nullable String virtualHost, @NonNull Function<String,Boolean> permissionTester)
void	postInit()	Execute the post initialization of the bridge management.
void	removeFallbackProfile(@NonNull UUID uniqueId)
abstract void	removeFallbackProfile(P player)
@Nullable eu.cloudnetservice.driver.service.ServiceTask	selfTask()
abstract @NonNull ServicePlayer	wrapPlayer(P player)

Methods inherited from class java.lang.Object

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

Methods inherited from interface eu.cloudnetservice.modules.bridge.BridgeManagement

registerServices

Field Details

CONNECTED_SERVICE_TESTER

protected static final Predicate<eu.cloudnetservice.driver.service.ServiceInfoSnapshot> CONNECTED_SERVICE_TESTER

sender

protected final eu.cloudnetservice.driver.network.rpc.RPCSender sender

eventManager

protected final eu.cloudnetservice.driver.event.EventManager eventManager

playerManager

protected final PlayerManager playerManager

taskProvider

protected final eu.cloudnetservice.driver.provider.ServiceTaskProvider taskProvider

serviceInfoHolder

protected final eu.cloudnetservice.wrapper.holder.ServiceInfoHolder serviceInfoHolder

serviceProvider

protected final eu.cloudnetservice.driver.provider.CloudServiceProvider serviceProvider

bridgeServiceHelper

protected final BridgeServiceHelper bridgeServiceHelper

ownNetworkServiceInfo

protected final NetworkServiceInfo ownNetworkServiceInfo

wrapperConfig

protected final eu.cloudnetservice.wrapper.configuration.WrapperConfiguration wrapperConfig

fallbackProfiles

protected final com.github.benmanes.caffeine.cache.LoadingCache<UUID,FallbackProfile> fallbackProfiles

cachedServices

protected final Map<UUID,eu.cloudnetservice.driver.service.ServiceInfoSnapshot> cachedServices

selfTask

protected volatile eu.cloudnetservice.driver.service.ServiceTask selfTask

configuration

protected volatile BridgeConfiguration configuration

currentFallbackConfiguration

protected volatile ProxyFallbackConfiguration currentFallbackConfiguration

cacheTester

protected volatile Predicate<eu.cloudnetservice.driver.service.ServiceInfoSnapshot> cacheTester

cacheRegisterListener

protected volatile Consumer<eu.cloudnetservice.driver.service.ServiceInfoSnapshot> cacheRegisterListener

cacheUnregisterListener

protected volatile Consumer<eu.cloudnetservice.driver.service.ServiceInfoSnapshot> cacheUnregisterListener

Constructor Details

PlatformBridgeManagement

public PlatformBridgeManagement(@NonNull
 @NonNull eu.cloudnetservice.driver.network.rpc.factory.RPCFactory rpcFactory,
 @NonNull
 @NonNull eu.cloudnetservice.driver.event.EventManager eventManager,
 @NonNull
 @NonNull eu.cloudnetservice.driver.network.NetworkClient networkClient,
 @NonNull
 @NonNull eu.cloudnetservice.driver.provider.ServiceTaskProvider taskProvider,
 @NonNull
 @NonNull BridgeServiceHelper serviceHelper,
 @NonNull
 @NonNull eu.cloudnetservice.wrapper.holder.ServiceInfoHolder serviceInfoHolder,
 @NonNull
 @NonNull eu.cloudnetservice.driver.provider.CloudServiceProvider serviceProvider,
 @NonNull
 @NonNull eu.cloudnetservice.wrapper.configuration.WrapperConfiguration wrapperConfig)

Method Details

configuration

@NonNull
public @NonNull BridgeConfiguration configuration()

Description copied from interface: BridgeManagement

Gets the bridge configuration that is currently loaded and applied.

Specified by:

configuration in interface BridgeManagement

Returns:

the currently loaded configuration.

configuration

public void configuration(@NonNull
 @NonNull BridgeConfiguration configuration)

Description copied from interface: BridgeManagement

Sets the bridge configuration for every connected component in the cluster that is running the bridge.

Specified by:

configuration in interface BridgeManagement

Parameters:

configuration - the configuration to set.

configurationSilently

public void configurationSilently(@NonNull
 @NonNull BridgeConfiguration configuration)

appendServiceInformation

public void appendServiceInformation(@NonNull
 @NonNull eu.cloudnetservice.wrapper.event.ServiceInfoPropertiesConfigureEvent configureEvent)

cachedServices

@NonNull
public @NonNull Collection<eu.cloudnetservice.driver.service.ServiceInfoSnapshot> cachedServices()

selfTask

@Nullable
public @Nullable eu.cloudnetservice.driver.service.ServiceTask selfTask()

handleTaskUpdate

public void handleTaskUpdate(@NonNull
 @NonNull String name,
 @Nullable
 @Nullable eu.cloudnetservice.driver.service.ServiceTask task)

cachedService

@NonNull
public @NonNull Optional<eu.cloudnetservice.driver.service.ServiceInfoSnapshot> cachedService(@NonNull
 @NonNull Predicate<eu.cloudnetservice.driver.service.ServiceInfoSnapshot> filter)

cachedService

@NonNull
public @NonNull Optional<eu.cloudnetservice.driver.service.ServiceInfoSnapshot> cachedService(@NonNull
 @NonNull UUID uniqueId)

handleServiceUpdate

public void handleServiceUpdate(@NonNull
 @NonNull eu.cloudnetservice.driver.service.ServiceInfoSnapshot snapshot)

fallback

@NonNull
public @NonNull Optional<eu.cloudnetservice.driver.service.ServiceInfoSnapshot> fallback(@NonNull
 @NonNull UUID playerId,
 @Nullable
 @Nullable String currentServerName,
 @Nullable
 @Nullable String virtualHost,
 @NonNull
 @NonNull Function<String,Boolean> permissionTester)

possibleFallbacks

@NonNull
public @NonNull Stream<ProxyFallback> possibleFallbacks(@Nullable
 @Nullable String currentServerName,
 @Nullable
 @Nullable String virtualHost,
 @NonNull
 @NonNull Function<String,Boolean> permissionTester)

isOnAnyFallbackInstance

public boolean isOnAnyFallbackInstance(@Nullable
 @Nullable String currentServerName,
 @Nullable
 @Nullable String virtualHost,
 @NonNull
 @NonNull Function<String,Boolean> permissionTester)

anyTaskService

@NonNull
protected @NonNull Optional<eu.cloudnetservice.driver.service.ServiceInfoSnapshot> anyTaskService(@NonNull
 @NonNull String task,
 @NonNull
 @NonNull FallbackProfile profile,
 @Nullable
 @Nullable String currentServerName)

handleFallbackConnectionSuccess

public void handleFallbackConnectionSuccess(@NonNull
 @NonNull UUID uniqueId)

removeFallbackProfile

public void removeFallbackProfile(@NonNull
 @NonNull UUID uniqueId)

postInit

public void postInit()

Description copied from interface: BridgeManagement

Execute the post initialization of the bridge management. Populating the caches and applying startup time actions.

Note: This method should not be used as part of the api and is for internal use only.

Specified by:

postInit in interface BridgeManagement

ownNetworkServiceInfo

@NonNull
public @NonNull NetworkServiceInfo ownNetworkServiceInfo()

wrapPlayer

@NonNull
public abstract @NonNull ServicePlayer wrapPlayer(@NonNull
 P player)

createPlayerInformation

@NonNull
public abstract I createPlayerInformation(@NonNull
 P player)

permissionFunction

@NonNull
public abstract @NonNull BiFunction<P,String,Boolean> permissionFunction()

isOnAnyFallbackInstance

public abstract boolean isOnAnyFallbackInstance(@NonNull
 P player)

fallback

@NonNull
public abstract @NonNull Optional<eu.cloudnetservice.driver.service.ServiceInfoSnapshot> fallback(@NonNull
 P player)

fallback

@NonNull
public abstract @NonNull Optional<eu.cloudnetservice.driver.service.ServiceInfoSnapshot> fallback(@NonNull
 P player,
 @Nullable
 @Nullable String currServer)

handleFallbackConnectionSuccess

public abstract void handleFallbackConnectionSuccess(@NonNull
 P player)

removeFallbackProfile

public abstract void removeFallbackProfile(@NonNull
 P player)

directPlayerExecutor

@NonNull
public abstract @NonNull PlayerExecutor directPlayerExecutor(@NonNull
 @NonNull UUID uniqueId)