本文整理了Java中org.apache.geode.cache.RegionAttributes.getMembershipAttributes
方法的一些代码示例,展示了RegionAttributes.getMembershipAttributes
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RegionAttributes.getMembershipAttributes
方法的具体详情如下:
包路径:org.apache.geode.cache.RegionAttributes
类名称: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());
内容来源于网络,如有侵权,请联系作者删除!