org.apache.geode.cache.RegionAttributes.getMembershipAttributes()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(5.3k)|赞(0)|评价(0)|浏览(69)

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

RegionAttributes.getMembershipAttributes介绍

[英]Returns the MembershipAttributes that configure required roles for reliable access to the region.
[中]返回MembershipAttributes,用于配置可靠访问该区域所需的角色。

代码示例

代码示例来源:origin: apache/geode

@Override
public MembershipAttributes getMembershipAttributes() {
 return this.ra.getMembershipAttributes();
}

代码示例来源:origin: apache/geode

public static MembershipAttributesData getMembershipAttributesData(RegionAttributes regAttrs) {
 MembershipAttributes memAttrs = regAttrs.getMembershipAttributes();
 Set<String> requiredRoles = new HashSet<String>();
 Iterator<Role> it = memAttrs.getRequiredRoles().iterator();
 while (it.hasNext()) {
  requiredRoles.add(it.next().getName());
 }
 String lossAction = memAttrs.getLossAction().toString();
 String resumptionAction = memAttrs.getResumptionAction().toString();
 MembershipAttributesData membershipAttributesData =
   new MembershipAttributesData(requiredRoles, lossAction, resumptionAction);
 return membershipAttributesData;
}

代码示例来源:origin: apache/geode

private PartitionAttributes initializeAttributes(final Cache cache) {
 PartitionAttributes partitionAttributes = mock(PartitionAttributes.class);
 RegionAttributes attributes = mock(RegionAttributes.class);
 when(attributes.getCacheListeners()).thenReturn(new CacheListener[0]);
 when(attributes.getRegionTimeToLive()).thenReturn(ExpirationAttributes.DEFAULT);
 when(attributes.getRegionIdleTimeout()).thenReturn(ExpirationAttributes.DEFAULT);
 when(attributes.getEntryTimeToLive()).thenReturn(ExpirationAttributes.DEFAULT);
 when(attributes.getEntryIdleTimeout()).thenReturn(ExpirationAttributes.DEFAULT);
 when(attributes.getMembershipAttributes()).thenReturn(new MembershipAttributes());
 when(cache.getRegionAttributes(RegionShortcut.PARTITION.toString())).thenReturn(attributes);
 when(partitionAttributes.getTotalNumBuckets()).thenReturn(113);
 return partitionAttributes;
}

代码示例来源:origin: apache/geode

when(regionAttributes.getConcurrencyLevel()).thenReturn(16);
when(regionAttributes.getLoadFactor()).thenReturn(0.75f);
when(regionAttributes.getMembershipAttributes()).thenReturn(membershipAttributes);
when(regionAttributes.getScope()).thenReturn(scope);
when(partitionedRegion.getFullPath()).thenReturn("parent");

代码示例来源:origin: apache/geode

this, other.getPartitionAttributes()));
if (!equal(this.membershipAttributes, other.getMembershipAttributes())) {
 throw new RuntimeException(
   "Membership Attributes are not the same");

代码示例来源:origin: apache/geode

boolean setRequiresReliabilityCheck = attrs.getMembershipAttributes().hasRequiredRoles() &&
  !attrs.getMembershipAttributes().getLossAction().isAllAccess()
  && !attrs.getMembershipAttributes().getLossAction().isReconnect();
Set reqRoles = new HashSet(attrs.getMembershipAttributes().getRequiredRoles());
reqRoles.removeAll(getSystem().getDistributedMember().getRoles());
if (reqRoles.isEmpty()) {

代码示例来源:origin: apache/geode

MembershipAttributes p = attrs.getMembershipAttributes();
if (p != null && p.hasRequiredRoles()) {
 generate(p);

代码示例来源:origin: apache/geode

if (attrs.getMembershipAttributes().hasRequiredRoles()) {
 if (attrs.getScope().isLocal()) {
  throw new IllegalStateException(

代码示例来源:origin: apache/geode

this.indexMaintenanceSynchronous = attrs.getIndexMaintenanceSynchronous();
this.partitionAttributes = attrs.getPartitionAttributes();
this.membershipAttributes = attrs.getMembershipAttributes();
this.subscriptionAttributes = attrs.getSubscriptionAttributes();
this.dataPolicy = attrs.getDataPolicy();

代码示例来源:origin: apache/geode

this.mcastEnabled = attrs.getMulticastEnabled();
this.partitionAttributes = attrs.getPartitionAttributes();
this.membershipAttributes = attrs.getMembershipAttributes();
this.subscriptionAttributes = attrs.getSubscriptionAttributes();
this.cloningEnable = attrs.getCloningEnabled();

代码示例来源:origin: apache/geode

(EvictionAttributesImpl) regionAttributes.getEvictionAttributes();
this.regionAttributes.membershipAttributes = regionAttributes.getMembershipAttributes();
this.regionAttributes.subscriptionAttributes = regionAttributes.getSubscriptionAttributes();
this.regionAttributes.evictionAttributes =

代码示例来源:origin: apache/geode

this.membershipAttributes = attr.getMembershipAttributes();
this.subscriptionAttributes = attr.getSubscriptionAttributes();
this.cloningEnable = attr.getCloningEnabled();

代码示例来源:origin: org.springframework.data/spring-data-geode

regionFactory.setLoadFactor(regionAttributes.getLoadFactor());
regionFactory.setLockGrantor(regionAttributes.isLockGrantor());
regionFactory.setMembershipAttributes(regionAttributes.getMembershipAttributes());
regionFactory.setMulticastEnabled(regionAttributes.getMulticastEnabled());
regionFactory.setOffHeap(regionAttributes.getOffHeap());

代码示例来源:origin: org.springframework.data/spring-data-gemfire

regionFactory.setLoadFactor(regionAttributes.getLoadFactor());
regionFactory.setLockGrantor(regionAttributes.isLockGrantor());
regionFactory.setMembershipAttributes(regionAttributes.getMembershipAttributes());
regionFactory.setMulticastEnabled(regionAttributes.getMulticastEnabled());
regionFactory.setOffHeap(regionAttributes.getOffHeap());

相关文章

微信公众号

最新文章

更多

RegionAttributes类方法