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

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

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

Group.removeMember介绍

[英]Removes the given member, returning true if this modifies the set of members (i.e. it was a member).
[中]删除给定成员,如果此操作修改了成员集(即它是一个成员),则返回true。

代码示例

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

@Override
public void removeHost(DockerHost host) {
  SdnAgent agent = host.sensors().get(SdnAgent.SDN_AGENT);
  if (agent == null) {
    LOG.warn("{} cannot find calico service: {}", this, host);
    return;
  }
  agent.stop();
  getAgents().removeMember(agent);
  Entities.unmanage(agent);
  if (LOG.isDebugEnabled()) LOG.debug("{} removed calico plugin {}", this, agent);
}

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

@Override
public void removeHost(DockerHost host) {
  SdnAgent agent = host.sensors().get(SdnAgent.SDN_AGENT);
  if (agent == null) {
    LOG.warn("{} cannot find overlay service: {}", this, host);
    return;
  }
  agent.stop();
  getAgents().removeMember(agent);
  Entities.unmanage(agent);
  if (LOG.isDebugEnabled()) LOG.debug("{} removed overlay plugin {}", this, agent);
}

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

@Override
public void removeHost(DockerHost host) {
  SdnAgent agent = host.sensors().get(SdnAgent.SDN_AGENT);
  if (agent == null) {
    LOG.warn("{} cannot find Weave service: {}", this, host);
    return;
  }
  agent.stop();
  getAgents().removeMember(agent);
  Entities.unmanage(agent);
  LOG.debug("{} removed Weave service {}", this, agent);
}

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

@Override
public void release(DockerContainerLocation machine) {
  lock.readLock().lock();
  try {
    LOG.info("Releasing {}", machine);
    Group cluster = dockerHost.getDockerContainerCluster();
    DockerContainer container = machine.getOwner();
    if (cluster.removeMember(container)) {
      LOG.info("Docker Host {}: member {} released", dockerHost, machine);
    } else {
      LOG.warn("Docker Host {}: member {} not found for release", dockerHost, machine);
    }
    // Now close and unmange the container
    try {
      container.stop();
      machine.close();
    } catch (Exception e) {
      LOG.warn("Error stopping container: " + container, e);
      Exceptions.propagateIfFatal(e);
    } finally {
      Entities.unmanage(container);
    }
  } finally {
    lock.readLock().unlock();
  }
}

代码示例来源: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: io.brooklyn.clocker/brooklyn-clocker-mesos

@Override
public void release(MarathonTaskLocation location) {
  lock.readLock().lock();
  try {
    LOG.info("Releasing {}", location);
    Group cluster = framework.sensors().get(MesosFramework.FRAMEWORK_TASKS);
    MarathonTask task = location.getOwner();
    if (cluster.removeMember(task)) {
      LOG.info("Marathon framework {}: member {} released", framework, location);
    } else {
      LOG.warn("Marathon framework {}: member {} not found for release", framework, location);
    }
    // Now close and unmange the container
    try {
      location.close();
      task.stop();
    } catch (Exception e) {
      LOG.warn("Error stopping task: " + task, e);
      Exceptions.propagateIfFatal(e);
    } finally {
      Entities.unmanage(task);
    }
  } finally {
    lock.readLock().unlock();
  }
}

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

@Override
public void deallocateNetwork(VirtualNetwork network) {
  sensors().get(SDN_NETWORKS).removeMember(network);
  network.stop();
  Entities.unmanage(network);
  // TODO actually deprovision the network if possible?
}

代码示例来源: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);
    }
  }
}

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

continue;
} else if (Lifecycle.STOPPING.equals(state) || Lifecycle.STOPPED.equals(state)) {
  getTaskCluster().removeMember(member);
  getTaskCluster().removeChild(member);
  Entities.unmanage(member);

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

e.clearParent();
for (Group group : e.groups()) {
  if (!Entities.isNoLongerManaged(group)) group.removeMember(e);

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

protected void updateMembership(Entity e) {
  boolean isMember = checkMembership(e);
  if (isMember) getGroup().addMember(e);
  else getGroup().removeMember(e);
}

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

continue;
} else if (Lifecycle.STOPPING.equals(state) || Lifecycle.STOPPED.equals(state)) {
  getDockerContainerCluster().removeMember(member);
  getDockerContainerCluster().removeChild(member);
  Entities.unmanage(member);

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

continue;
} else if (Lifecycle.STOPPING.equals(state) || Lifecycle.STOPPED.equals(state)) {
  group.removeMember(found);
  group.removeChild(found);
  Entities.unmanage(found);

相关文章