Package akka.cluster
Class JoinConfigCompatChecker$
- java.lang.Object
-
- akka.cluster.JoinConfigCompatChecker$
-
public class JoinConfigCompatChecker$ extends java.lang.Object
Checks that allrequiredKeys
are available intoCheck
Config.param: requiredKeys - a Seq of required keys param: toCheck - the Config instance to be checked
-
-
Field Summary
Fields Modifier and Type Field Description static JoinConfigCompatChecker$
MODULE$
Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description JoinConfigCompatChecker$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ConfigValidation
exists(scala.collection.immutable.Seq<java.lang.String> requiredKeys, com.typesafe.config.Config toCheck)
com.typesafe.config.Config
filterWithKeys(scala.collection.immutable.Seq<java.lang.String> requiredKeys, com.typesafe.config.Config config)
INTERNAL API Builds a new Config object containing only the required entries defined byrequiredKeys
ConfigValidation
fullMatch(scala.collection.immutable.Seq<java.lang.String> requiredKeys, com.typesafe.config.Config toCheck, com.typesafe.config.Config actualConfig)
Checks that allrequiredKeys
are available intoCheck
Config and its values match exactly the values incurrentConfig
.JoinConfigCompatChecker
load(ExtendedActorSystem system, ClusterSettings clusterSettings)
INTERNAL APIscala.collection.immutable.Seq<java.lang.String>
removeSensitiveKeys(com.typesafe.config.Config config, ClusterSettings clusterSettings)
INTERNAL API Builds a Seq of keys using the passedConfig
not including any sensitive keys, as defined in 'akka.cluster.configuration-compatibility-check.sensitive-config-paths'.scala.collection.immutable.Seq<java.lang.String>
removeSensitiveKeys(scala.collection.immutable.Seq<java.lang.String> requiredKeys, ClusterSettings clusterSettings)
INTERNAL API Removes sensitive keys, as defined in 'akka.cluster.configuration-compatibility-check.sensitive-config-paths', from the passedrequiredKeys
Seq.
-
-
-
Field Detail
-
MODULE$
public static final JoinConfigCompatChecker$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
exists
public ConfigValidation exists(scala.collection.immutable.Seq<java.lang.String> requiredKeys, com.typesafe.config.Config toCheck)
-
fullMatch
public ConfigValidation fullMatch(scala.collection.immutable.Seq<java.lang.String> requiredKeys, com.typesafe.config.Config toCheck, com.typesafe.config.Config actualConfig)
Checks that allrequiredKeys
are available intoCheck
Config and its values match exactly the values incurrentConfig
.- Parameters:
requiredKeys
- - a Seq of required keystoCheck
- - the Config instance to be checkedactualConfig
- - the Config instance containing the expected values- Returns:
- (undocumented)
-
filterWithKeys
public com.typesafe.config.Config filterWithKeys(scala.collection.immutable.Seq<java.lang.String> requiredKeys, com.typesafe.config.Config config)
INTERNAL API Builds a new Config object containing only the required entries defined byrequiredKeys
This method is used from the joining side to prepare the
Config
instance that will be sent over the wire. We don't send the full config to avoid unnecessary data transfer, but also to avoid leaking any sensitive information that users may have added to their configuration.- Parameters:
requiredKeys
- (undocumented)config
- (undocumented)- Returns:
- (undocumented)
-
removeSensitiveKeys
public scala.collection.immutable.Seq<java.lang.String> removeSensitiveKeys(scala.collection.immutable.Seq<java.lang.String> requiredKeys, ClusterSettings clusterSettings)
INTERNAL API Removes sensitive keys, as defined in 'akka.cluster.configuration-compatibility-check.sensitive-config-paths', from the passedrequiredKeys
Seq.- Parameters:
requiredKeys
- (undocumented)clusterSettings
- (undocumented)- Returns:
- (undocumented)
-
removeSensitiveKeys
public scala.collection.immutable.Seq<java.lang.String> removeSensitiveKeys(com.typesafe.config.Config config, ClusterSettings clusterSettings)
INTERNAL API Builds a Seq of keys using the passedConfig
not including any sensitive keys, as defined in 'akka.cluster.configuration-compatibility-check.sensitive-config-paths'.- Parameters:
config
- (undocumented)clusterSettings
- (undocumented)- Returns:
- (undocumented)
-
load
public JoinConfigCompatChecker load(ExtendedActorSystem system, ClusterSettings clusterSettings)
INTERNAL APIThis method loads the
JoinConfigCompatChecker
defined in the configuration. Checkers are then combined to be used whenever a join node tries to join an existing cluster.- Parameters:
system
- (undocumented)clusterSettings
- (undocumented)- Returns:
- (undocumented)
-
-