DiskStoreRealizer implements ConfigurationRealizer<DiskStore, DiskStoreInfo> { @Override public boolean exists(DiskStore config, InternalCache cache) { return cache.listDiskStores().stream() .anyMatch(diskStore -> diskStore.getName().equals(config.getName())); }  @Override RealizationResult create(DiskStore config, InternalCache cache); @Override boolean exists(DiskStore config, InternalCache cache); @Override DiskStoreInfo get(DiskStore config, InternalCache cache); @Override RealizationResult update(DiskStore config, InternalCache cache); @Override RealizationResult delete(DiskStore config, InternalCache cache); @Override boolean isReadyOnly();  }
@Test public void existsReturnsTrueIfADiskStoreMatchesName() { DiskStore config = new DiskStore(); String name = "diskStoreName"; Collection<org.apache.geode.cache.DiskStore> diskStores = new ArrayList(); org.apache.geode.cache.DiskStore existingDiskStore = mock(org.apache.geode.cache.DiskStore.class); when(existingDiskStore.getName()).thenReturn(name); diskStores.add(existingDiskStore); when(cache.listDiskStores()).thenReturn(diskStores); config.setName(name); assertThat(diskStoreRealizer.exists(config, cache)).isTrue(); }
@Test public void existsReturnsFalseIfADiskStoreMatchesName() { DiskStore config = new DiskStore(); String name = "diskStoreName"; Collection<org.apache.geode.cache.DiskStore> diskStores = new ArrayList(); org.apache.geode.cache.DiskStore existingDiskStore = mock(org.apache.geode.cache.DiskStore.class); when(existingDiskStore.getName()).thenReturn("notTheDiskStoreYouAreLookingFor"); diskStores.add(existingDiskStore); when(cache.listDiskStores()).thenReturn(diskStores); config.setName(name); assertThat(diskStoreRealizer.exists(config, cache)).isFalse(); }