@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 BaseConfig
public int getSoTimeout()
getSoTimeout
in interface BaseConfig
public int getMinEventDelay()
getMinEventDelay
in interface BaseConfig
public java.net.URL[] getTopologyConnectorURLs()
getTopologyConnectorURLs
in interface BaseConfig
public java.lang.String[] getTopologyConnectorWhitelist()
getTopologyConnectorWhitelist
in interface BaseConfig
protected java.lang.String getDiscoveryResourcePath()
public java.lang.String getClusterInstancesPath()
getClusterInstancesPath
in interface BaseConfig
public java.lang.String getSyncTokenPath()
DiscoveryLiteConfig
getSyncTokenPath
in interface DiscoveryLiteConfig
public java.lang.String getIdMapPath()
DiscoveryLiteConfig
getIdMapPath
in interface DiscoveryLiteConfig
public boolean isHmacEnabled()
isHmacEnabled
in interface BaseConfig
public java.lang.String getSharedKey()
getSharedKey
in interface BaseConfig
public long getKeyInterval()
getKeyInterval
in interface BaseConfig
public boolean isEncryptionEnabled()
isEncryptionEnabled
in interface BaseConfig
public boolean isGzipConnectorRequestsEnabled()
isGzipConnectorRequestsEnabled
in interface BaseConfig
public boolean isAutoStopLocalLoopEnabled()
isAutoStopLocalLoopEnabled
in interface BaseConfig
public int getBackoffStandbyFactor()
getBackoffStandbyFactor
in interface BaseConfig
public int getBackoffStableFactor()
getBackoffStableFactor
in interface BaseConfig
public long getBackoffStandbyInterval()
getBackoffStandbyInterval
in interface BaseConfig
public long getConnectorPingInterval()
BaseConfig
getConnectorPingInterval
in interface BaseConfig
public long getConnectorPingTimeout()
BaseConfig
getConnectorPingTimeout
in interface BaseConfig
public long getDiscoveryLiteCheckInterval()
public long getClusterSyncServiceTimeoutMillis()
DiscoveryLiteConfig
getClusterSyncServiceTimeoutMillis
in interface DiscoveryLiteConfig
public long getClusterSyncServiceIntervalMillis()
DiscoveryLiteConfig
getClusterSyncServiceIntervalMillis
in interface DiscoveryLiteConfig
public boolean getSyncTokenEnabled()
public boolean isInvertLeaderElectionPrefixOrder()
public long getLeaderElectionPrefix()
Copyright © 2022 The Apache Software Foundation. All rights reserved.