-public class DistributedDataStore implements DOMStore, SchemaContextListener,
- DatastoreContextConfigAdminOverlay.Listener, AutoCloseable {
-
- private static final Logger LOG = LoggerFactory.getLogger(DistributedDataStore.class);
- public static final int REGISTER_DATA_CHANGE_LISTENER_TIMEOUT_FACTOR = 24; // 24 times the usual operation timeout
-
- private final ActorContext actorContext;
-
- private AutoCloseable closeable;
-
- private DatastoreConfigurationMXBeanImpl datastoreConfigMXBean;
-
- public DistributedDataStore(ActorSystem actorSystem, ClusterWrapper cluster,
- Configuration configuration, DatastoreContext datastoreContext) {
- Preconditions.checkNotNull(actorSystem, "actorSystem should not be null");
- Preconditions.checkNotNull(cluster, "cluster should not be null");
- Preconditions.checkNotNull(configuration, "configuration should not be null");
- Preconditions.checkNotNull(datastoreContext, "datastoreContext should not be null");
-
- String type = datastoreContext.getDataStoreType();
-
- String shardManagerId = ShardManagerIdentifier.builder().type(type).build().toString();