Java RestartPolicy类代码示例

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

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

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

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

示例1: toRestartPolicy

import com.github.dockerjava.api.model.RestartPolicy; //导入依赖的package包/类
private static final RestartPolicy toRestartPolicy(
    org.arquillian.cube.docker.impl.client.config.RestartPolicy restart) {
    if (restart.getName() != null) {
        String name = restart.getName();

        if ("failure".equals(name)) {
            return RestartPolicy.onFailureRestart(restart.getMaximumRetryCount());
        } else {
            if ("restart".equals(name)) {
                return RestartPolicy.alwaysRestart();
            } else {
                return RestartPolicy.noRestart();
            }
        }
    } else {
        return RestartPolicy.noRestart();
    }
}

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

示例2: setRestartPolicy

import com.github.dockerjava.api.model.RestartPolicy; //导入依赖的package包/类
private void setRestartPolicy(Instance instance, RestartPolicy restartPolicy) {
    if (restartPolicy == null || StringUtils.isEmpty(restartPolicy.getName())) {
        return;
    }

    io.cattle.platform.core.addon.RestartPolicy rp = new io.cattle.platform.core.addon.RestartPolicy();
    rp.setMaximumRetryCount(restartPolicy.getMaximumRetryCount());
    rp.setName(restartPolicy.getName());
    setField(instance, FIELD_RESTART_POLICY, rp);
}

开发者ID:rancher，项目名称:cattle，代码行数:11，代码来源:DockerTransformerImpl.java

示例3: verify_container_with_user

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

	String imageName = BUSY_BOX;
	loadImageIfNeeded( imageName );
	String containerName = "/junit-container-with-user-"
			+ LocalDateTime.now().format( DateTimeFormatter.ofPattern( "MMM.d-HH.mm.ss" ) );

	CreateContainerResponse createResponse = dockerClient.createContainerCmd( imageName )
		.withName( containerName )
		.withWorkingDir( "/" )
		.withRestartPolicy( RestartPolicy.onFailureRestart( 3 ) )
		.withUser( "1001:1001" ) // uid:gid
		// .withCmd( "ls", "-l" )
		.withCmd( "id" )
		.exec();

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

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

	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( "id command output" )
		.contains( "uid=1001 gid=1001" );

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

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

}

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

示例4: createContainer

import com.github.dockerjava.api.model.RestartPolicy; //导入依赖的package包/类
/**
	 * creates {@link Container}
	 * 
	 * @param element - {@link Element}
	 * @param host - host ip address
	 * @return id of created {@link Container}
	 * @throws Exception
	 */
	public String createContainer(Element element, String host) throws Exception {
		RestartPolicy restartPolicy = RestartPolicy.onFailureRestart(10);

		Ports portBindings = new Ports();
		List<ExposedPort> exposedPorts = new ArrayList<>();
		if (element.getPortMappings() != null)
			element.getPortMappings().forEach(mapping -> {
				ExposedPort internal = ExposedPort.tcp(Integer.parseInt(mapping.getInside()));
				Ports.Binding external = Ports.Binding(Integer.parseInt(mapping.getOutside()));
				portBindings.bind(internal, external);
				exposedPorts.add(internal);
			});
		String[] extraHosts = { host };
		
		Map<String, String> containerLogConfig = new HashMap<String, String>();
		int logFiles = 1; 
		if (element.getLogSize() > 2)
			logFiles = (int) (element.getLogSize() / 2); 

		containerLogConfig.put("max-file", String.valueOf(logFiles));
		containerLogConfig.put("max-size", "2m");
		LogConfig containerLog = new LogConfig(LogConfig.LoggingType.DEFAULT, containerLogConfig);
		
		CreateContainerCmd cmd = dockerClient.createContainerCmd(element.getImageName())
				.withLogConfig(containerLog)
				.withCpuset("0")
				.withExposedPorts(exposedPorts.toArray(new ExposedPort[0]))
				.withPortBindings(portBindings)
				.withEnv("SELFNAME=" + element.getElementId())
				.withName(element.getElementId())
				.withRestartPolicy(restartPolicy);
//		if (element.getImageName().startsWith("iotracks/catalog:core-networking"))
//			cmd = cmd.withMemoryLimit(256 * Constants.MiB);
		if (StringUtil.isNullOrEmpty(host))
			cmd = cmd.withNetworkMode("host").withPrivileged(true);
		else
			cmd = cmd.withExtraHosts(extraHosts);
		CreateContainerResponse resp = cmd.exec();
		return resp.getId();
	}

开发者ID:iotracks，项目名称:iofabric，代码行数:49，代码来源:DockerUtil.java

示例5: call

import com.github.dockerjava.api.model.RestartPolicy; //导入依赖的package包/类
public String call() throws Exception {
    DockerClient client = DockerCommand.getClient(descriptor, cfgData.dockerUrlRes, cfgData.dockerVersionRes, cfgData.dockerCertPathRes, null);
    
    CreateContainerCmd cfgCmd = client.createContainerCmd(imageRes);
    if (commandRes != null) {
        cfgCmd.withCmd(commandRes);
    }
    cfgCmd.withHostName(hostNameRes);
    cfgCmd.withName(containerNameRes);
    HostConfig hc = new HostConfig();
    cfgCmd.withLinks(LinkUtils.parseLinks(linksRes).getLinks());
    if (envVarsRes != null) {
        cfgCmd.withEnv(envVarsRes);
    }
    if (exposedPortsRes != null && !exposedPortsRes.isEmpty()) {
    	final ExposedPort[] ports;
        String[] exposedPortsSplitted = exposedPortsRes.split(",");
        ports = new ExposedPort[exposedPortsSplitted.length];
        for (int i = 0; i < ports.length; i++) {
            ports[i] = ExposedPort.parse(exposedPortsSplitted[i]);
        }

    	cfgCmd.withExposedPorts(ports);
    }
    if (cpuSharesRes != null) {
        cfgCmd.withCpuShares(cpuSharesRes);
    }
    if (memoryLimitRes != null) {
        cfgCmd.withMemory(memoryLimitRes);
    }
    if (dnsRes != null) {
        cfgCmd.withDns(dnsRes);
    }
    if (extraHostsRes != null) {
        cfgCmd.withExtraHosts(extraHostsRes);
    }
    if (portBindingsRes != null) {
        cfgCmd.withPortBindings(PortBindingParser.parse(portBindingsRes));
    }
    if (bindMountsRes != null) {
        cfgCmd.withBinds(BindParser.parse(bindMountsRes));
    }
    if (alwaysRestart) {
        cfgCmd.withRestartPolicy(RestartPolicy.alwaysRestart());
    }
    
    CreateContainerResponse resp = cfgCmd.withPublishAllPorts(publishAllPorts).withPrivileged(privileged).exec();
    InspectContainerResponse inspectResp = client.inspectContainerCmd(resp.getId()).exec();
    
    ObjectMapper mapper = new ObjectMapper();
    String serialized = mapper.writeValueAsString(inspectResp);
    return serialized;
}

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

示例6: getRestartPolicy

import com.github.dockerjava.api.model.RestartPolicy; //导入依赖的package包/类
@CheckForNull
RestartPolicy getRestartPolicy();

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

示例7: getRestartPolicy

import com.github.dockerjava.api.model.RestartPolicy; //导入依赖的package包/类
@Override
@JsonIgnore
public RestartPolicy getRestartPolicy() {
    return hostConfig.getRestartPolicy();
}

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

示例8: withRestartPolicy

import com.github.dockerjava.api.model.RestartPolicy; //导入依赖的package包/类
@Override
public CreateContainerCmd withRestartPolicy(RestartPolicy restartPolicy) {
    checkNotNull(restartPolicy, "restartPolicy was not specified");
    this.hostConfig.withRestartPolicy(restartPolicy);
    return this;
}

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

示例9: startContainerWithRestartPolicy

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

    RestartPolicy restartPolicy = RestartPolicy.onFailureRestart(5);

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

    LOG.info("Created container {}", container.toString());

    assertThat(container.getId(), not(isEmptyString()));

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

    InspectContainerResponse inspectContainerResponse = dockerRule.getClient().inspectContainerCmd(container.getId()).exec();

    assertThat(inspectContainerResponse.getState().getRunning(), is(true));

    assertThat(inspectContainerResponse.getHostConfig().getRestartPolicy(), is(equalTo(restartPolicy)));
}

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

示例10: createContainerWithRestartPolicy

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

    RestartPolicy restartPolicy = RestartPolicy.onFailureRestart(5);

    CreateContainerResponse container = dockerRule.getClient().createContainerCmd(DEFAULT_IMAGE).withCmd("sleep", "9999")
            .withRestartPolicy(restartPolicy).exec();

    LOG.info("Created container {}", container.toString());

    assertThat(container.getId(), not(isEmptyString()));

    InspectContainerResponse inspectContainerResponse = dockerRule.getClient().inspectContainerCmd(container.getId()).exec();

    assertThat(inspectContainerResponse.getHostConfig().getRestartPolicy(), is(equalTo(restartPolicy)));
}

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

示例11: withRestartPolicy

import com.github.dockerjava.api.model.RestartPolicy; //导入依赖的package包/类
/**
 * Set custom {@link RestartPolicy} for the container. Defaults to {@link RestartPolicy#noRestart()}
 */
CreateContainerCmd withRestartPolicy(RestartPolicy restartPolicy);

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

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

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

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

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

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

阅读：18210|2023-10-27

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

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

阅读：9656|2022-11-06

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

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

阅读：8168|2022-11-06

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

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

阅读：8543|2022-11-06

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

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

阅读：8449|2022-11-06

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

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

阅读：9375|2022-11-06

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

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

阅读：8418|2022-11-06

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

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

阅读：7855|2022-11-06

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

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

阅读：8403|2022-11-06

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

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

阅读：7391|2022-11-06

客服电话

电子邮件

Java RestartPolicy类代码示例

示例1: toRestartPolicy

示例2: setRestartPolicy

示例3: verify_container_with_user

示例4: createContainer

示例5: call

示例6: getRestartPolicy

示例7: getRestartPolicy

示例8: withRestartPolicy

示例9: startContainerWithRestartPolicy

示例10: createContainerWithRestartPolicy

示例11: withRestartPolicy

请发表评论

全部评论

上一篇：

下一篇：

leafo/etlua: Embedded Lua templates

akexorcist/GoogleDirectionLibrary: [Andr

magnayn/Jenkins-Repository: Jenkins Mave

krishnaik06/Machine-Learning-in-90-days

sorainu-lab/mastodon: mofmof.coffee(mast

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

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

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053