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

x33g5p2x  于2022-01-20 转载在 其他  
字(7.5k)|赞(0)|评价(0)|浏览(84)

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

Group.getMembers介绍

[英]Return the entities that are members of this group.
[中]返回属于此组的实体。

代码示例

代码示例来源：origin: org.apache.brooklyn/brooklyn-software-webapp

@Override
public Iterable<UrlMapping> getUrlMappings() {
  // For mapping by URL
  Group urlMappingGroup = getConfig(NginxController.URL_MAPPINGS);
  if (urlMappingGroup != null) {
    return Iterables.filter(urlMappingGroup.getMembers(), UrlMapping.class);
  } else {
    return Collections.<UrlMapping>emptyList();
  }
}

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

protected void setEntityAfterSubscribingProducerMemberEvents() {
  if (producer instanceof Group) {
    for (Entity member : Iterables.filter(((Group)producer).getMembers(), entityFilter)) {
      addProducerMember(member);
    }
  }
}

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

@Override public void run() {
      Collection<Entity> members = group.getMembers();
      assertEquals(members.size(), expected, "members=" + members);
    }});
}

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

@Override
  public boolean apply(SensorEvent<T> input) {
    return parent.getMembers().contains(input.getSource());
  }
};

代码示例来源：origin: org.apache.brooklyn/brooklyn-software-webapp

protected boolean belongsInServerPool(Entity member) {
  if (!groovyTruth(member.getAttribute(Startable.SERVICE_UP))) {
    if (LOG.isTraceEnabled()) LOG.trace("Members of {}, checking {}, eliminating because not up", this, member);
    return false;
  }
  if (!getServerPool().getMembers().contains(member)) {
    if (LOG.isTraceEnabled()) LOG.trace("Members of {}, checking {}, eliminating because not member", this, member);
    return false;
  }
  if (LOG.isTraceEnabled()) LOG.trace("Members of {}, checking {}, approving", this, member);
  return true;
}

代码示例来源：origin: org.apache.brooklyn/brooklyn-software-webapp

protected boolean belongsInServerPool(Entity member) {
  if (!groovyTruth(member.getAttribute(Startable.SERVICE_UP))) {
    if (LOG.isTraceEnabled()) LOG.trace("Members of {}, checking {}, eliminating because not up", this, member);
    return false;
  }
  if (!getServerPool().getMembers().contains(member)) {
    if (LOG.isTraceEnabled()) LOG.trace("Members of {}, checking {}, eliminating because not member", this, member);
    return false;
  }
  if (LOG.isTraceEnabled()) LOG.trace("Members of {}, checking {}, approving", this, member);
  return true;
}

代码示例来源：origin: org.apache.brooklyn/brooklyn-software-base

private Entity getMember(String memberId) {
  Group cluster = (Group)entity();
  try {
    return Iterables.find(cluster.getMembers(), EntityPredicates.idEqualTo(memberId));
  } catch (NoSuchElementException e) {
    throw new IllegalStateException(memberId + " is not an ID of brooklyn node in this cluster");
  }
}

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

@Override
  public Boolean call() throws Exception {
    if (cluster.getMembers().isEmpty())
      return false;
    if (Lifecycle.RUNNING != cluster.sensors().get(SERVICE_STATE_ACTUAL))
      return false;
    for (Entity member : cluster.getMembers())
      if (!Boolean.TRUE.equals(member.sensors().get(SERVICE_UP)))
        return false;
    return true;
  }
}

代码示例来源：origin: io.brooklyn.clocker/brooklyn-clocker-mesos

@Override
public MesosSlave getMesosSlave(String hostname) {
  Collection<Entity> slaves = sensors().get(MESOS_SLAVES).getMembers();
  Optional<Entity> found = Iterables.tryFind(slaves, Predicates.or(
      EntityPredicates.attributeEqualTo(MesosSlave.HOSTNAME, hostname),
      EntityPredicates.attributeEqualTo(MesosSlave.ADDRESS, hostname)));
  if (found.isPresent()) {
    return (MesosSlave) found.get();
  } else {
    throw new IllegalStateException("Cannot find slave for host: " + hostname);
  }
}

代码示例来源：origin: io.brooklyn.clocker/brooklyn-clocker-docker

@Override
public void provisionNetwork(VirtualNetwork network) {
  SdnAgent agent = (SdnAgent) (getAgents().getMembers().iterator().next());
  String networkId = agent.provisionNetwork(network);
  LOG.info("Provisioned network {} at {}", networkId, agent);
  sensors().get(SDN_NETWORKS).addMember(network);
}

代码示例来源：origin: io.brooklyn.clocker/brooklyn-clocker-docker

@Override
public void deallocateNetwork(VirtualNetwork network) {
  String networkId = network.sensors().get(VirtualNetwork.NETWORK_ID);
  sensors().get(SDN_NETWORKS).removeMember(network);
  SdnAgent agent = (SdnAgent) (getAgents().getMembers().iterator().next());
  agent.deallocateNetwork(network);
  LOG.info("Deallocated network {} at {}", networkId, agent);
}

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

@Override
  public void run() {
    Group bucketA = (Group) find(dmg.getChildren(), displayNameEqualTo("bucketA"), null);
    assertNotNull(bucketA);
    assertEquals(ImmutableSet.copyOf(bucketA.getMembers()), ImmutableSet.of(child));
  }
});

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

@Override
  public void run() {
    Group bucketC = (Group) find(dmg.getChildren(), displayNameEqualTo("bucketC"), null);
    assertNotNull(bucketC);
    assertEquals(ImmutableSet.copyOf(bucketC.getMembers()), ImmutableSet.of(child3));
  }
});

代码示例来源：origin: io.brooklyn.clocker/brooklyn-clocker-mesos

@Override
public void stop() {
  super.stop();
  // Stop all of our managed Marathon tasks
  Iterable<Entity> tasks = Iterables.filter(getTaskCluster().getMembers(), EntityPredicates.attributeEqualTo(MesosTask.MANAGED, Boolean.TRUE));
  for (Entity task : tasks) {
    ((MarathonTask) task).stop();
  }
  deleteLocation();
}

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

@Override
  public void run() {
    Group bucketA = (Group) find(dmg.getChildren(), displayNameEqualTo("bucketA"), null);
    Group bucketB = (Group) find(dmg.getChildren(), displayNameEqualTo("bucketB"), null);
    assertNotNull(bucketA);
    assertNull(bucketB);
    assertEquals(ImmutableSet.copyOf(bucketA.getMembers()), ImmutableSet.of(child1, child2));
  }
});

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

@Override
  public void run() {
    Group bucketA = (Group) find(dmg.getChildren(), displayNameEqualTo("bucketA"), null);
    Group bucketB = (Group) find(dmg.getChildren(), displayNameEqualTo("bucketB"), null);
    assertNull(bucketA);
    assertNotNull(bucketB);
    assertEquals(ImmutableSet.copyOf(bucketB.getMembers()), ImmutableSet.of(child));
  }
});

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

@Override
  public void run() {
    Group bucketB = (Group) find(dmg.getChildren(), displayNameEqualTo("bucketB"), null);
    Group bucketC = (Group) find(dmg.getChildren(), displayNameEqualTo("bucketC"), null);
    assertNotNull(bucketB);
    assertNull(bucketC);
    assertEquals(ImmutableSet.copyOf(bucketB.getMembers()), ImmutableSet.of(child1, child2));
  }
});

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

@Override
  public void setEntity(EntityLocal entity) {
    super.setEntity(entity);
    assertTrue(entity instanceof TestApplication);
    assertEquals(entity.getChildren().size(), 2);
    assertEquals(((Group)Iterables.find(entity.getChildren(), Predicates.instanceOf(Group.class))).getMembers().size(), 1);
    success = true;
  }
}

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

@Override
  public void setEntity(EntityLocal entity) {
    super.setEntity(entity);
    assertTrue(entity instanceof TestApplication);
    assertEquals(entity.getChildren().size(), 2);
    assertEquals(((Group)Iterables.find(entity.getChildren(), Predicates.instanceOf(Group.class))).getMembers().size(), 1);
    success = true;
  }
}

代码示例来源：origin: io.brooklyn.clocker/brooklyn-clocker-mesos

@Override
public void deleteUnmanagedTasks() {
  for (Entity member : getTaskCluster().getMembers()) {
    if (member instanceof MesosTask && Boolean.FALSE.equals(member.config().get(MesosTask.MANAGED))) {
      // TODO Presumably `unmanage(member)` would be enough, but leaving like this
      // because that is what Andrew previously used!
      getTaskCluster().removeMember(member);
      getTaskCluster().removeChild(member);
      Entities.unmanage(member);
    }
  }
}

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

Group

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com