|
|
@@ -1,10 +1,7 @@
|
|
|
package cn.reghao.devops.common.docker;
|
|
|
|
|
|
-import cn.reghao.devops.common.docker.po.ContainerInfo;
|
|
|
-import cn.reghao.devops.common.docker.po.DockerAuth;
|
|
|
-import cn.reghao.devops.common.docker.po.ImageInfo;
|
|
|
+import cn.reghao.devops.common.docker.model.DockerAuth;
|
|
|
import cn.reghao.jutil.jdk.exception.ExceptionUtil;
|
|
|
-import cn.reghao.jutil.jdk.converter.DateTimeConverter;
|
|
|
import cn.reghao.jutil.jdk.text.TextFile;
|
|
|
import com.github.dockerjava.api.DockerClient;
|
|
|
import com.github.dockerjava.api.async.ResultCallback;
|
|
|
@@ -19,7 +16,6 @@ import lombok.extern.slf4j.Slf4j;
|
|
|
|
|
|
import java.io.File;
|
|
|
import java.time.Duration;
|
|
|
-import java.time.LocalDateTime;
|
|
|
import java.util.*;
|
|
|
import java.util.stream.Collectors;
|
|
|
|
|
|
@@ -185,7 +181,7 @@ public class DockerImpl implements Docker {
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public InspectContainerResponse createAndRun(String containerName, cn.reghao.devops.common.docker.po.Config containerConfig) throws Exception {
|
|
|
+ public InspectContainerResponse createAndRun(String containerName, cn.reghao.devops.common.docker.model.Config containerConfig) throws Exception {
|
|
|
stopAndDelete(containerName);
|
|
|
|
|
|
String image = containerConfig.getImage();
|
|
|
@@ -248,9 +244,10 @@ public class DockerImpl implements Docker {
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public List<ImageInfo> images() {
|
|
|
+ public List<Image> images() {
|
|
|
List<Image> images = dockerClient.listImagesCmd().exec();
|
|
|
- return images.stream().map(image -> {
|
|
|
+ return images;
|
|
|
+ /*return images.stream().map(image -> {
|
|
|
long created = image.getCreated();
|
|
|
String[] repoTags = image.getRepoTags();
|
|
|
if (repoTags.length == 0) {
|
|
|
@@ -263,7 +260,7 @@ public class DockerImpl implements Docker {
|
|
|
String tag = repoTag[1];
|
|
|
LocalDateTime created1 = DateTimeConverter.localDateTime(created*1000);
|
|
|
return new ImageInfo(repo, tag, imageId, created1);
|
|
|
- }).filter(Objects::nonNull).collect(Collectors.toList());
|
|
|
+ }).filter(Objects::nonNull).collect(Collectors.toList());*/
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
@@ -277,17 +274,13 @@ public class DockerImpl implements Docker {
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public List<ContainerInfo> psAll() {
|
|
|
+ public List<InspectContainerResponse> psAll() {
|
|
|
List<Container> list = dockerClient.listContainersCmd()
|
|
|
.withShowAll(true)
|
|
|
.exec();
|
|
|
-
|
|
|
return list.stream().map(container -> {
|
|
|
String containerId = container.getId();
|
|
|
- String state = container.getState();
|
|
|
- boolean running = "running".equalsIgnoreCase(state);
|
|
|
- String imageId = container.getImageId();
|
|
|
- return new ContainerInfo(containerId, running, imageId);
|
|
|
+ return dockerClient.inspectContainerCmd(containerId).exec();
|
|
|
}).collect(Collectors.toList());
|
|
|
}
|
|
|
|