org.apache.brooklyn.api.entity.Entity.getId()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(7.2k)|赞(0)|评价(0)|浏览(125)

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

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);
}

相关文章