ContainerPlacementMetadataStore { @VisibleForTesting MetadataStore getContainerPlacementStore() { return containerPlacementMessageStore; } ContainerPlacementMetadataStore(MetadataStore containerPlacementMessageStore); void start(); void stop(); boolean isRunning(); UUID writeContainerPlacementRequestMessage(String deploymentId, String processorId, String destinationHost,
      Duration requestExpiry, long timestamp); void writeContainerPlacementResponseMessage(ContainerPlacementResponseMessage message); Optional<ContainerPlacementRequestMessage> readContainerPlacementRequestMessage(UUID uuid); Optional<ContainerPlacementResponseMessage> readContainerPlacementResponseMessage(UUID uuid); void deleteContainerPlacementRequestMessage(UUID uuid); void deleteContainerPlacementResponseMessage(UUID uuid); void deleteAllContainerPlacementMessages(UUID uuid); void deleteAllContainerPlacementMessages(); static final String CONTAINER_PLACEMENT_STORE_NAMESPACE; }
@Test public void testDefaultMetadataStore() { Assert.assertNotNull(containerPlacementMetadataStore); Assert.assertEquals(NamespaceAwareCoordinatorStreamStore.class, containerPlacementMetadataStore.getContainerPlacementStore().getClass()); }