@Service(value={Config.class,BaseConfig.class,DiscoveryLiteConfig.class})
public class Config
extends java.lang.Object
implements BaseConfig, DiscoveryLiteConfig
The properties are described below under.
| Modifier and Type | Field and Description |
|---|---|
static java.lang.String |
CLUSTER_SYNC_SERVICE_INTERVAL_KEY |
static java.lang.String |
CLUSTER_SYNC_SERVICE_TIMEOUT_KEY |
protected long |
clusterSyncServiceInterval |
protected long |
clusterSyncServiceTimeout |
protected long |
connectorPingInterval |
protected long |
connectorPingTimeout |
static long |
DEFAULT_CLUSTER_SYNC_SERVICE_INTERVAL |
static long |
DEFAULT_CLUSTER_SYNC_SERVICE_TIMEOUT |
static long |
DEFAULT_DISCOVERY_LITE_CHECK_INTERVAL
Configure the interval (in seconds) according to which the heartbeats are exchanged in the topology.
|
static int |
DEFAULT_MIN_EVENT_DELAY
Configure the time (in seconds) which must be passed at minimum between sending TOPOLOGY_CHANGING/_CHANGED (avoid flooding).
|
static int |
DEFAULT_SO_TIMEOUT
Configure the socket read timeout (SO_TIMEOUT) for topology connectors.
|
static int |
DEFAULT_SOCKET_CONNECT_TIMEOUT
Configure the socket connect timeout for topology connectors.
|
static long |
DEFAULT_TOPOLOGY_CONNECTOR_INTERVAL
Configure the interval (in seconds) according to which the heartbeats are exchanged in the topology.
|
static long |
DEFAULT_TOPOLOGY_CONNECTOR_TIMEOUT
Configure the timeout (in seconds) after which an instance is considered dead/crashed.
|
static java.lang.String |
DISCOVERY_LITE_CHECK_INTERVAL_KEY |
static java.lang.String |
DISCOVERY_RESOURCE_PATH_KEY |
protected long |
discoveryLiteCheckInterval |
protected java.lang.String |
discoveryResourcePath |
protected boolean |
invertLeaderElectionPrefixOrder |
protected long |
leaderElectionPrefix |
static java.lang.String |
MIN_EVENT_DELAY_KEY |
protected int |
minEventDelay |
static java.lang.String |
SO_TIMEOUT_KEY |
static java.lang.String |
SOCKET_CONNECT_TIMEOUT_KEY |
static java.lang.String |
TOPOLOGY_CONNECTOR_INTERVAL_KEY |
static java.lang.String |
TOPOLOGY_CONNECTOR_TIMEOUT_KEY |
static java.lang.String |
TOPOLOGY_CONNECTOR_URLS_KEY
URLs where to join a topology, eg http://localhost:4502/libs/sling/topology/connector
|
static java.lang.String |
TOPOLOGY_CONNECTOR_WHITELIST_KEY |
protected java.lang.String[] |
topologyConnectorWhitelist |
| Constructor and Description |
|---|
Config() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
activate(java.util.Map<java.lang.String,java.lang.Object> properties) |
protected void |
configure(java.util.Map<java.lang.String,java.lang.Object> properties) |
int |
getBackoffStableFactor()
Returns the (maximum) backoff factor to be used for stable connectors
|
int |
getBackoffStandbyFactor()
Returns the backoff factor to be used for standby (loop) connectors
|
long |
getBackoffStandbyInterval()
Returns the backoff interval for standby (loop) connectors in seconds
|
java.lang.String |
getClusterInstancesPath()
Returns the resource path where cluster instance informations are stored.
|
long |
getClusterSyncServiceIntervalMillis()
Returns the interval (in milliseconds) to be used when waiting for the sync tokens or id mapping
|
long |
getClusterSyncServiceTimeoutMillis()
Returns the timeout (in milliseconds) to be used when waiting for the sync tokens or id mapping
|
long |
getConnectorPingInterval()
Returns the interval (in seconds) in which connectors are pinged
|
long |
getConnectorPingTimeout()
Returns the timeout (in seconds) after which a connector ping is considered invalid/timed out
|
long |
getDiscoveryLiteCheckInterval() |
protected java.lang.String |
getDiscoveryResourcePath() |
java.lang.String |
getIdMapPath()
Returns the configured path to store the idMap to
|
long |
getKeyInterval() |
long |
getLeaderElectionPrefix() |
int |
getMinEventDelay()
Returns the minimum time (in seconds) between sending TOPOLOGY_CHANGING/_CHANGED events - to avoid flooding
|
java.lang.String |
getSharedKey() |
int |
getSocketConnectTimeout()
Returns the socket connect() timeout used by the topology connector, 0 disables the timeout
|
int |
getSoTimeout()
Returns the socket read timeout (SO_TIMEOUT) used by the topology connector, 0 disables the timeout
|
boolean |
getSyncTokenEnabled() |
java.lang.String |
getSyncTokenPath()
Returns the configured path to store the syncTokens to
|
java.net.URL[] |
getTopologyConnectorURLs()
Returns the URLs to which to open a topology connector - or null/empty if no topology connector
is configured (default is null)
|
java.lang.String[] |
getTopologyConnectorWhitelist()
Returns a comma separated list of hostnames and/or ip addresses which are allowed as
remote hosts to open connections to the topology connector servlet
|
boolean |
isAutoStopLocalLoopEnabled() |
boolean |
isEncryptionEnabled() |
boolean |
isGzipConnectorRequestsEnabled() |
boolean |
isHmacEnabled() |
boolean |
isInvertLeaderElectionPrefixOrder() |
public static final long DEFAULT_TOPOLOGY_CONNECTOR_TIMEOUT
@Property(longValue=120L) public static final java.lang.String TOPOLOGY_CONNECTOR_TIMEOUT_KEY
protected long connectorPingTimeout
public static final long DEFAULT_TOPOLOGY_CONNECTOR_INTERVAL
@Property(longValue=30L) public static final java.lang.String TOPOLOGY_CONNECTOR_INTERVAL_KEY
protected long connectorPingInterval
public static final long DEFAULT_DISCOVERY_LITE_CHECK_INTERVAL
@Property(longValue=2L) public static final java.lang.String DISCOVERY_LITE_CHECK_INTERVAL_KEY
protected long discoveryLiteCheckInterval
public static final long DEFAULT_CLUSTER_SYNC_SERVICE_TIMEOUT
@Property(longValue=120L) public static final java.lang.String CLUSTER_SYNC_SERVICE_TIMEOUT_KEY
protected long clusterSyncServiceTimeout
public static final long DEFAULT_CLUSTER_SYNC_SERVICE_INTERVAL
@Property(longValue=2L) public static final java.lang.String CLUSTER_SYNC_SERVICE_INTERVAL_KEY
protected long clusterSyncServiceInterval
public static final int DEFAULT_MIN_EVENT_DELAY
@Property(intValue=3) public static final java.lang.String MIN_EVENT_DELAY_KEY
protected int minEventDelay
public static final int DEFAULT_SOCKET_CONNECT_TIMEOUT
@Property(intValue=10) public static final java.lang.String SOCKET_CONNECT_TIMEOUT_KEY
public static final int DEFAULT_SO_TIMEOUT
@Property(intValue=10) public static final java.lang.String SO_TIMEOUT_KEY
@Property(cardinality=1024) public static final java.lang.String TOPOLOGY_CONNECTOR_URLS_KEY
@Property(value={"localhost","127.0.0.1"})
public static final java.lang.String TOPOLOGY_CONNECTOR_WHITELIST_KEY
protected java.lang.String[] topologyConnectorWhitelist
@Property(value="/var/discovery/oak/",
propertyPrivate=true)
public static final java.lang.String DISCOVERY_RESOURCE_PATH_KEY
protected java.lang.String discoveryResourcePath
protected long leaderElectionPrefix
protected boolean invertLeaderElectionPrefixOrder
@Activate protected void activate(java.util.Map<java.lang.String,java.lang.Object> properties)
protected void configure(java.util.Map<java.lang.String,java.lang.Object> properties)
public int getSocketConnectTimeout()
getSocketConnectTimeout in interface BaseConfigpublic int getSoTimeout()
getSoTimeout in interface BaseConfigpublic int getMinEventDelay()
getMinEventDelay in interface BaseConfigpublic java.net.URL[] getTopologyConnectorURLs()
getTopologyConnectorURLs in interface BaseConfigpublic java.lang.String[] getTopologyConnectorWhitelist()
getTopologyConnectorWhitelist in interface BaseConfigprotected java.lang.String getDiscoveryResourcePath()
public java.lang.String getClusterInstancesPath()
getClusterInstancesPath in interface BaseConfigpublic java.lang.String getSyncTokenPath()
DiscoveryLiteConfiggetSyncTokenPath in interface DiscoveryLiteConfigpublic java.lang.String getIdMapPath()
DiscoveryLiteConfiggetIdMapPath in interface DiscoveryLiteConfigpublic boolean isHmacEnabled()
isHmacEnabled in interface BaseConfigpublic java.lang.String getSharedKey()
getSharedKey in interface BaseConfigpublic long getKeyInterval()
getKeyInterval in interface BaseConfigpublic boolean isEncryptionEnabled()
isEncryptionEnabled in interface BaseConfigpublic boolean isGzipConnectorRequestsEnabled()
isGzipConnectorRequestsEnabled in interface BaseConfigpublic boolean isAutoStopLocalLoopEnabled()
isAutoStopLocalLoopEnabled in interface BaseConfigpublic int getBackoffStandbyFactor()
getBackoffStandbyFactor in interface BaseConfigpublic int getBackoffStableFactor()
getBackoffStableFactor in interface BaseConfigpublic long getBackoffStandbyInterval()
getBackoffStandbyInterval in interface BaseConfigpublic long getConnectorPingInterval()
BaseConfiggetConnectorPingInterval in interface BaseConfigpublic long getConnectorPingTimeout()
BaseConfiggetConnectorPingTimeout in interface BaseConfigpublic long getDiscoveryLiteCheckInterval()
public long getClusterSyncServiceTimeoutMillis()
DiscoveryLiteConfiggetClusterSyncServiceTimeoutMillis in interface DiscoveryLiteConfigpublic long getClusterSyncServiceIntervalMillis()
DiscoveryLiteConfiggetClusterSyncServiceIntervalMillis in interface DiscoveryLiteConfigpublic boolean getSyncTokenEnabled()
public boolean isInvertLeaderElectionPrefixOrder()
public long getLeaderElectionPrefix()
Copyright © 2022 The Apache Software Foundation. All rights reserved.