Java PullResponseItem类代码示例

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

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

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

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

示例1: call

import com.github.dockerjava.api.model.PullResponseItem; //导入依赖的package包/类
public Void call() throws Exception {
    final ConsoleLogger console = new ConsoleLogger(listener);
    DockerClient client = DockerCommand.getClient(descriptor, cfgData.dockerUrlRes, cfgData.dockerVersionRes, cfgData.dockerCertPathRes, authConfig);

    PullImageCmd pullImageCmd = client.pullImageCmd(fromImageRes);
    PullImageResultCallback callback = new PullImageResultCallback() {
        @Override
        public void onNext(PullResponseItem item) {
            console.logInfo(item.toString());
            super.onNext(item);
        }

        @Override
        public void onError(Throwable throwable) {
            console.logError("Failed to exec start:" + throwable.getMessage());
            super.onError(throwable);
        }
    };
    pullImageCmd.exec(callback).awaitSuccess();
    
    return null;
}

开发者ID:jenkinsci，项目名称:docker-build-step-plugin，代码行数:23，代码来源:PullImageRemoteCallable.java

示例2: onNext

import com.github.dockerjava.api.model.PullResponseItem; //导入依赖的package包/类
@Override
public void onNext ( PullResponseItem item ) {

	logger.debug( "response: {} ", item );

	String progress = item.getStatus();
	if ( item.getErrorDetail() != null ) {
		progress = item.getErrorDetail().getMessage();
		setFoundPullError( true );
	} else if ( item.getProgressDetail() != null && item.getProgressDetail().getCurrent() != null ) {
		progress += "..." + Math.round( item.getProgressDetail().getCurrent() * 100 / item.getProgressDetail().getTotal() ) + "%";
	}

	if ( get_pullOutputManager() != null ) {
		get_pullOutputManager().print( progress );
	}

	if ( lastResults.length() < MAX_PROGRESS ) {

		// System.out.println( progress );
		lastResults.append( "\n" + progress );
	} else {
		logger.warn( "MAX progress messages exceeded: {}", MAX_PROGRESS );
	}

}

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

示例3: onNext

import com.github.dockerjava.api.model.PullResponseItem; //导入依赖的package包/类
@Override
public void onNext ( PullResponseItem item ) {

	logger.debug( "response: {} ", item );

	String progress = item.getStatus();

	if ( item.getProgressDetail() != null && item.getProgressDetail().getCurrent() != null ) {
		progress += "..." + Math.round( item.getProgressDetail().getCurrent() * 100 / item.getProgressDetail().getTotal() ) + "%";
	}

	if ( item.getErrorDetail() != null ) {
		System.err.println( item.getErrorDetail().getMessage() );
	} else {

		System.out.println( progress );
	}
}

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

示例4: ensureImage

import com.github.dockerjava.api.model.PullResponseItem; //导入依赖的package包/类
public static void ensureImage(String imageName) {
    List<Image> images = dockerClient.listImagesCmd().withImageNameFilter(imageName).exec();
    if (images.isEmpty()){
        logger.info("Pulling docker image from Docker Hub ...");
        // FIXME: Figure out how image tags should work
        dockerClient.pullImageCmd(imageName).withTag("latest")
                .exec(new PullImageResultCallback(){
                    @Override
                    public void onNext(PullResponseItem item) {
                        super.onNext(item);
                        logger.debug(item.toString());
                    }
                })
                .awaitSuccess();
        logger.info("Finished pulling docker image.");
    }
}

开发者ID:b-long，项目名称:jedi，代码行数:18，代码来源:ContainerUtils.java

示例5: pull

import com.github.dockerjava.api.model.PullResponseItem; //导入依赖的package包/类
public void pull(InstanceStartRequest request, InstanceStartResponse response) {
    try {
        dockerClient.pullImageCmd(request.getRepository()).exec(new PullImageResultCallback() {
            @Override
            public void onNext(PullResponseItem item) {
                super.onNext(item);
                if (logger.isDebugEnabled()) {
                    logger.debug(item);
                }
            }
        }).awaitSuccess();
        response.success();
    } catch (Exception e) {
        response.fail(e.toString());
        logger.error(String.format("error pullImage: %s", request), e);
    }
}

开发者ID:dianping，项目名称:Dolphin，代码行数:18，代码来源:DockerImageServiceImpl.java

示例6: callbackNotifier

import com.github.dockerjava.api.model.PullResponseItem; //导入依赖的package包/类
@Override
protected AbstractCallbackNotifier<PullResponseItem> callbackNotifier(PullImageCmd command,
        ResultCallback<PullResponseItem> resultCallback) {

    WebTarget webResource = getBaseResource().path("/images/create").queryParam("tag", command.getTag())
            .queryParam("fromImage", command.getRepository()).queryParam("registry", command.getRegistry());

    LOGGER.trace("POST: {}", webResource);
    Builder builder = resourceWithOptionalAuthConfig(command.getAuthConfig(), webResource.request()).accept(
            MediaType.APPLICATION_OCTET_STREAM_TYPE);

    return new POSTCallbackNotifier<PullResponseItem>(new JsonStreamProcessor<PullResponseItem>(
            PullResponseItem.class), resultCallback, builder, entity(null, MediaType.APPLICATION_JSON));
}

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

示例7: execute0

import com.github.dockerjava.api.model.PullResponseItem; //导入依赖的package包/类
@Override
protected Void execute0(PullImageCmd command, ResultCallback<PullResponseItem> resultCallback) {

    WebTarget webResource = getBaseResource().path("/images/create").queryParam("tag", command.getTag())
            .queryParam("fromImage", command.getRepository()).queryParam("registry", command.getRegistry());

    LOGGER.trace("POST: {}", webResource);
    resourceWithOptionalAuthConfig(command.getAuthConfig(), webResource.request()).accept(MediaType.APPLICATION_OCTET_STREAM).post(
            null, new TypeReference<PullResponseItem>() {
            }, resultCallback);

    return null;
}

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

示例8: checkDockerSwarmPullSuccessful

import com.github.dockerjava.api.model.PullResponseItem; //导入依赖的package包/类
private void checkDockerSwarmPullSuccessful() {
    if (results.isEmpty()) {
        throw new DockerClientException("Could not pull image through Docker Swarm");
    } else {
        boolean pullFailed = false;
        StringBuilder sb = new StringBuilder();

        for (PullResponseItem pullResponseItem : results.values()) {
            if (!pullResponseItem.isPullSuccessIndicated()) {
                pullFailed = true;
                sb.append("[" + pullResponseItem.getId() + ":" + messageFromPullResult(pullResponseItem) + "]");
            }
        }

        if (pullFailed) {
            throw new DockerClientException("Could not pull image: " + sb.toString());
        }
    }
}

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

示例9: pullImage

import com.github.dockerjava.api.model.PullResponseItem; //导入依赖的package包/类
void pullImage(DockerAPI api, TaskListener listener) throws IOException, InterruptedException {

        String image = getFullImageId();
        final DockerClient client = api.getClient();

        if (pullStrategy.shouldPullImage(client, image)) {
            // TODO create a FlyWeightTask so end-user get visibility on pull operation progress
            LOGGER.info("Pulling image '{}'. This may take awhile...", image);

            long startTime = System.currentTimeMillis();

            PullImageCmd cmd =  client.pullImageCmd(image);
            final DockerRegistryEndpoint registry = getRegistry();
            DockerCloud.setRegistryAuthentication(cmd, registry, Jenkins.getInstance());
            cmd.exec(new PullImageResultCallback() {
                @Override
                public void onNext(PullResponseItem item) {
                    listener.getLogger().println(item.getStatus());
                }
            }).awaitCompletion();

            try {
                client.inspectImageCmd(image).exec();
            } catch (NotFoundException e) {
                throw new DockerClientException("Could not pull image: " + image, e);
            }

            long pullTime = System.currentTimeMillis() - startTime;
            LOGGER.info("Finished pulling image '{}', took {} ms", image, pullTime);
        }

    }

开发者ID:jenkinsci，项目名称:docker-plugin，代码行数:33，代码来源:DockerTemplate.java

示例10: createContainer

import com.github.dockerjava.api.model.PullResponseItem; //导入依赖的package包/类
private CreateContainerResponse createContainer(@NonNull final DockerClient _dockerClient,
                                                @NonNull final String _dispatcher) {
    synchronized(this) {
        if (_dockerClient.listImagesCmd().withImageNameFilter(_dispatcher).exec().isEmpty()) {
            log.info("Image '" + _dispatcher + "' not found. Please wait while pulling from main repository...");

            boolean success = false;

            try {
                success = _dockerClient.pullImageCmd(_dispatcher)
                        .exec(new PullImageResultCallback() {
                            @Override
                            public void onNext(PullResponseItem item) {
                                //System.out.println("" + item);
                                super.onNext(item);
                            }
                        })
                        .awaitCompletion(5, TimeUnit.MINUTES);
            } catch (InterruptedException _e) {
                // ignore
            }

            if (!success) {
                throw new RuntimeException("Unable to retrieve image:" + _dispatcher);
            }
        } else {
            log.debug("Image found.");
        }
    }

    return _dockerClient
            .createContainerCmd(_dispatcher)
            .withEntrypoint("/bin/sh")
            .withTty(true)
            .exec();
}

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

示例11: onNext

import com.github.dockerjava.api.model.PullResponseItem; //导入依赖的package包/类
@Override
public void onNext(PullResponseItem item) {
    // only do it once
    if (results == null && latestItem == null) {
        checkForDockerSwarmResponse(item);
    }

    if (isSwarm) {
        handleDockerSwarmResponse(item);
    } else {
        handleDockerClientResponse(item);
    }

    LOGGER.debug(item.toString());
}

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

示例12: handleDockerSwarmResponse

import com.github.dockerjava.api.model.PullResponseItem; //导入依赖的package包/类
private void handleDockerSwarmResponse(final PullResponseItem item) {
    if (results == null) {
        results = new HashMap<>();
    }

    // Swarm terminates a pull sometimes with an empty line.
    // Therefore keep first success message
    PullResponseItem currentItem = results.get(item.getId());
    if (currentItem == null || !currentItem.isPullSuccessIndicated()) {
        results.put(item.getId(), item);
    }
}

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

示例13: processEmptyJson

import com.github.dockerjava.api.model.PullResponseItem; //导入依赖的package包/类
@Test
public void processEmptyJson() throws Exception {

    InputStream response = new ByteArrayInputStream("{}".getBytes());

    JsonStreamProcessor<PullResponseItem> jsonStreamProcessor = new JsonStreamProcessor<PullResponseItem>(PullResponseItem.class);

    final List<Boolean> completed = new ArrayList<Boolean>();

    jsonStreamProcessor.processResponseStream(response, new ResultCallback<PullResponseItem>() {

        @Override
        public void close() throws IOException {
        }

        @Override
        public void onStart(Closeable closeable) {
        }

        @Override
        public void onNext(PullResponseItem object) {
            assertFalse("onNext called for empty json", true);
        }

        @Override
        public void onError(Throwable throwable) {
        }

        @Override
        public void onComplete() {
            completed.add(true);
        }
    });

    assertFalse("Stream processing not completed", completed.isEmpty());
}

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

示例14: onNext

import com.github.dockerjava.api.model.PullResponseItem; //导入依赖的package包/类
@Override
public void onNext(PullResponseItem item) {
    this.latestItem = item;
    LOGGER.debug(item.toString());
}

开发者ID:fabzo，项目名称:kraken，代码行数:6，代码来源:NoLogPullImageResultCallback.java

示例15: checkForDockerSwarmResponse

import com.github.dockerjava.api.model.PullResponseItem; //导入依赖的package包/类
private void checkForDockerSwarmResponse(PullResponseItem item) {
    if (item.getStatus().matches("Pulling\\s.+\\.{3}$")) {
        isSwarm = true;
        LOGGER.debug("Communicating with Docker Swarm.");
    }
}

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

示例16: handleDockerClientResponse

import com.github.dockerjava.api.model.PullResponseItem; //导入依赖的package包/类
private void handleDockerClientResponse(PullResponseItem item) {
    latestItem = item;
}

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

示例17: messageFromPullResult

import com.github.dockerjava.api.model.PullResponseItem; //导入依赖的package包/类
private String messageFromPullResult(PullResponseItem pullResponseItem) {
    return (pullResponseItem.getError() != null) ? pullResponseItem.getError() : pullResponseItem.getStatus();
}

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

示例18: exec

import com.github.dockerjava.api.model.PullResponseItem; //导入依赖的package包/类
public Void exec(PullImageCmd command, ResultCallback<PullResponseItem> resultCallback) {
    return null;
}

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

注：本文中的com.github.dockerjava.api.model.PullResponseItem类示例整理自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 DynamicConfiguration类代码示例发布时间：2022-05-22

Java GeocoderStatus类代码示例发布时间：2022-05-22

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

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

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

阅读：18257|2023-10-27

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

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

阅读：9673|2022-11-06

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

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

阅读：8175|2022-11-06

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

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

阅读：8547|2022-11-06

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

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

阅读：8455|2022-11-06

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

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

阅读：9387|2022-11-06

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

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

阅读：8427|2022-11-06

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

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

阅读：7861|2022-11-06

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

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

阅读：8411|2022-11-06

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

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

阅读：7394|2022-11-06

客服电话

电子邮件

Java PullResponseItem类代码示例

示例1: call

示例2: onNext

示例3: onNext

示例4: ensureImage

示例5: pull

示例6: callbackNotifier

示例7: execute0

示例8: checkDockerSwarmPullSuccessful

示例9: pullImage

示例10: createContainer

示例11: onNext

示例12: handleDockerSwarmResponse

示例13: processEmptyJson

示例14: onNext

示例15: checkForDockerSwarmResponse

示例16: handleDockerClientResponse

示例17: messageFromPullResult

示例18: exec

请发表评论

全部评论

上一篇：

下一篇：

dphi-official/Machine_Learning_Bootcamp

juven/maven-bash-completion: Maven Bash

win7系统注册表编辑器打开的操作方法

route101/mastoinker: Quick image view as

CVE-2022-21509

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

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

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053