+ private final Map<String, List<String>> shardNameToMembers =
+ new HashMap<>();
+
+ private final LoggingAdapter log =
+ Logging.getLogger(getContext().system(), this);
+
+
+ private final Map<String, ActorPath> localShards = new HashMap<>();
+
+
+ private final ClusterWrapper cluster;
+
+ /**
+ * @param type defines the kind of data that goes into shards created by this shard manager. Examples of type would be
+ * configuration or operational
+ */
+ private ShardManager(String type, ClusterWrapper cluster, Configuration configuration) {
+ this.cluster = cluster;
+ String memberName = cluster.getCurrentMemberName();
+ List<String> memberShardNames =
+ configuration.getMemberShardNames(memberName);