Java WaitContainerResultCallback类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中com.github.dockerjava.core.command.WaitContainerResultCallback类的典型用法代码示例。如果您正苦于以下问题：Java WaitContainerResultCallback类的具体用法？Java WaitContainerResultCallback怎么用？Java WaitContainerResultCallback使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

WaitContainerResultCallback类属于com.github.dockerjava.core.command包，在下文中一共展示了WaitContainerResultCallback类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: stopAndRemoveContainer

import com.github.dockerjava.core.command.WaitContainerResultCallback; //导入依赖的package包/类
private void stopAndRemoveContainer(@NonNull final DockerClient _dockerClient,
                                    @NonNull final CreateContainerResponse _container) {
    _dockerClient
            .stopContainerCmd(_container.getId())
            .withTimeout(0)
            .exec();

    try {
        _dockerClient
                .waitContainerCmd(_container.getId())
                .exec(new WaitContainerResultCallback())
                .awaitCompletion();
    } catch (InterruptedException e) {
        // ignore
    }

    _dockerClient
            .removeContainerCmd(_container.getId())
            .exec();
}

开发者ID:jonfryd，项目名称:tifoon，代码行数:21，代码来源:DockerExecutorPlugin.java

示例2: testWaitContainerTimeout

import com.github.dockerjava.core.command.WaitContainerResultCallback; //导入依赖的package包/类
@Test
public void testWaitContainerTimeout() throws Exception {

    CreateContainerResponse container = dockerRule.getClient().createContainerCmd("busybox").withCmd("sleep", "10").exec();

    LOG.info("Created container: {}", container.toString());
    assertThat(container.getId(), not(isEmptyString()));

    dockerRule.getClient().startContainerCmd(container.getId()).exec();

    WaitContainerResultCallback callback = dockerRule.getClient().waitContainerCmd(container.getId()).exec(
            new WaitContainerResultCallback());
    try {
        callback.awaitStatusCode(100, TimeUnit.MILLISECONDS);
        throw new AssertionError("Should throw exception on timeout.");
    } catch (DockerClientException e) {
        LOG.info(e.getMessage());
    }
}

开发者ID:docker-java，项目名称:docker-java，代码行数:20，代码来源:WaitContainerCmdIT.java

示例3: testContainerDiff

import com.github.dockerjava.core.command.WaitContainerResultCallback; //导入依赖的package包/类
@Test
public void testContainerDiff() throws DockerException {
    CreateContainerResponse container = dockerRule.getClient().createContainerCmd(DEFAULT_IMAGE).withCmd("touch", "/test").exec();
    LOG.info("Created container: {}", container.toString());
    assertThat(container.getId(), not(isEmptyString()));
    dockerRule.getClient().startContainerCmd(container.getId()).exec();

    int exitCode = dockerRule.getClient().waitContainerCmd(container.getId()).exec(new WaitContainerResultCallback())
            .awaitStatusCode();
    assertThat(exitCode, equalTo(0));

    List<ChangeLog> filesystemDiff = dockerRule.getClient().containerDiffCmd(container.getId()).exec();
    LOG.info("Container DIFF: {}", filesystemDiff.toString());

    assertThat(filesystemDiff.size(), equalTo(1));
    ChangeLog testChangeLog = selectUnique(filesystemDiff, hasField("path", equalTo("/test")));

    assertThat(testChangeLog, hasField("path", equalTo("/test")));
    assertThat(testChangeLog, hasField("kind", equalTo(1)));
}

开发者ID:docker-java，项目名称:docker-java，代码行数:21，代码来源:ContainerDiffCmdIT.java

示例4: setUp

import com.github.dockerjava.core.command.WaitContainerResultCallback; //导入依赖的package包/类
@Before
public void setUp()
throws Exception {
	super.setUp();
	initTestContainer();
	dockerClient.startContainerCmd(testContainerId).exec();
	dockerClient
		.waitContainerCmd(testContainerId)
		.exec(new WaitContainerResultCallback())
		.awaitStatusCode(1000, TimeUnit.SECONDS);
	stdOutput = stdOutBuff.toString();
}

开发者ID:emc-mongoose，项目名称:mongoose-base，代码行数:13，代码来源:GroovyParallelShellCommandsTest.java

示例5: setUp

import com.github.dockerjava.core.command.WaitContainerResultCallback; //导入依赖的package包/类
@Before
public void setUp()
throws Exception {
	configArgs.add("--storage-net-http-namespace=ns1");
	configArgs.add("--storage-mock-capacity=10000000");
	super.setUp();
	if(storageType.equals(StorageType.FS)) {
		itemOutputPath = Paths.get(
			Paths.get(PathUtil.getBaseDir()).getParent().toString(), stepId
		).toString();
		EnvUtil.set("ITEM_OUTPUT_PATH", itemOutputPath);
	} else {
		itemOutputPath = "/default";
		EnvUtil.set("ITEM_OUTPUT_PATH", stepId);
	}
	configArgs.add("--item-output-path=" + itemOutputPath);

	initTestContainer();
	duration = System.currentTimeMillis();
	dockerClient.startContainerCmd(testContainerId).exec();
	containerExitCode = dockerClient
		.waitContainerCmd(testContainerId)
		.exec(new WaitContainerResultCallback())
		.awaitStatusCode(2, TimeUnit.MINUTES);
	duration = System.currentTimeMillis() - duration;
	stdOutput = stdOutBuff.toString();
}

开发者ID:emc-mongoose，项目名称:mongoose-base，代码行数:28，代码来源:PyWeightedLoadTest.java

示例6: setUp

import com.github.dockerjava.core.command.WaitContainerResultCallback; //导入依赖的package包/类
@Before
public void setUp()
throws Exception {
	configArgs.add("--test-step-limit-count=" + COUNT_LIMIT);
	super.setUp();
	switch(storageType) {
		case FS:
			itemOutputPath = Paths.get(
				Paths.get(PathUtil.getBaseDir()).getParent().toString(), stepId
			).toString();
			configArgs.add("--item-output-path=" + itemOutputPath);
			break;
		case SWIFT:
			configArgs.add("--storage-net-http-namespace=ns1");
			break;
	}
	initTestContainer();

	duration = System.currentTimeMillis();
	dockerClient.startContainerCmd(testContainerId).exec();
	containerExitCode = dockerClient
		.waitContainerCmd(testContainerId)
		.exec(new WaitContainerResultCallback())
		.awaitStatusCode(1000, TimeUnit.SECONDS);
	duration = System.currentTimeMillis() - duration;
	stdOutput = stdOutBuff.toString();
}

开发者ID:emc-mongoose，项目名称:mongoose-base，代码行数:28，代码来源:JsChainLoadStepTest.java

示例7: setUp

import com.github.dockerjava.core.command.WaitContainerResultCallback; //导入依赖的package包/类
@Before @Override
public void setUp()
throws Exception {

	super.setUp();

	switch(storageType) {
		case FS:
			final Path containerItemOutputPath = Paths.get(CONTAINER_SHARE_PATH, stepId);
			configArgs.add("--item-output-path=" + containerItemOutputPath.toString());
			break;
		case SWIFT:
			configArgs.add("--storage-net-http-namespace=ns1");
			break;
	}

	EnvUtil.set("ITEMS_FILE_0", stepId + "_0.csv");
	EnvUtil.set("ITEMS_FILE_1", stepId + "_1.csv");
	EnvUtil.set("ITEMS_FILE_2", stepId + "_2.csv");
	EnvUtil.set("FIRST_STEP_DURATION_LIMIT", Integer.toString(FIRST_STEP_DURATION_LIMIT));
	EnvUtil.set("UPDATE_RANDOM_RANGES_COUNT", Integer.toString(UPDATE_RANDOM_RANGES_COUNT));

	initTestContainer();
	dockerClient.startContainerCmd(testContainerId).exec();
	containerExitCode = dockerClient
		.waitContainerCmd(testContainerId)
		.exec(new WaitContainerResultCallback())
		.awaitStatusCode(300, TimeUnit.SECONDS);
	stdOutput = stdOutBuff.toString();
}

开发者ID:emc-mongoose，项目名称:mongoose-base，代码行数:31，代码来源:GroovyLoadTypeStepsTest.java

示例8: setUp

import com.github.dockerjava.core.command.WaitContainerResultCallback; //导入依赖的package包/类
@Before @Override
public void setUp()
throws Exception {

	super.setUp();

	switch(storageType) {
		case FS:
			final Path containerItemOutputPath = Paths.get(CONTAINER_SHARE_PATH, stepId);
			configArgs.add("--item-output-path=" + containerItemOutputPath.toString());
			break;
		case SWIFT:
			configArgs.add("--storage-net-http-namespace=ns1");
			break;
	}

	EnvUtil.set("ITEMS_FILE_0", stepId + "_0.csv");
	EnvUtil.set("ITEMS_FILE_1", stepId + "_1.csv");
	EnvUtil.set("FIRST_STEP_COUNT_LIMIT", Integer.toString(FIRST_STEP_COUNT_LIMIT));

	initTestContainer();
	dockerClient.startContainerCmd(testContainerId).exec();
	containerExitCode = dockerClient
		.waitContainerCmd(testContainerId)
		.exec(new WaitContainerResultCallback())
		.awaitStatusCode(300, TimeUnit.SECONDS);
	stdOutput = stdOutBuff.toString();
}

开发者ID:emc-mongoose，项目名称:mongoose-base，代码行数:29，代码来源:JsUpdateAndReadVariantsTest.java

示例9: DockerizedProcess

import com.github.dockerjava.core.command.WaitContainerResultCallback; //导入依赖的package包/类
public DockerizedProcess(final DockerClient dockerClient, final String containerId, final Closure afterContainerStop) throws Exception
{
    this.dockerClient = dockerClient;
    this.containerId = containerId;
    this.afterContainerStop = afterContainerStop;
    attachStreams();
    dockerClient.waitContainerCmd(containerId).exec(new WaitContainerResultCallback() {
        @Override public void onNext(WaitResponse waitResponse)
        {
            exitCode.set(waitResponse.getStatusCode());
            try
            {
                attachContainerResultCallback.close();
                attachContainerResultCallback.awaitCompletion();
                stdOutWriteStream.close();
                stdErrWriteStream.close();
            } catch (Exception e) {
                LOGGER.debug("Error by detaching streams", e);
            } finally
            {
                finished.countDown();
                invokeIfNotNull(afterContainerStop, containerId, dockerClient);
            }


        }
    });
}

开发者ID:pedjak，项目名称:gradle-dockerized-test-plugin，代码行数:29，代码来源:DockerizedExecHandle.java

示例10: testWaitNonExistingContainer

import com.github.dockerjava.core.command.WaitContainerResultCallback; //导入依赖的package包/类
@Test(expected = NotFoundException.class)
public void testWaitNonExistingContainer() throws DockerException {

    WaitContainerResultCallback callback = new WaitContainerResultCallback() {
        public void onNext(WaitResponse waitResponse) {
            throw new AssertionError("expected NotFoundException");
        }
    };

    dockerRule.getClient().waitContainerCmd("non-existing").exec(callback).awaitStatusCode();
}

开发者ID:docker-java，项目名称:docker-java，代码行数:12，代码来源:WaitContainerCmdIT.java

示例11: copyFileWithExecutePermission

import com.github.dockerjava.core.command.WaitContainerResultCallback; //导入依赖的package包/类
@Test
public void copyFileWithExecutePermission() throws Exception {
    // create script file, add permission to execute
    Path scriptPath = Files.createTempFile("run", ".sh");
    boolean executable = scriptPath.toFile().setExecutable(true, false);
    if (!executable){
        throw new Exception("Execute permission on file not set!");
    }
    String snippet = "Running script with execute permission.";
    String scriptTextStr = "#!/bin/sh\necho \"" + snippet + "\"";
    // write content for created script
    Files.write(scriptPath, scriptTextStr.getBytes());
    // create a test container which starts and waits 3 seconds for the
    // script to be copied to the container's home dir and then executes it
    String containerCmd = "sleep 3; /home/" + scriptPath.getFileName().toString();
    CreateContainerResponse container = dockerRule.getClient().createContainerCmd("busybox")
            .withName("copyFileWithExecutivePerm" + dockerRule.getKind())
            .withCmd("/bin/sh", "-c", containerCmd)
            .exec();
    // start the container
    dockerRule.getClient().startContainerCmd(container.getId()).exec();
    // copy script to container home dir
    dockerRule.getClient().copyArchiveToContainerCmd(container.getId())
            .withRemotePath("/home")
            .withHostResource(scriptPath.toString())
            .exec();
    // await exid code
    int exitCode = dockerRule.getClient().waitContainerCmd(container.getId())
            .exec(new WaitContainerResultCallback())
            .awaitStatusCode();
    // check result
    assertThat(exitCode, equalTo(0));
}

开发者ID:docker-java，项目名称:docker-java，代码行数:34，代码来源:CopyArchiveToContainerCmdIT.java

示例12: commitWithLabels

import com.github.dockerjava.core.command.WaitContainerResultCallback; //导入依赖的package包/类
@Test
public void commitWithLabels() throws DockerException {

    CreateContainerResponse container = dockerRule.getClient().createContainerCmd("busybox")
            .withCmd("touch", "/test")
            .exec();

    LOG.info("Created container: {}", container.toString());
    assertThat(container.getId(), not(isEmptyString()));
    dockerRule.getClient().startContainerCmd(container.getId()).exec();

    Integer status = dockerRule.getClient().waitContainerCmd(container.getId())
            .exec(new WaitContainerResultCallback())
            .awaitStatusCode();

    assertThat(status, is(0));

    LOG.info("Committing container: {}", container.toString());
    Map<String, String> labels = ImmutableMap.of("label1", "abc", "label2", "123");
    String imageId = dockerRule.getClient().commitCmd(container.getId())
            .withLabels(labels)
            .exec();

    InspectImageResponse inspectImageResponse = dockerRule.getClient().inspectImageCmd(imageId).exec();
    LOG.info("Image Inspect: {}", inspectImageResponse.toString());

    //use config here since containerConfig contains the configuration of the container which was
    //committed to the container
    //https://stackoverflow.com/questions/36216220/what-is-different-of-config-and-containerconfig-of-docker-inspect
    Map<String, String> responseLabels = inspectImageResponse.getConfig().getLabels();
    //swarm will attach additional labels here
    assertThat(responseLabels.size(), greaterThanOrEqualTo(2));
    assertThat(responseLabels.get("label1"), equalTo("abc"));
    assertThat(responseLabels.get("label2"), equalTo("123"));
}

开发者ID:docker-java，项目名称:docker-java，代码行数:36，代码来源:CommitCmdIT.java

示例13: asyncLogContainerWithSince

import com.github.dockerjava.core.command.WaitContainerResultCallback; //导入依赖的package包/类
@Test
public void asyncLogContainerWithSince() throws Exception {
    String snippet = "hello world";

    CreateContainerResponse container = dockerRule.getClient().createContainerCmd("busybox")
            .withCmd("/bin/echo", snippet)
            .exec();

    LOG.info("Created container: {}", container.toString());
    assertThat(container.getId(), not(isEmptyString()));

    int timestamp = (int) (System.currentTimeMillis() / 1000);

    dockerRule.getClient().startContainerCmd(container.getId()).exec();

    int exitCode = dockerRule.getClient().waitContainerCmd(container.getId())
            .exec(new WaitContainerResultCallback())
            .awaitStatusCode();

    assertThat(exitCode, equalTo(0));

    LogContainerTestCallback loggingCallback = new LogContainerTestCallback();

    dockerRule.getClient().logContainerCmd(container.getId())
            .withStdErr(true)
            .withStdOut(true)
            .withSince(timestamp)
            .exec(loggingCallback);

    loggingCallback.awaitCompletion();

    assertThat(loggingCallback.toString(), containsString(snippet));
}

开发者ID:docker-java，项目名称:docker-java，代码行数:34，代码来源:LogContainerCmdIT.java

示例14: testExitedFilter

import com.github.dockerjava.core.command.WaitContainerResultCallback; //导入依赖的package包/类
@Test
public void testExitedFilter() throws Exception {
    dockerRule.getClient().createContainerCmd(DEFAULT_IMAGE)
            .withLabels(testLabel)
            .exec();

    String id = dockerRule.getClient().createContainerCmd(DEFAULT_IMAGE)
            .withLabels(testLabel)
            .withCmd("sh", "-c", "exit 42")
            .exec()
            .getId();

    dockerRule.getClient().startContainerCmd(id).exec();

    Integer status = dockerRule.getClient().waitContainerCmd(id).exec(new WaitContainerResultCallback())
            .awaitStatusCode();

    assertThat(status, is(42));

    List<Container> filteredContainers = dockerRule.getClient().listContainersCmd()
            .withLabelFilter(testLabel)
            .withShowAll(true)
            .withExitedFilter(42)
            .exec();

    assertThat(filteredContainers.size(), is(1));
    assertThat(filteredContainers.get(0).getId(), is(id));
}

开发者ID:docker-java，项目名称:docker-java，代码行数:29，代码来源:ListContainersCmdIT.java

示例15: execBuild

import com.github.dockerjava.core.command.WaitContainerResultCallback; //导入依赖的package包/类
private String execBuild(BuildImageCmd buildImageCmd) throws Exception {
    String imageId = buildImageCmd.withNoCache(true).exec(new BuildImageResultCallback()).awaitImageId();

    // Create container based on image
    CreateContainerResponse container = dockerRule.getClient().createContainerCmd(imageId).exec();

    LOG.info("Created container: {}", container.toString());
    assertThat(container.getId(), not(isEmptyString()));

    dockerRule.getClient().startContainerCmd(container.getId()).exec();
    dockerRule.getClient().waitContainerCmd(container.getId()).exec(new WaitContainerResultCallback()).awaitStatusCode();

    return dockerRule.containerLog(container.getId());
}

开发者ID:docker-java，项目名称:docker-java，代码行数:15，代码来源:BuildImageCmdIT.java

示例16: waitContainer

import com.github.dockerjava.core.command.WaitContainerResultCallback; //导入依赖的package包/类
public int waitContainer(String containerId) {
    this.readWriteLock.readLock().lock();
    try {
        return this.dockerClient.waitContainerCmd(containerId)
            .exec(new WaitContainerResultCallback())
            .awaitStatusCode();
    } finally {
        this.readWriteLock.readLock().unlock();
    }
}

开发者ID:arquillian，项目名称:arquillian-cube，代码行数:11，代码来源:DockerClientExecutor.java

示例17: verify_csap_base

import com.github.dockerjava.core.command.WaitContainerResultCallback; //导入依赖的package包/类
@Ignore
@Test
public void verify_csap_base ()
		throws Exception {

	// ref. https://github.com/docker-java/docker-java/wiki

	String containerName = "/junit-csapbase-"
			+ LocalDateTime.now().format( DateTimeFormatter.ofPattern( "MMM.d-HH.mm.ss" ) );

	String imageName = CSAP_DOCKER_REPOSITORY +"/csap-base";
	// imageName = "centos";
	loadImageIfNeeded( imageName );

	CreateContainerResponse containerResponse = dockerClient.createContainerCmd( imageName )
		.withName( containerName )
		.withWorkingDir( "/" )
		.exec();

	dockerClient
		.startContainerCmd( containerResponse.getId() )
		.exec();

	// Thread.sleep( 3000 );
	int exitCode = dockerClient.waitContainerCmd( containerResponse.getId() )
		.exec( new WaitContainerResultCallback() )
		.awaitStatusCode( 5, TimeUnit.SECONDS );

	logger.info( "Container exited with: {}", exitCode );

	LogContainerTestCallback loggingCallback = new LogContainerTestCallback( false );
	dockerClient
		.logContainerCmd( containerResponse.getId() )
		.withStdErr( true )
		.withStdOut( true )
		.withTailAll()
		.exec( loggingCallback );

	loggingCallback.awaitCompletion( 3, TimeUnit.SECONDS );

	logger.info( "logs: \n {} ", loggingCallback.toString() );

	loggingCallback.close();

	assertThat( loggingCallback.toString() )
		.as( "csap-base logs" )
		.contains( "Java HotSpot(TM) 64-Bit Server VM" );

	dockerClient
		.removeContainerCmd( containerResponse.getId() )
		.withForce( true )
		.exec();
}

开发者ID:csap-platform，项目名称:csap-core，代码行数:54，代码来源:Docker_Java.java

示例18: verify_container_logs

import com.github.dockerjava.core.command.WaitContainerResultCallback; //导入依赖的package包/类
@Test
public void verify_container_logs ()
		throws Exception {

	String imageName = "hello-world";
	loadImageIfNeeded( imageName );
	String containerName = "/junit-logtest-"
			+ LocalDateTime.now().format( DateTimeFormatter.ofPattern( "MMM.d-HH.mm.ss" ) );

	CreateContainerResponse createResponse = dockerClient
		.createContainerCmd( imageName )
		.withName( containerName )
		.withCmd( "/hello" )
		.withTty( true )
		.exec();

	// CreateContainerResponse createResponse =
	// dockerClient.createContainerCmd( "busybox" )
	// .withCmd( "/bin/ls" )
	// .withName( containerName )
	// .exec();

	logger.info( "Create: {}", createResponse );

	dockerClient
		.startContainerCmd( createResponse.getId() )
		.exec();

	int exitCode = dockerClient.waitContainerCmd( createResponse.getId() )
		.exec( new WaitContainerResultCallback() )
		.awaitStatusCode( 5, TimeUnit.SECONDS );

	LogContainerTestCallback loggingCallback = new LogContainerTestCallback( false );

	dockerClient
		.logContainerCmd( createResponse.getId() )
		.withStdErr( true )
		.withStdOut( true )
		.withTailAll()
		.exec( loggingCallback );
	//
	loggingCallback.awaitCompletion( 3, TimeUnit.SECONDS );

	logger.info( "{} logs: \n {} ", containerName, loggingCallback.toString() );

	loggingCallback.close();

	assertThat( loggingCallback.toString() )
		.as( "HelloWorld logs" )
		.contains( "Hello from Docker!" );

	dockerClient
		.removeContainerCmd( createResponse.getId() )
		.withRemoveVolumes( true )
		.withForce( true )
		.exec();

	logger.info( "Container removed: {}", createResponse.getId() );

}

开发者ID:csap-platform，项目名称:csap-core，代码行数:61，代码来源:Docker_Java.java

示例19: verify_container_logs_stream

import com.github.dockerjava.core.command.WaitContainerResultCallback; //导入依赖的package包/类
@Test
public void verify_container_logs_stream ()
		throws Exception {

	String imageName = "hello-world";
	loadImageIfNeeded( imageName );
	String containerName = "/junit-logtest-"
			+ LocalDateTime.now().format( DateTimeFormatter.ofPattern( "MMM.d-HH.mm.ss" ) );

	CreateContainerResponse createResponse = dockerClient
		.createContainerCmd( imageName )
		.withName( containerName )
		.withCmd( "/hello" )
		.withTty( true )
		.exec();

	// CreateContainerResponse createResponse =
	// dockerClient.createContainerCmd( "busybox" )
	// .withCmd( "/bin/ls" )
	// .withName( containerName )
	// .exec();

	logger.info( "Create: {}", createResponse );

	dockerClient
		.startContainerCmd( createResponse.getId() )
		.exec();

	int exitCode = dockerClient.waitContainerCmd( createResponse.getId() )
		.exec( new WaitContainerResultCallback() )
		.awaitStatusCode( 5, TimeUnit.SECONDS );

	StringWriter sw = new StringWriter();
	LogContainerTestCallback loggingCallback = new LogContainerTestCallback( sw );

	dockerClient
		.logContainerCmd( createResponse.getId() )
		.withStdErr( true )
		.withStdOut( true )
		.withTailAll()
		.exec( loggingCallback );
	//
	loggingCallback.awaitCompletion( 3, TimeUnit.SECONDS );

	sw.flush();
	logger.info( "{} logs from stream: \n {} ", containerName, sw.toString() );

	loggingCallback.close();

	assertThat( sw.toString() )
		.as( "HelloWorld logs" )
		.contains( "Hello from Docker!" );

	dockerClient
		.removeContainerCmd( createResponse.getId() )
		.withRemoveVolumes( true )
		.withForce( true )
		.exec();

	logger.info( "Container removed: {}", createResponse.getId() );

	loggingCallback.close();

}

开发者ID:csap-platform，项目名称:csap-core，代码行数:65，代码来源:Docker_Java.java

示例20: runBuild

import com.github.dockerjava.core.command.WaitContainerResultCallback; //导入依赖的package包/类
public void runBuild(String image, String cmd, Path repoPath) {

        LOGGER.info("Run Build Start");
        String fileName = repoPath.getFileName().toString();
        Volume volume = new Volume(File.separator + fileName);

        // mvn cache
        Volume mvnVolume = new Volume(DOCKER_MVN_CACHE_FOLDER);

        LOGGER.info("Run Build Start - " + Paths.get(repoPath.getParent().toString(), REPOSITORY).toString());

        CreateContainerResponse container = docker
            .createContainerCmd(image)
            .withBinds(new Bind(repoPath.toString(), volume),
                new Bind(Paths.get(repoPath.getParent().toString(), REPOSITORY).toString(), mvnVolume))
            .withWorkingDir(File.separator + fileName)
            .withCmd(BASH, "-c", cmd)
            .withTty(true)
            .exec();

        docker.startContainerCmd(container.getId()).exec();

        BuildProcess loggingCallback = new
            BuildProcess();

        try {
            docker
                .logContainerCmd(container.getId())
                .withStdErr(true)
                .withStdOut(true)
                .withFollowStream(true)
                .withTailAll()
                .exec(loggingCallback)
                .awaitStarted();

            loggingCallback.awaitCompletion();

            int exitCode = docker
                .waitContainerCmd(container.getId())
                .exec(new WaitContainerResultCallback())
                .awaitStatusCode();

            docker.removeContainerCmd(container.getId()).exec();
            if (exitCode != 0) {
                throw new PluginException("Build Project Error ExitCode: " + exitCode);
            }

        } catch (Throwable e) {
            docker.removeContainerCmd(container.getId());
            LOGGER.error("Docker build error ", e);
            throw new PluginException("Docker build error " + e.getMessage());
        }
        LOGGER.info("Run Build Finish");
    }

开发者ID:FlowCI，项目名称:flow-platform，代码行数:55，代码来源:Docker.java

注：本文中的com.github.dockerjava.core.command.WaitContainerResultCallback类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java XSComponent类代码示例发布时间：2022-05-23

Java TypedXmlWriter类代码示例发布时间：2022-05-23

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18013|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9590|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8140|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8522|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8425|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9327|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8388|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7823|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8378|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7370|2022-11-06

客服电话

电子邮件

Java WaitContainerResultCallback类代码示例

示例1: stopAndRemoveContainer

示例2: testWaitContainerTimeout

示例3: testContainerDiff

示例4: setUp

示例5: setUp

示例6: setUp

示例7: setUp

示例8: setUp

示例9: DockerizedProcess

示例10: testWaitNonExistingContainer

示例11: copyFileWithExecutePermission

示例12: commitWithLabels

示例13: asyncLogContainerWithSince

示例14: testExitedFilter

示例15: execBuild

示例16: waitContainer

示例17: verify_csap_base

示例18: verify_container_logs

示例19: verify_container_logs_stream

示例20: runBuild

请发表评论

全部评论

上一篇：

下一篇：

librespeed/speedtest: Self-hosted Speedt

CVE-2022-30275

avehtari/BDA_m_demos: Bayesian Data Anal

四维彩超怎么看性别？四维看男孩女孩诀窍

膛的拼音和组词，带膛字词语大全

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053