本文整理了Java中org.apache.brooklyn.api.entity.Group.removeMember()
方法的一些代码示例,展示了Group.removeMember()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Group.removeMember()
方法的具体详情如下:
包路径:org.apache.brooklyn.api.entity.Group
类名称: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);
内容来源于网络,如有侵权,请联系作者删除!