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

Group.sensors介绍

暂无

代码示例

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

public static Entity getFirst(Group g) {
  Collection<Entity> members = g.sensors().get(AbstractGroup.GROUP_MEMBERS);
  if (!members.isEmpty()) return members.iterator().next();
  return null;
}

代码示例来源：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-docker

@Override
public int compare(DockerHostLocation l1, DockerHostLocation l2) {
  Integer size1 = l1.getOwner().sensors().get(DockerHost.DOCKER_CONTAINER_CLUSTER).sensors().get(BasicGroup.GROUP_SIZE);
  if (size1 == null) size1 = 0;
  Integer size2 = l2.getOwner().sensors().get(DockerHost.DOCKER_CONTAINER_CLUSTER).sensors().get(BasicGroup.GROUP_SIZE);
  if (size2 == null) size2 = 0;
  return size1.compareTo(size2);
}

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

@Override
public boolean apply(DockerHostLocation input) {
  Integer maxSize = config().get(DOCKER_CONTAINER_CLUSTER_MAX_SIZE);
  DockerInfrastructure infrastructure = config().get(DOCKER_INFRASTRUCTURE);
  if (infrastructure != null) {
    Integer infrastructureMax = infrastructure.config().get(DOCKER_CONTAINER_CLUSTER_MAX_SIZE);
    if (infrastructureMax != null) maxSize = infrastructureMax;
  }
  if (maxSize == null) maxSize = DEFAULT_MAX_CONTAINERS;
  Integer currentSize = input.getOwner().sensors().get(DockerHost.DOCKER_CONTAINER_CLUSTER).sensors().get(BasicGroup.GROUP_SIZE);
  boolean accept = currentSize < maxSize;
  LOG.debug("Location {} size is {}/{}: {}", new Object[] { input, currentSize, maxSize, accept ? "accepted" : "rejected" });
  return accept;
}

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

@Override
public void postStart() {
  Entities.waitForServiceUp(this);
  sensors().get(DOCKER_CONTAINER_CLUSTER).sensors().set(SERVICE_UP, Boolean.TRUE);
  if (Boolean.TRUE.equals(sensors().get(DOCKER_INFRASTRUCTURE).config().get(SdnAttributes.SDN_ENABLE))) {
    LOG.info("Waiting on SDN agent");
    SdnAgent agent = Entities.attributeSupplierWhenReady(this, SdnAgent.SDN_AGENT).get();
    Entities.waitForServiceUp(agent);
    LOG.info("SDN agent running: " + agent.sensors().get(SERVICE_UP));
  }
  String imageId = config().get(DOCKER_IMAGE_ID);
  if (Strings.isBlank(imageId)) {
    String dockerfileUrl = config().get(DockerInfrastructure.DOCKERFILE_URL);
    String imageName = DockerUtils.imageName(this, dockerfileUrl);
    imageId = buildImage(dockerfileUrl, null, null, imageName, config().get(DockerHost.DOCKER_USE_SSH), ImmutableMap.<String, Object>of("fullyQualifiedImageName", imageName));
    sensors().set(DOCKER_IMAGE_NAME, imageName);
  }
  sensors().set(DOCKER_IMAGE_ID, imageId);
  scan = scanner();
  // If a registry URL is configured with credentials then log in
  String registryUrl = config().get(DockerInfrastructure.DOCKER_IMAGE_REGISTRY_URL);
  Boolean internalRegistry = config().get(DockerInfrastructure.DOCKER_SHOULD_START_REGISTRY);
  if (Strings.isNonBlank(registryUrl) && !internalRegistry) {
    String username = config().get(DockerInfrastructure.DOCKER_IMAGE_REGISTRY_USERNAME);
    String password = config().get(DockerInfrastructure.DOCKER_IMAGE_REGISTRY_PASSWORD);
    if (Strings.isNonBlank(username) && Strings.isNonBlank(password)) {
      runDockerCommand(String.format("login  -e \"fake@example.org\" -u %s -p %s %s", username, password, registryUrl));
    }
  }
}