org.infinispan.configuration.cache.Configuration.memory()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(9.5k)|赞(0)|评价(0)|浏览(127)

本文整理了Java中org.infinispan.configuration.cache.Configuration.memory()方法的一些代码示例，展示了Configuration.memory()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Configuration.memory()方法的具体详情如下：
包路径：org.infinispan.configuration.cache.Configuration
类名称：Configuration
方法名：memory

Configuration.memory介绍

暂无

代码示例

代码示例来源：origin: org.infinispan/infinispan-cdi-embedded

public void testSmallCache() {
   // Check that we have the correctly configured cache
   assertEquals(smallCache.getCacheConfiguration().memory().size(), 10);
  }
}

代码示例来源：origin: org.infinispan/infinispan-cdi-embedded

public void testDefaultConfiguration() {
 assertEquals(cache.getCacheConfiguration().memory().size(), 16);
 assertEquals(cache.getName(), DEFAULT_CACHE_NAME);
}

代码示例来源：origin: org.infinispan/infinispan-cdi-embedded

public void testSmallCache() {
 assertEquals(smallCache.getCacheConfiguration().memory().size(), 7);
 assertEquals(observers.getCacheStartedEventCount(), 1);
}

代码示例来源：origin: org.infinispan/infinispan-core

private CacheNotifierImpl newNotifier() {
 CacheNotifierImpl notifier = new CacheNotifierImpl();
 AdvancedCache mockCache = mock(AdvancedCache.class, RETURNS_DEEP_STUBS);
 ComponentRegistry registry = mock(ComponentRegistry.class);
 Configuration config = mock(Configuration.class, RETURNS_DEEP_STUBS);
 when(config.clustering().cacheMode()).thenReturn(CacheMode.LOCAL);
 when(config.memory().storageType()).thenReturn(StorageType.OBJECT);
 TestingUtil.inject(notifier, mockCache, new ClusteringDependentLogic.LocalLogic(), config,
           new InternalEntryFactoryImpl(), mock(ClusterEventManager.class),
           mock(BasicComponentRegistry.class));
 return notifier;
}

代码示例来源：origin: org.infinispan/infinispan-cdi-embedded

public void testSpecificCacheManager() throws Exception {
   assertEquals(largeCache.getCacheConfiguration().memory().size(), 2000);
   assertEquals(largeCache.getCacheManager().getDefaultCacheConfiguration().memory().size(), 4000);

   assertEquals(smallCache.getCacheConfiguration().memory().size(), 20);
   assertEquals(smallCache.getCacheManager().getDefaultCacheConfiguration().memory().size(), 4000);

   // asserts that the small and large cache are defined in the same cache manager
   assertTrue(smallCache.getCacheManager().equals(largeCache.getCacheManager()));
   assertFalse(smallCache.getCacheManager().equals(cache.getCacheManager()));

   // check that the default configuration has not been modified
   assertEquals(cache.getCacheConfiguration().memory().size(), -1);
  }
}

代码示例来源：origin: org.infinispan/infinispan-core

@Test
public void testEvictionSize() {
 Configuration configuration = new ConfigurationBuilder()
   .memory().size(20)
   .build();
 Assert.assertEquals(configuration.memory().size(), 20);
}

代码示例来源：origin: org.infinispan.server/infinispan-server-infinispan

@Override
  public void registerAttributes(ManagementResourceRegistration resourceRegistration) {
    final OperationStepHandler restartCacheWriteHandler = new RestartServiceWriteAttributeHandler(
       resource.getPathElement().getKey(), resource.getServiceInstaller(), CacheServiceName.CONFIGURATION, attributes);

    resourceRegistration.registerReadWriteAttribute(STRATEGY, CacheReadAttributeHandler.INSTANCE, restartCacheWriteHandler);
    resourceRegistration.registerReadWriteAttribute(SIZE, CacheReadAttributeHandler.INSTANCE,
       new RuntimeCacheConfigurationWriteAttributeHandler(SIZE, (configuration, newSize) -> configuration.memory().size(newSize.asLong())));
  }
}

代码示例来源：origin: org.infinispan/infinispan-embedded-query

private static void validateMetadataCache(Cache<?, ?> cache, String indexName) {
 Configuration configuration = cache.getCacheConfiguration();
 if (configuration.memory().isEvictionEnabled()) {
   throw log.evictionNotAllowedInMetadataCache(indexName, cache.getName());
 }
 if (configuration.persistence().usingStores() && !configuration.persistence().preload()) {
   throw log.preloadNeededIfPersistenceIsEnabledForMetadataCache(indexName, cache.getName());
 }
}

代码示例来源：origin: org.infinispan/infinispan-lucene-directory

private static void validateMetadataCache(Cache<?, ?> cache, String indexName) {
 Configuration configuration = cache.getCacheConfiguration();
 if (configuration.memory().isEvictionEnabled()) {
   throw log.evictionNotAllowedInMetadataCache(indexName, cache.getName());
 }
 if (configuration.persistence().usingStores() && !configuration.persistence().preload()) {
   throw log.preloadNeededIfPersistenceIsEnabledForMetadataCache(indexName, cache.getName());
 }
}

代码示例来源：origin: org.infinispan/infinispan-core

@Override
  public void call() {
   Configuration cfg = cm.getDefaultCacheConfiguration();
   assertTrue(cfg.dataContainer().<byte[]>keyEquivalence() instanceof AnyEquivalence);
   assertTrue(cfg.dataContainer().valueEquivalence() instanceof AnyEquivalence);
   assertEquals(StorageType.OFF_HEAP, cfg.memory().storageType());
   assertEquals(EvictionStrategy.MANUAL, cfg.memory().evictionStrategy());
  }
});

代码示例来源：origin: org.infinispan/infinispan-core

public void testDefiningConfigurationOverridingBooleans() {
 EmbeddedCacheManager cm = createCacheManager(false);
 ConfigurationBuilder c = new ConfigurationBuilder();
 c.memory().storageType(StorageType.BINARY);
 Configuration lazy = cm.defineConfiguration("storeAsBinary", c.build());
 assertEquals(StorageType.BINARY, lazy.memory().storageType());
 c = new ConfigurationBuilder().read(lazy);
 c.memory().storageType(StorageType.OFF_HEAP).size(1);
 Configuration lazyOffHeap = cm.defineConfiguration("lazyDeserializationWithOffHeap", c.build());
 assertEquals(StorageType.OFF_HEAP, lazyOffHeap.memory().storageType());
 assertEquals(1, lazyOffHeap.memory().size());
}

代码示例来源：origin: org.infinispan/infinispan-core

public void testEvictionSize() throws Exception {
   ObjectName defaultOn = getCacheObjectName(JMX_DOMAIN, "___defaultcache(local)", "Configuration");
   assertEquals(1000L, (long) server.getAttribute(defaultOn, "evictionSize"));
   assertEquals(1000, cache().getCacheConfiguration().memory().size());
   DefaultDataContainer<Object, Object> dataContainer = (DefaultDataContainer<Object, Object>) cache()
      .getAdvancedCache().getDataContainer();
   assertEquals(1000, dataContainer.capacity());
   server.setAttribute(defaultOn, new Attribute("evictionSize", 2000L));
   assertEquals(2000, cache().getCacheConfiguration().memory().size());
   assertEquals(2000, dataContainer.capacity());
  }
}

代码示例来源：origin: org.infinispan/infinispan-cdi-embedded

public void testQuickCache() {
   assertEquals(quickCache.getCacheConfiguration().memory().size(), 1000);
   assertEquals(quickCache.getCacheConfiguration().expiration().wakeUpInterval(), 1);
  }
}

代码示例来源：origin: org.infinispan/infinispan-core

public void testBackwardCompatibility() {
 ConfigurationBuilder c = new ConfigurationBuilder();
 c.memory().storageType(StorageType.BINARY);
 ecm = TestCacheManagerFactory.createCacheManager(c);
 assertEquals(StorageType.BINARY, ecm.getCache().getCacheConfiguration().memory().storageType());
}

代码示例来源：origin: org.infinispan/infinispan-core

public void testConfigurationOverride() throws Exception {
 ConfigurationBuilder defaultCfgBuilder = new ConfigurationBuilder();
 defaultCfgBuilder.memory().size(200).storageType(StorageType.BINARY);
 cm = TestCacheManagerFactory.createCacheManager(defaultCfgBuilder);
 final ConfigurationBuilder cacheCfgBuilder =
    new ConfigurationBuilder().read(defaultCfgBuilder.build());
 cm.defineConfiguration("my-cache", cacheCfgBuilder.build());
 Cache<?, ?> cache = cm.getCache("my-cache");
 assertEquals(200, cache.getCacheConfiguration().memory().size());
 assertEquals(StorageType.BINARY, cache.getCacheConfiguration().memory().storageType());
}

代码示例来源：origin: org.infinispan/infinispan-core

@Override
  public void call() {
   Configuration cfg = cm.getDefaultCacheConfiguration();
   assertTrue(cfg.dataContainer().<byte[]>keyEquivalence() instanceof AnyEquivalence);
   assertTrue(cfg.dataContainer().<byte[]>valueEquivalence() instanceof AnyEquivalence);
   assertEquals(StorageType.BINARY, cfg.memory().storageType());
  }
});

代码示例来源：origin: org.infinispan/infinispan-core

@Override
  public void call() {
   Configuration cfg = cm.getDefaultCacheConfiguration();
   assertTrue(cfg.dataContainer().<byte[]>keyEquivalence() instanceof AnyEquivalence);
   assertTrue(cfg.dataContainer().<byte[]>valueEquivalence() instanceof AnyEquivalence);
   assertEquals(StorageType.OBJECT, cfg.memory().storageType());
  }
});

代码示例来源：origin: org.infinispan/infinispan-core

public void testConfigCloning() {
 ConfigurationBuilder c = new ConfigurationBuilder();
 c.memory().storageType(StorageType.BINARY);
 ConfigurationBuilder builder = new ConfigurationBuilder().read(c.build());
 Configuration clone = builder.build();
 assertEquals(StorageType.BINARY, clone.memory().storageType());
}

代码示例来源：origin: org.infinispan/infinispan-core

public void testConfigOverriding() {
 ConfigurationBuilder c = new ConfigurationBuilder();
 c.memory().storageType(StorageType.BINARY);
 ecm = TestCacheManagerFactory.createCacheManager(c);
 ecm.defineConfiguration("newCache", new ConfigurationBuilder().read(c.build()).memory().storageType(StorageType.OBJECT).build());
 assertEquals(StorageType.OBJECT, ecm.getCache("newCache").getCacheConfiguration().memory().storageType());
}

代码示例来源：origin: org.infinispan/infinispan-core

@Override
  public void check(ConfigurationBuilderHolder holder) {
   GlobalStateConfiguration gs = getGlobalConfiguration(holder).globalState();
   assertEquals(ConfigurationStorage.OVERLAY, gs.configurationStorage());
   assertEquals("sharedPath", gs.sharedPersistentLocation());
   EncodingConfiguration encoding = getConfiguration(holder, "local").encoding();
   assertEquals(MediaType.APPLICATION_OBJECT, encoding.keyDataType().mediaType());
   assertEquals(MediaType.APPLICATION_OBJECT, encoding.valueDataType().mediaType());
   MemoryConfiguration memory = getConfiguration(holder, "dist-template").memory();
   assertEquals(EvictionStrategy.REMOVE, memory.evictionStrategy());
  }
},

内容来源于网络，如有侵权，请联系作者删除！

Configuration

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com