本文整理了Java中org.apache.brooklyn.api.entity.Entity.getId()
方法的一些代码示例,展示了Entity.getId()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Entity.getId()
方法的具体详情如下:
包路径:org.apache.brooklyn.api.entity.Entity
类名称:Entity
方法名:getId
[英]The unique identifier for this entity.
[中]此实体的唯一标识符。
代码示例来源:origin: org.apache.brooklyn/brooklyn-core
/**
* Whether the entity is in the process of being managed.
*/
private synchronized boolean isPreManaged(Entity e) {
return preManagedEntitiesById.containsKey(e.getId());
}
代码示例来源:origin: org.apache.brooklyn/brooklyn-core
@Override
public boolean apply(@Nullable Entity input) {
return (input != null) && condition.apply(input.getId());
}
@Override
代码示例来源:origin: org.apache.brooklyn/brooklyn-core
@Override
public boolean apply(@Nullable Entity input) {
return (input != null) && Objects.equal(input.getId(), val);
}
};
代码示例来源:origin: org.apache.brooklyn/brooklyn-core
@Override
public String apply(Entity input) {
if (input==null) return null;
Entity entity = input;
String url = String.format("#/v1/applications/%s/entities/%s", entity.getApplicationId(), entity.getId());
return url;
}
};
代码示例来源:origin: org.apache.brooklyn/brooklyn-core
void prePreManage(Entity entity) {
if (isPreRegistered(entity)) {
log.warn(""+this+" redundant call to pre-pre-manage entity "+entity+"; skipping",
new Exception("source of duplicate pre-pre-manage of "+entity));
return;
}
preRegisteredEntitiesById.put(entity.getId(), entity);
}
代码示例来源:origin: org.apache.brooklyn/brooklyn-core
private Entity toRealEntity(Entity e) {
checkNotNull(e, "entity");
if (e instanceof AbstractEntity) {
return e;
} else {
Entity result = toRealEntityOrNull(e.getId());
if (result == null) {
throw new IllegalStateException("No concrete entity known for entity "+e+" ("+e.getId()+", "+e.getEntityType().getName()+")");
}
return result;
}
}
代码示例来源:origin: org.apache.brooklyn/brooklyn-core
@Override
public boolean apply(@Nullable Entity input) {
return (input != null) && Objects.equal(input.getId(), val);
}
}
代码示例来源:origin: org.apache.brooklyn/brooklyn-rest-resources
/** walks the hierarchy (depth-first) at root (often an Application) looking for
* an entity matching the given ID or name; returns the first such entity, or null if none found
**/
public Entity searchForEntityNamed(Entity root, String entity) {
if (root.getId().equals(entity) || entity.equals(root.getDisplayName())) return root;
for (Entity child: root.getChildren()) {
Entity result = searchForEntityNamed(child, entity);
if (result!=null) return result;
}
return null;
}
代码示例来源:origin: io.brooklyn.clocker/brooklyn-clocker-docker
public static String getContainerName(Entity target) {
String unique = getUniqueContainerName(target);
String suffix = "_" + target.getId();
return Strings.removeFromEnd(unique, suffix);
}
代码示例来源:origin: org.apache.brooklyn/brooklyn-software-base
private String getServiceName() {
String serviceNameTemplate = enricher.config().get(SystemServiceEnricher.SERVICE_NAME);
return serviceNameTemplate
.replace("${id}", entity.getId())
.replace("${entity_name}", getEntityName());
}
代码示例来源:origin: org.apache.brooklyn/brooklyn-core
@Override
public boolean apply(@Nullable Entity input) {
return (input != null) && Objects.equal(input.getId(), paramVal);
}
};
代码示例来源:origin: org.apache.brooklyn/brooklyn-core
EffectorCallPropagatedRuntimeException(Entity entity, Effector<?> effector, Throwable throwable) {
super(makeMessage(entity, effector), throwable);
this.entityId = entity.getId();
this.effectorName = effector.getName();
}
@Override
代码示例来源:origin: org.apache.brooklyn/brooklyn-rest-resources
private List<Map<String, String>> entitiesIdAndNameAsList(Collection<? extends Entity> entities) {
List<Map<String, String>> members = Lists.newArrayList();
for (Entity entity : entities) {
if (Entitlements.isEntitled(mgmt().getEntitlementManager(), Entitlements.SEE_ENTITY, entity)) {
members.add(ImmutableMap.of("id", entity.getId(), "name", entity.getDisplayName()));
}
}
return members;
}
代码示例来源:origin: org.apache.brooklyn/brooklyn-software-base
private void demoteOldMaster(Entity oldMaster, HighAvailabilityMode mode) {
ManagementNodeState oldState = DynamicTasks.queue(
Effectors.invocation(
oldMaster,
BrooklynNode.SET_HIGH_AVAILABILITY_MODE,
MutableMap.of(SetHighAvailabilityModeEffector.MODE, mode))
).asTask().getUnchecked();
if (oldState != ManagementNodeState.MASTER) {
LOG.warn("The previous HA state on node " + oldMaster.getId() + " was " + oldState +
", while the expected value is " + ManagementNodeState.MASTER + ".");
}
}
代码示例来源:origin: org.apache.brooklyn/brooklyn-core
private Map<String, EntityMemento> toMementos(Iterable<? extends Entity> entities) {
Map<String, EntityMemento> result = Maps.newLinkedHashMap();
for (Entity entity : entities) {
result.put(entity.getId(), (EntityMemento) MementosGenerators.newBasicMemento(Entities.deproxy(entity)));
}
return result;
}
}
代码示例来源:origin: org.apache.brooklyn/brooklyn-core
@Test
public void testCheckPointAndLoadMemento() throws Exception {
BrooklynMemento reloadedMemento = loadMemento();
assertNotNull(reloadedMemento);
assertTrue(Iterables.contains(reloadedMemento.getEntityIds(), entity.getId()));
assertEquals(Iterables.getOnlyElement(reloadedMemento.getLocationIds()), location.getId());
assertEquals(Iterables.getOnlyElement(reloadedMemento.getPolicyIds()), policy.getId());
assertTrue(reloadedMemento.getEnricherIds().contains(enricher.getId()));
}
代码示例来源:origin: org.apache.brooklyn/brooklyn-software-nosql
@Override
public void run() {
assertEquals(replicaSet.getCurrentSize().intValue(), 2);
for (Entity member : replicaSet.getMembers()) {
assertNotEquals(member.getId(), removed.getId());
}
assertNotNull(replicaSet.getPrimary());
assertNotEquals(replicaSet.getPrimary().getId(), removed.getId(), "Expected a new primary to have been elected");
}
});
代码示例来源:origin: org.apache.brooklyn/brooklyn-camp
@Test
public void testDeferredDslChainingDslComponent() throws Exception {
final Entity app = createAndStartApplication(
"services:",
"- type: " + BasicApplication.class.getName(),
" brooklyn.config:",
" dest: $brooklyn:config(\"targetValue\").self().attributeWhenReady(\"entity.id\")");
app.config().set(ConfigKeys.newConfigKey(TestDslSupplierValue.class, "targetValue"), new TestDslSupplierValue());
assertEquals(getConfigEventually(app, DEST), app.getId());
}
代码示例来源:origin: org.apache.brooklyn/brooklyn-camp
@Test
public void testDslSensorSupplier() throws Exception {
final Entity app = createAndStartApplication(
"services:",
"- type: " + BasicApplication.class.getName(),
" brooklyn.config:",
" " + sensorSupplier1.getName() + ": $brooklyn:sensor(\"mySensorName\")");
rebind();
Entity newEntity = mgmt().getEntityManager().getEntity(app.getId());
Sensor<?> sensor = newEntity.config().get(sensorSupplier1);
assertEquals(sensor.getName(), "mySensorName");
}
代码示例来源:origin: org.apache.brooklyn/brooklyn-launcher
@Test
public void testDeletesOrphanedEnricher() throws Exception {
Entity entity = origApp.addChild(EntitySpec.create(TestEntity.class).impl(MyEntity.class));
MyEnricher enricher = entity.enrichers().add(EnricherSpec.create(MyEnricher.class));
MementoTweaker tweaker = new MementoTweaker(new Deletions().entities(entity.getId()));
assertTransformDeletes(new Deletions().enrichers(enricher.getId()), tweaker);
}
内容来源于网络,如有侵权,请联系作者删除!