summaryrefslogtreecommitdiffstats
path: root/docker-api
diff options
context:
space:
mode:
authorfreva <valerijf@yahoo-inc.com>2017-03-03 15:42:20 +0100
committerfreva <valerijf@yahoo-inc.com>2017-03-03 15:42:20 +0100
commit1b084181a6cf58fc53c3f477b9242840a9a7b465 (patch)
treec0549a46abbcba3bc5a27c33e7f4b7b73114a49e /docker-api
parent27b365d790c435e23f2aa87aeae8a79509635115 (diff)
Simplify getContainer()
Diffstat (limited to 'docker-api')
-rw-r--r--docker-api/src/main/java/com/yahoo/vespa/hosted/dockerapi/DockerImpl.java13
1 files changed, 4 insertions, 9 deletions
diff --git a/docker-api/src/main/java/com/yahoo/vespa/hosted/dockerapi/DockerImpl.java b/docker-api/src/main/java/com/yahoo/vespa/hosted/dockerapi/DockerImpl.java
index c331a6dcd5c..5a13c06909c 100644
--- a/docker-api/src/main/java/com/yahoo/vespa/hosted/dockerapi/DockerImpl.java
+++ b/docker-api/src/main/java/com/yahoo/vespa/hosted/dockerapi/DockerImpl.java
@@ -41,7 +41,6 @@ import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
-import java.util.Objects;
import java.util.Optional;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.TimeUnit;
@@ -336,22 +335,18 @@ public class DockerImpl implements Docker {
public List<Container> getAllContainersManagedBy(String manager) {
return listAllContainers().stream()
.filter(container -> isManagedBy(container, manager))
+ .map(com.github.dockerjava.api.model.Container::getId)
.flatMap(this::asContainer)
.collect(Collectors.toList());
}
@Override
public Optional<Container> getContainer(ContainerName containerName) {
- return listAllContainers().stream()
- .filter(container -> Arrays.stream(container.getNames())
- .map(this::decode)
- .anyMatch(name -> name.equals(containerName.asString())))
- .flatMap(this::asContainer)
- .findFirst();
+ return asContainer(containerName.asString()).findFirst();
}
- private Stream<Container> asContainer(com.github.dockerjava.api.model.Container dockerClientContainer) {
- return inspectContainerCmd(dockerClientContainer.getId())
+ private Stream<Container> asContainer(String container) {
+ return inspectContainerCmd(container)
.map(response ->
new Container(
response.getConfig().getHostName(),