com.jlupin.impl.client.util

Class JLupinClientUtil

java.lang.Object

com.jlupin.impl.client.util.JLupinClientUtil

public class JLupinClientUtil
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JLupinClientUtil.JLupinLoadBalancerAlgorithmType

Method Summary

Modifier and Type	Method and Description
static void	closeResources()
static JLupinDelegator	generateInnerMicroserviceLoadBalancerDelegator(int howOftenCheckingServerInMillis, int repeatsAmount, int changeServerIntervalInMillis, PortType portType)
static JLupinDelegator	generateInnerMicroserviceLoadBalancerDelegator(int howOftenCheckingServerInMillis, int repeatsAmount, int changeServerIntervalInMillis, PortType portType, int connectionTimeoutInMilliseconds, int readTimeoutInMilliseconds)
static JLupinDelegator	generateInnerMicroserviceLoadBalancerDelegator(int howOftenCheckingServerInMillis, int repeatsAmount, int changeServerIntervalInMillis, PortType portType, int connectionTimeoutInMilliseconds, int readTimeoutInMilliseconds, boolean isKeepAlive, boolean isOOBInline, boolean isTcpNoDelay, boolean isReuseAddress, int sendBufferSize, int receiveBufferSize, int soLinger, int trafficClass)
static JLupinDelegator	generateInnerMicroserviceLoadBalancerDelegator(int howOftenCheckingServerInMillis, int repeatsAmount, int changeServerIntervalInMillis, PortType portType, int connectionTimeoutInMilliseconds, int readTimeoutInMilliseconds, boolean isKeepAlive, boolean isOOBInline, boolean isTcpNoDelay, boolean isReuseAddress, int sendBufferSize, int receiveBufferSize, int soLinger, int trafficClass, JLupinClientUtil.JLupinLoadBalancerAlgorithmType jLupinLoadBalancerAlgorithmType)
static JLupinDelegator	generateInnerMicroserviceLoadBalancerDelegator(int howOftenCheckingServerInMillis, int repeatsAmount, int changeServerIntervalInMillis, PortType portType, int connectionTimeoutInMilliseconds, int readTimeoutInMilliseconds, JLupinClientUtil.JLupinLoadBalancerAlgorithmType jLupinLoadBalancerAlgorithmType)
static JLupinDelegator	generateInnerMicroserviceLoadBalancerDelegator(int howOftenCheckingServerInMillis, int repeatsAmount, int changeServerIntervalInMillis, PortType portType, JLupinClientUtil.JLupinLoadBalancerAlgorithmType jLupinLoadBalancerAlgorithmType)
static JLupinDelegator	generateInnerMicroserviceLoadBalancerDelegator(PortType portType)
static JLupinDelegator	generateInnerMicroserviceLoadBalancerDelegator(PortType portType, JLupinClientUtil.JLupinLoadBalancerAlgorithmType jLupinLoadBalancerAlgorithmType)
static JLupinLoadBalancer	generateLoadBalancer(com.jlupin.impl.balancer.servicerepository.JLupinServiceRepositoryImpl jLupinServiceRepositoryImpl, int repeatsAmount, int changeServerIntervalInMillis, JLupinClientUtil.JLupinLoadBalancerAlgorithmType jLupinLoadBalancerAlgorithmType, JLupinLogger jLupinLogger)
static JLupinDelegator	generateLoadBalancerDelegator(PortType portType, JLupinLoadBalancer jLupinLoadBalancer)
static JLupinDelegator	generateOuterMicroserviceLoadBalancerDelegator(int howOftenCheckingServerInMillis, int repeatsAmount, int changeServerIntervalInMillis, PortType portType, int connectionTimeoutInMilliseconds, int readTimeoutInMilliseconds, boolean isKeepAlive, boolean isOOBInline, boolean isTcpNoDelay, boolean isReuseAddress, int sendBufferSize, int receiveBufferSize, int soLinger, int trafficClass, com.jlupin.common.various.JLupinMainServerInZoneConfiguration[] jLupinMainServerInZoneConfigurations)
static JLupinDelegator	generateOuterMicroserviceLoadBalancerDelegator(int howOftenCheckingServerInMillis, int repeatsAmount, int changeServerIntervalInMillis, PortType portType, int connectionTimeoutInMilliseconds, int readTimeoutInMilliseconds, boolean isKeepAlive, boolean isOOBInline, boolean isTcpNoDelay, boolean isReuseAddress, int sendBufferSize, int receiveBufferSize, int soLinger, int trafficClass, com.jlupin.common.various.JLupinMainServerInZoneConfiguration[] jLupinMainServerInZoneConfigurations, JLupinSerializer jLupinSerializer, JLupinLogger jLupinLogger)
static JLupinDelegator	generateOuterMicroserviceLoadBalancerDelegator(int howOftenCheckingServerInMillis, int repeatsAmount, int changeServerIntervalInMillis, PortType portType, int connectionTimeoutInMilliseconds, int readTimeoutInMilliseconds, com.jlupin.common.various.JLupinMainServerInZoneConfiguration[] jLupinMainServerInZoneConfigurations)
static JLupinDelegator	generateOuterMicroserviceLoadBalancerDelegator(int howOftenCheckingServerInMillis, int repeatsAmount, int changeServerIntervalInMillis, PortType portType, int connectionTimeoutInMilliseconds, int readTimeoutInMilliseconds, com.jlupin.common.various.JLupinMainServerInZoneConfiguration[] jLupinMainServerInZoneConfigurations, JLupinSerializer jLupinSerializer, JLupinLogger jLupinLogger)
static JLupinDelegator	generateOuterMicroserviceLoadBalancerDelegator(int howOftenCheckingServerInMillis, int repeatsAmount, int changeServerIntervalInMillis, PortType portType, com.jlupin.common.various.JLupinMainServerInZoneConfiguration[] jLupinMainServerInZoneConfigurations)
static JLupinDelegator	generateOuterMicroserviceLoadBalancerDelegator(int howOftenCheckingServerInMillis, int repeatsAmount, int changeServerIntervalInMillis, PortType portType, com.jlupin.common.various.JLupinMainServerInZoneConfiguration[] jLupinMainServerInZoneConfigurations, JLupinSerializer jLupinSerializer, JLupinLogger jLupinLogger)
static JLupinDelegator	generateOuterMicroserviceLoadBalancerDelegator(PortType portType, com.jlupin.common.various.JLupinMainServerInZoneConfiguration[] jLupinMainServerInZoneConfigurations)
static JLupinDelegator	generateOuterMicroserviceLoadBalancerDelegator(PortType portType, com.jlupin.common.various.JLupinMainServerInZoneConfiguration[] jLupinMainServerInZoneConfigurations, JLupinSerializer jLupinSerializer, JLupinLogger jLupinLogger)
static <T> T	generateRemote(JLupinDelegator jLupinDelegator, String microserviceName, Class serviceClass)
static <T> T	generateRemote(JLupinDelegator jLupinDelegator, String microserviceName, Class serviceClass, JLupinInputParameterVariablesProducer jLupinInputParameterVariablesProducer)
static <T> T	generateRemote(JLupinDelegator jLupinDelegator, String microserviceName, String serviceName, Class serviceClass)
static <T> T	generateRemote(JLupinDelegator jLupinDelegator, String microserviceName, String serviceName, Class serviceClass, JLupinInputParameterVariablesProducer jLupinInputParameterVariablesProducer)
static com.jlupin.interfaces.balancer.repository.JLupinServiceRepository	generateServiceRepository(int howOftenCheckingServerInMillis, JLupinServiceRepositoryType jLupinServiceRepositoryType, com.jlupin.common.various.JLupinMainServerInZoneConfiguration[] jLupinMainServerInZoneConfigurations, JLupinServiceRepositoryConnectionToServerConfiguration connectionDetailsToConnectMainServersInZone, JLupinLogger jLupinLogger)
static ExecutorService	getExecutorServiceByNameManagedByJLupin(String threadPoolName)
static void	setVariables(int _serviceRepositoryHowOftenCheckingServerInMillis, int _loadBalancerConnectionRepeatsAmount, int _roundRobinLoadBalancerChangeServerIntervalInMillis)

Methods inherited from class java.lang.Object

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

Method Detail

setVariables

public static void setVariables(int _serviceRepositoryHowOftenCheckingServerInMillis,
                                int _loadBalancerConnectionRepeatsAmount,
                                int _roundRobinLoadBalancerChangeServerIntervalInMillis)

generateServiceRepository

public static com.jlupin.interfaces.balancer.repository.JLupinServiceRepository generateServiceRepository(int howOftenCheckingServerInMillis,
                                                                                                          JLupinServiceRepositoryType jLupinServiceRepositoryType,
                                                                                                          com.jlupin.common.various.JLupinMainServerInZoneConfiguration[] jLupinMainServerInZoneConfigurations,
                                                                                                          JLupinServiceRepositoryConnectionToServerConfiguration connectionDetailsToConnectMainServersInZone,
                                                                                                          JLupinLogger jLupinLogger)

generateLoadBalancer

public static JLupinLoadBalancer generateLoadBalancer(com.jlupin.impl.balancer.servicerepository.JLupinServiceRepositoryImpl jLupinServiceRepositoryImpl,
                                                      int repeatsAmount,
                                                      int changeServerIntervalInMillis,
                                                      JLupinClientUtil.JLupinLoadBalancerAlgorithmType jLupinLoadBalancerAlgorithmType,
                                                      JLupinLogger jLupinLogger)

generateLoadBalancerDelegator

public static JLupinDelegator generateLoadBalancerDelegator(PortType portType,
                                                            JLupinLoadBalancer jLupinLoadBalancer)

generateInnerMicroserviceLoadBalancerDelegator

public static JLupinDelegator generateInnerMicroserviceLoadBalancerDelegator(PortType portType)

generateInnerMicroserviceLoadBalancerDelegator

public static JLupinDelegator generateInnerMicroserviceLoadBalancerDelegator(PortType portType,
                                                                             JLupinClientUtil.JLupinLoadBalancerAlgorithmType jLupinLoadBalancerAlgorithmType)

generateOuterMicroserviceLoadBalancerDelegator

public static JLupinDelegator generateOuterMicroserviceLoadBalancerDelegator(PortType portType,
                                                                             com.jlupin.common.various.JLupinMainServerInZoneConfiguration[] jLupinMainServerInZoneConfigurations)

generateOuterMicroserviceLoadBalancerDelegator

public static JLupinDelegator generateOuterMicroserviceLoadBalancerDelegator(PortType portType,
                                                                             com.jlupin.common.various.JLupinMainServerInZoneConfiguration[] jLupinMainServerInZoneConfigurations,
                                                                             JLupinSerializer jLupinSerializer,
                                                                             JLupinLogger jLupinLogger)

generateInnerMicroserviceLoadBalancerDelegator

public static JLupinDelegator generateInnerMicroserviceLoadBalancerDelegator(int howOftenCheckingServerInMillis,
                                                                             int repeatsAmount,
                                                                             int changeServerIntervalInMillis,
                                                                             PortType portType)

generateInnerMicroserviceLoadBalancerDelegator

public static JLupinDelegator generateInnerMicroserviceLoadBalancerDelegator(int howOftenCheckingServerInMillis,
                                                                             int repeatsAmount,
                                                                             int changeServerIntervalInMillis,
                                                                             PortType portType,
                                                                             JLupinClientUtil.JLupinLoadBalancerAlgorithmType jLupinLoadBalancerAlgorithmType)

generateOuterMicroserviceLoadBalancerDelegator

public static JLupinDelegator generateOuterMicroserviceLoadBalancerDelegator(int howOftenCheckingServerInMillis,
                                                                             int repeatsAmount,
                                                                             int changeServerIntervalInMillis,
                                                                             PortType portType,
                                                                             com.jlupin.common.various.JLupinMainServerInZoneConfiguration[] jLupinMainServerInZoneConfigurations)

generateOuterMicroserviceLoadBalancerDelegator

public static JLupinDelegator generateOuterMicroserviceLoadBalancerDelegator(int howOftenCheckingServerInMillis,
                                                                             int repeatsAmount,
                                                                             int changeServerIntervalInMillis,
                                                                             PortType portType,
                                                                             com.jlupin.common.various.JLupinMainServerInZoneConfiguration[] jLupinMainServerInZoneConfigurations,
                                                                             JLupinSerializer jLupinSerializer,
                                                                             JLupinLogger jLupinLogger)

generateInnerMicroserviceLoadBalancerDelegator

public static JLupinDelegator generateInnerMicroserviceLoadBalancerDelegator(int howOftenCheckingServerInMillis,
                                                                             int repeatsAmount,
                                                                             int changeServerIntervalInMillis,
                                                                             PortType portType,
                                                                             int connectionTimeoutInMilliseconds,
                                                                             int readTimeoutInMilliseconds)

generateInnerMicroserviceLoadBalancerDelegator

public static JLupinDelegator generateInnerMicroserviceLoadBalancerDelegator(int howOftenCheckingServerInMillis,
                                                                             int repeatsAmount,
                                                                             int changeServerIntervalInMillis,
                                                                             PortType portType,
                                                                             int connectionTimeoutInMilliseconds,
                                                                             int readTimeoutInMilliseconds,
                                                                             JLupinClientUtil.JLupinLoadBalancerAlgorithmType jLupinLoadBalancerAlgorithmType)

generateOuterMicroserviceLoadBalancerDelegator

public static JLupinDelegator generateOuterMicroserviceLoadBalancerDelegator(int howOftenCheckingServerInMillis,
                                                                             int repeatsAmount,
                                                                             int changeServerIntervalInMillis,
                                                                             PortType portType,
                                                                             int connectionTimeoutInMilliseconds,
                                                                             int readTimeoutInMilliseconds,
                                                                             com.jlupin.common.various.JLupinMainServerInZoneConfiguration[] jLupinMainServerInZoneConfigurations)

generateOuterMicroserviceLoadBalancerDelegator

public static JLupinDelegator generateOuterMicroserviceLoadBalancerDelegator(int howOftenCheckingServerInMillis,
                                                                             int repeatsAmount,
                                                                             int changeServerIntervalInMillis,
                                                                             PortType portType,
                                                                             int connectionTimeoutInMilliseconds,
                                                                             int readTimeoutInMilliseconds,
                                                                             com.jlupin.common.various.JLupinMainServerInZoneConfiguration[] jLupinMainServerInZoneConfigurations,
                                                                             JLupinSerializer jLupinSerializer,
                                                                             JLupinLogger jLupinLogger)

generateInnerMicroserviceLoadBalancerDelegator

public static JLupinDelegator generateInnerMicroserviceLoadBalancerDelegator(int howOftenCheckingServerInMillis,
                                                                             int repeatsAmount,
                                                                             int changeServerIntervalInMillis,
                                                                             PortType portType,
                                                                             int connectionTimeoutInMilliseconds,
                                                                             int readTimeoutInMilliseconds,
                                                                             boolean isKeepAlive,
                                                                             boolean isOOBInline,
                                                                             boolean isTcpNoDelay,
                                                                             boolean isReuseAddress,
                                                                             int sendBufferSize,
                                                                             int receiveBufferSize,
                                                                             int soLinger,
                                                                             int trafficClass)

generateInnerMicroserviceLoadBalancerDelegator

public static JLupinDelegator generateInnerMicroserviceLoadBalancerDelegator(int howOftenCheckingServerInMillis,
                                                                             int repeatsAmount,
                                                                             int changeServerIntervalInMillis,
                                                                             PortType portType,
                                                                             int connectionTimeoutInMilliseconds,
                                                                             int readTimeoutInMilliseconds,
                                                                             boolean isKeepAlive,
                                                                             boolean isOOBInline,
                                                                             boolean isTcpNoDelay,
                                                                             boolean isReuseAddress,
                                                                             int sendBufferSize,
                                                                             int receiveBufferSize,
                                                                             int soLinger,
                                                                             int trafficClass,
                                                                             JLupinClientUtil.JLupinLoadBalancerAlgorithmType jLupinLoadBalancerAlgorithmType)

generateOuterMicroserviceLoadBalancerDelegator

public static JLupinDelegator generateOuterMicroserviceLoadBalancerDelegator(int howOftenCheckingServerInMillis,
                                                                             int repeatsAmount,
                                                                             int changeServerIntervalInMillis,
                                                                             PortType portType,
                                                                             int connectionTimeoutInMilliseconds,
                                                                             int readTimeoutInMilliseconds,
                                                                             boolean isKeepAlive,
                                                                             boolean isOOBInline,
                                                                             boolean isTcpNoDelay,
                                                                             boolean isReuseAddress,
                                                                             int sendBufferSize,
                                                                             int receiveBufferSize,
                                                                             int soLinger,
                                                                             int trafficClass,
                                                                             com.jlupin.common.various.JLupinMainServerInZoneConfiguration[] jLupinMainServerInZoneConfigurations)

generateOuterMicroserviceLoadBalancerDelegator

public static JLupinDelegator generateOuterMicroserviceLoadBalancerDelegator(int howOftenCheckingServerInMillis,
                                                                             int repeatsAmount,
                                                                             int changeServerIntervalInMillis,
                                                                             PortType portType,
                                                                             int connectionTimeoutInMilliseconds,
                                                                             int readTimeoutInMilliseconds,
                                                                             boolean isKeepAlive,
                                                                             boolean isOOBInline,
                                                                             boolean isTcpNoDelay,
                                                                             boolean isReuseAddress,
                                                                             int sendBufferSize,
                                                                             int receiveBufferSize,
                                                                             int soLinger,
                                                                             int trafficClass,
                                                                             com.jlupin.common.various.JLupinMainServerInZoneConfiguration[] jLupinMainServerInZoneConfigurations,
                                                                             JLupinSerializer jLupinSerializer,
                                                                             JLupinLogger jLupinLogger)

generateRemote

public static <T> T generateRemote(JLupinDelegator jLupinDelegator,
                                   String microserviceName,
                                   String serviceName,
                                   Class serviceClass)

generateRemote

public static <T> T generateRemote(JLupinDelegator jLupinDelegator,
                                   String microserviceName,
                                   Class serviceClass)

generateRemote

public static <T> T generateRemote(JLupinDelegator jLupinDelegator,
                                   String microserviceName,
                                   String serviceName,
                                   Class serviceClass,
                                   JLupinInputParameterVariablesProducer jLupinInputParameterVariablesProducer)

generateRemote

public static <T> T generateRemote(JLupinDelegator jLupinDelegator,
                                   String microserviceName,
                                   Class serviceClass,
                                   JLupinInputParameterVariablesProducer jLupinInputParameterVariablesProducer)

closeResources

public static void closeResources()

getExecutorServiceByNameManagedByJLupin

public static ExecutorService getExecutorServiceByNameManagedByJLupin(String threadPoolName)