Class NodeCloudServiceFactory

java.lang.Object

eu.cloudnetservice.node.impl.service.defaults.NodeCloudServiceFactory

All Implemented Interfaces:

eu.cloudnetservice.driver.provider.CloudServiceFactory

@Singleton
@Provides(eu.cloudnetservice.driver.provider.CloudServiceFactory.class)
public class NodeCloudServiceFactory
extends Object
implements eu.cloudnetservice.driver.provider.CloudServiceFactory

Field Summary

Fields

Modifier and Type	Field	Description
private final ScheduledExecutorService	createRetryExecutor
private final eu.cloudnetservice.driver.event.EventManager	eventManager
private final eu.cloudnetservice.driver.provider.GroupConfigurationProvider	groupProvider
private static final org.slf4j.Logger	LOGGER
private final eu.cloudnetservice.node.cluster.NodeServerProvider	nodeServerProvider
private final Lock	serviceCreationLock
private final InternalCloudServiceManager	serviceManager

Constructor Summary

Constructors

Constructor

Description

NodeCloudServiceFactory(@NonNull eu.cloudnetservice.driver.network.rpc.factory.RPCFactory rpcFactory, @NonNull eu.cloudnetservice.driver.event.EventManager eventManager, @NonNull eu.cloudnetservice.driver.network.rpc.handler.RPCHandlerRegistry handlerRegistry, @NonNull InternalCloudServiceManager serviceManager, @NonNull eu.cloudnetservice.node.cluster.NodeServerProvider nodeServerProvider, @NonNull eu.cloudnetservice.driver.provider.GroupConfigurationProvider groupProvider)

Method Summary

Modifier and Type	Method	Description
@NonNull eu.cloudnetservice.driver.service.ServiceCreateResult	createCloudService(@NonNull eu.cloudnetservice.driver.service.ServiceConfiguration maybeServiceConfiguration)
@NonNull CompletableFuture<eu.cloudnetservice.driver.service.ServiceCreateResult>	createCloudServiceAsync(@NonNull eu.cloudnetservice.driver.service.ServiceConfiguration configuration)
protected void	includeGroupComponents(@NonNull eu.cloudnetservice.driver.service.ServiceConfiguration input, eu.cloudnetservice.driver.service.ServiceConfiguration.Builder output)
protected @NonNull eu.cloudnetservice.driver.service.ServiceCreateResult	processServiceStartResponse(@NonNull eu.cloudnetservice.driver.service.ServiceCreateResult result, @NonNull eu.cloudnetservice.node.cluster.NodeServer associatedNode)
private void	registerServiceChannelListener()
protected void	replaceServiceId(@NonNull eu.cloudnetservice.driver.service.ServiceConfiguration input, eu.cloudnetservice.driver.service.ServiceConfiguration.Builder output)
protected void	replaceServiceUniqueId(@NonNull eu.cloudnetservice.driver.service.ServiceConfiguration input, eu.cloudnetservice.driver.service.ServiceConfiguration.Builder output)
protected @NonNull eu.cloudnetservice.driver.service.ServiceCreateResult	scheduleCreateRetryIfEnabled(@NonNull eu.cloudnetservice.driver.service.ServiceCreateRetryConfiguration retryConfiguration, @NonNull eu.cloudnetservice.driver.service.ServiceConfiguration serviceConfiguration)
protected @NonNull eu.cloudnetservice.driver.service.ServiceCreateResult	sendNodeServerStartRequest(@NonNull String message, @NonNull String targetNode, @NonNull eu.cloudnetservice.driver.service.ServiceConfiguration configuration)

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

eventManager

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

serviceManager

private final InternalCloudServiceManager serviceManager

nodeServerProvider

private final eu.cloudnetservice.node.cluster.NodeServerProvider nodeServerProvider

groupProvider

private final eu.cloudnetservice.driver.provider.GroupConfigurationProvider groupProvider

serviceCreationLock

private final Lock serviceCreationLock

createRetryExecutor

private final ScheduledExecutorService createRetryExecutor

Constructor Details

NodeCloudServiceFactory

@Inject
public NodeCloudServiceFactory(@NonNull
 @NonNull eu.cloudnetservice.driver.network.rpc.factory.RPCFactory rpcFactory,
 @NonNull
 @NonNull eu.cloudnetservice.driver.event.EventManager eventManager,
 @NonNull
 @NonNull eu.cloudnetservice.driver.network.rpc.handler.RPCHandlerRegistry handlerRegistry,
 @NonNull
 @NonNull InternalCloudServiceManager serviceManager,
 @NonNull
 @NonNull eu.cloudnetservice.node.cluster.NodeServerProvider nodeServerProvider,
 @NonNull
 @NonNull eu.cloudnetservice.driver.provider.GroupConfigurationProvider groupProvider)

Method Details

registerServiceChannelListener

@Inject
private void registerServiceChannelListener()

createCloudService

@NonNull
public @NonNull eu.cloudnetservice.driver.service.ServiceCreateResult createCloudService(@NonNull
 @NonNull eu.cloudnetservice.driver.service.ServiceConfiguration maybeServiceConfiguration)

Specified by:

createCloudService in interface eu.cloudnetservice.driver.provider.CloudServiceFactory

createCloudServiceAsync

@NonNull
public @NonNull CompletableFuture<eu.cloudnetservice.driver.service.ServiceCreateResult> createCloudServiceAsync(@NonNull
 @NonNull eu.cloudnetservice.driver.service.ServiceConfiguration configuration)

Specified by:

createCloudServiceAsync in interface eu.cloudnetservice.driver.provider.CloudServiceFactory

processServiceStartResponse

@NonNull
protected @NonNull eu.cloudnetservice.driver.service.ServiceCreateResult processServiceStartResponse(@NonNull
 @NonNull eu.cloudnetservice.driver.service.ServiceCreateResult result,
 @NonNull
 @NonNull eu.cloudnetservice.node.cluster.NodeServer associatedNode)

sendNodeServerStartRequest

@NonNull
protected @NonNull eu.cloudnetservice.driver.service.ServiceCreateResult sendNodeServerStartRequest(@NonNull
 @NonNull String message,
 @NonNull
 @NonNull String targetNode,
 @NonNull
 @NonNull eu.cloudnetservice.driver.service.ServiceConfiguration configuration)

scheduleCreateRetryIfEnabled

@NonNull
protected @NonNull eu.cloudnetservice.driver.service.ServiceCreateResult scheduleCreateRetryIfEnabled(@NonNull
 @NonNull eu.cloudnetservice.driver.service.ServiceCreateRetryConfiguration retryConfiguration,
 @NonNull
 @NonNull eu.cloudnetservice.driver.service.ServiceConfiguration serviceConfiguration)

includeGroupComponents

protected void includeGroupComponents(@NonNull
 @NonNull eu.cloudnetservice.driver.service.ServiceConfiguration input,
 @NonNull
 eu.cloudnetservice.driver.service.ServiceConfiguration.Builder output)

replaceServiceId

protected void replaceServiceId(@NonNull
 @NonNull eu.cloudnetservice.driver.service.ServiceConfiguration input,
 @NonNull
 eu.cloudnetservice.driver.service.ServiceConfiguration.Builder output)

replaceServiceUniqueId

protected void replaceServiceUniqueId(@NonNull
 @NonNull eu.cloudnetservice.driver.service.ServiceConfiguration input,
 @NonNull
 eu.cloudnetservice.driver.service.ServiceConfiguration.Builder output)