import com.github.dockerjava.api.model.ContainerConfig; //导入依赖的package包/类
private DockerEvent getDockerEvent(String containerId){
	DockerEvent result = null;
	try{
		InspectContainerResponse inspectResponse = dockerClient.inspectContainerCmd(containerId).exec();
		ContainerConfig config = inspectResponse.getConfig();
		Map<String,String> labels = config.getLabels();
		String taskId = labels.get(TASK_ID);
		if(this.taskId.getValue().equals(taskId)){
			ContainerState state = inspectResponse.getState();
			String name = inspectResponse.getName();
			int exitCode = state.getExitCode();
			int pid = state.getPid();
			result= new DockerEvent(containerId, name, pid, exitCode);
		}
	}catch(NotFoundException exception){
		log.debug("tried to debug non-existent containerId",exception);
	}
	return result;
}
 

import com.github.dockerjava.api.model.ContainerConfig; //导入依赖的package包/类
private void setNetworkMode(Instance instance, ContainerConfig containerConfig, HostConfig hostConfig) {
    if(DataAccessor.fields(instance).withKey(FIELD_NETWORK_MODE).get() != null)
        return;

    String netMode = null;
    if (containerConfig != null && containerConfig.isNetworkDisabled()) {
        netMode = NetworkConstants.NETWORK_MODE_NONE;
    } else if (hostConfig != null) {
        String inspectNetMode = hostConfig.getNetworkMode();
        if (NetworkConstants.NETWORK_MODE_BRIDGE.equals(inspectNetMode) ||
                NetworkConstants.NETWORK_MODE_HOST.equals(inspectNetMode) ||
                NetworkConstants.NETWORK_MODE_NONE.equals(inspectNetMode)) {
            netMode = inspectNetMode;
        } else if (NetworkConstants.NETWORK_MODE_DEFAULT.equals(inspectNetMode) || StringUtils.isBlank(inspectNetMode)) {
            netMode = NetworkConstants.NETWORK_MODE_BRIDGE;
        } else if (StringUtils.startsWith(inspectNetMode, NetworkConstants.NETWORK_MODE_CONTAINER)) {
            throw new ClientVisibleException(ResponseCodes.UNPROCESSABLE_ENTITY, ValidationErrorCodes.INVALID_OPTION,
                    "Transformer API does not support container network mode.", null);
        } else {
            throw new ClientVisibleException(ResponseCodes.UNPROCESSABLE_ENTITY, ValidationErrorCodes.INVALID_OPTION,
                    "Unrecognized network mode: " + inspectNetMode, null);
        }
    }

    setField(instance, FIELD_NETWORK_MODE, netMode);
}
 

import com.github.dockerjava.api.model.ContainerConfig; //导入依赖的package包/类
@Override
public KieContainerDetails inspect(String containerId) {

    Timer timer = new Timer();
    if (LOGGER.isDebugEnabled()) {
        LOGGER.debug("Start inspecting container with id = " + containerId);
        timer.start();
    }
    
    final DockerClient dockerClient = getClient();
    final InspectContainerResponse response = dockerClient.inspectContainerCmd(containerId).exec();
    final NetworkSettings networkSettings = response.getNetworkSettings();
    final ContainerConfig config = response.getConfig();
    final String[] envVars = config.getEnv();
    final InspectContainerResponse.ContainerState state = response.getState();
    final String ipAddress = networkSettings.getIpAddress();
    final int containerPid = state.getPid();
    final String containerStartedAt = state.getStartedAt();
    final String containerFinishedAt = state.getFinishedAt();
    final Map<String, Map<String, String>> portMappings = networkSettings.getPortMapping();
    final String[] containerArgs = response.getArgs();
    
    final KieContainerDetails details = new KieContainerDetails();
    details.setIpAddress(ipAddress);
    details.setContainerPid(containerPid);
    details.setContainerStartedAt(containerStartedAt);
    details.setContainerFinishedAt(containerFinishedAt);
    details.setPortMappings(portMappings);
    details.setContainerArgs(containerArgs);
    details.setEnvVars(escapeEnvVars(envVars));

    if (LOGGER.isDebugEnabled()) {
        timer.end();
        LOGGER.debug("container with id = " + containerId + " inspected. Elapsed time = " + timer.getTotalTime());
    }
    
    return details;
}
 

import com.github.dockerjava.api.model.ContainerConfig; //导入依赖的package包/类
@Override
public void setExposed(Instance instance, Map<String, Object> fromInspect) {
    InspectContainerResponse inspect = transformInspect(fromInspect);
    ContainerConfig containerConfig = inspect.getConfig();
    HostConfig hostConfig = inspect.getHostConfig();

    if (containerConfig != null && hostConfig != null) {
        setExposed(instance, safeGetExposedPorts(containerConfig));
    }

}
 

import com.github.dockerjava.api.model.ContainerConfig; //导入依赖的package包/类
private ExposedPort[] safeGetExposedPorts(ContainerConfig containerConfig) {
    try {
        return containerConfig.getExposedPorts();
    } catch (NullPointerException e) {
        // Bug in docker-java doesn't account for this property being null
        return null;
    }
}
 

import com.github.dockerjava.api.model.ContainerConfig; //导入依赖的package包/类
public ContainerConfig getConfig() {
    return config;
}
 

import com.github.dockerjava.api.model.ContainerConfig; //导入依赖的package包/类
/**
 * Get the image commit configuration
 * @see #config
 */
@CheckForNull
public ContainerConfig getConfig() {
    return config;
}
 

import com.github.dockerjava.api.model.ContainerConfig; //导入依赖的package包/类
/**
 * @see #config
 */
public InspectImageResponse withConfig(ContainerConfig config) {
    this.config = config;
    return this;
}
 

import com.github.dockerjava.api.model.ContainerConfig; //导入依赖的package包/类
/**
 * @see #containerConfig
 */
public InspectImageResponse withContainerConfig(ContainerConfig containerConfig) {
    this.containerConfig = containerConfig;
    return this;
}
 

import com.github.dockerjava.api.model.ContainerConfig; //导入依赖的package包/类
private ContainerConfig getImageConfig() {
    return this.actual.getConfig();
}
 

import com.github.dockerjava.api.model.ContainerConfig; //导入依赖的package包/类
private ContainerConfig getContainerConfig() {
    return this.actual.getConfig();
}
 

import com.github.dockerjava.api.model.ContainerConfig; //导入依赖的package包/类
/**
 * If the image was created from a container, this config contains the configuration of the container
 * which was committed in this image
 * @see #containerConfig
 */
@CheckForNull
public ContainerConfig getContainerConfig() {
    return containerConfig;
}