Java Quantity类代码示例

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

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

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

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

示例1: loadsFromYaml

import io.fabric8.kubernetes.api.model.Quantity; //导入依赖的package包/类
@Test
public void loadsFromYaml() throws Exception {
  RunEnvironment env = fromYaml("/minimal-pod.yaml");
  Pod pod = createPod(env);

  assertThat(pod.getSpec().getRestartPolicy(), is("Never"));

  Container container = findHypeRunContainer(pod);
  assertThat(container.getImage(), is("busybox:1"));
  assertThat(container.getImagePullPolicy(), is("Always"));
  assertThat(container.getEnv(), hasItems(envVar("EXAMPLE", "my-env-value")));

  ResourceRequirements resources = container.getResources();
  assertThat(resources.getRequests(), hasEntry("cpu", new Quantity("100m")));
  assertThat(resources.getLimits(), hasEntry("memory", new Quantity("1Gi")));
}

开发者ID:spotify，项目名称:hype，代码行数:17，代码来源:KubernetesDockerRunnerTest.java

示例2: build

import io.fabric8.kubernetes.api.model.Quantity; //导入依赖的package包/类
@Override
public PersistentVolumeClaim build() {
	ObjectMetaBuilder meta = new ObjectMetaBuilder()
			.withName(getName());

	return new PersistentVolumeClaimBuilder()
			.withMetadata(metadataBuilder().build())

			// spec
			.withNewSpec()
			.withAccessModes(accessMode.toString())
			.withNewResources()
			.withRequests(Collections.singletonMap("storage", new Quantity(storageRequest)))
			.endResources()
			.endSpec()

			// build
			.build();
}

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

示例3: shouldConfigureResourceRequirements

import io.fabric8.kubernetes.api.model.Quantity; //导入依赖的package包/类
@Test
public void shouldConfigureResourceRequirements() throws IOException, IsClosedException {
  final String memRequest = "17Mi";
  final String memLimit = "4711Mi";
  final Pod pod = KubernetesDockerRunner.createPod(WORKFLOW_INSTANCE, RunSpec.builder()
      .executionId("eid1")
      .imageName("busybox")
      .memRequest(memRequest)
      .memLimit(memLimit)
      .build(),
      EMPTY_SECRET_SPEC);

  final ResourceRequirements resourceReqs = pod.getSpec().getContainers().get(0).getResources();
  assertThat(resourceReqs.getRequests().get("memory"), is(new Quantity(memRequest)));
  assertThat(resourceReqs.getLimits().get("memory"), is(new Quantity(memLimit)));
}

开发者ID:spotify，项目名称:styx，代码行数:17，代码来源:KubernetesDockerRunnerTest.java

示例4: deduceResourceRequests

import io.fabric8.kubernetes.api.model.Quantity; //导入依赖的package包/类
/**
 * Get the resource requests for the deployment request. Resource requests are guaranteed by the Kubernetes
 * runtime.
 * Falls back to the server properties if not present in the deployment request.
 *
 * @param request    The deployment properties.
 */
protected Map<String, Quantity> deduceResourceRequests(AppDeploymentRequest request) {
	String memOverride = request.getDeploymentProperties().get("spring.cloud.deployer.kubernetes.requests.memory");
	if (memOverride == null) {
		memOverride = properties.getRequests().getMemory();
	}

	String cpuOverride = request.getDeploymentProperties().get("spring.cloud.deployer.kubernetes.requests.cpu");
	if (cpuOverride == null) {
		cpuOverride = properties.getRequests().getCpu();
	}

	logger.debug("Using requests - cpu: " + cpuOverride + " mem: " + memOverride);

	Map<String,Quantity> requests = new HashMap<String, Quantity>();
	if (memOverride != null) {
		requests.put("memory", new Quantity(memOverride));
	}
	if (cpuOverride != null) {
		requests.put("cpu", new Quantity(cpuOverride));
	}
	return requests;
}

开发者ID:spring-cloud，项目名称:spring-cloud-deployer-kubernetes，代码行数:30，代码来源:AbstractKubernetesDeployer.java

示例5: newPod

import io.fabric8.kubernetes.api.model.Quantity; //导入依赖的package包/类
/** Returns new instance of {@link Pod} with given name and command. */
private Pod newPod(String podName, String[] command) {
  final Container container =
      new ContainerBuilder()
          .withName(podName)
          .withImage(jobImage)
          .withImagePullPolicy(IMAGE_PULL_POLICY)
          .withCommand(command)
          .withVolumeMounts(newVolumeMount(pvcName, JOB_MOUNT_PATH, null))
          .withNewResources()
          .withLimits(singletonMap("memory", new Quantity(jobMemoryLimit)))
          .endResources()
          .build();
  return new PodBuilder()
      .withNewMetadata()
      .withName(podName)
      .endMetadata()
      .withNewSpec()
      .withContainers(container)
      .withVolumes(newVolume(pvcName, pvcName))
      .withRestartPolicy(POD_RESTART_POLICY)
      .endSpec()
      .build();
}

开发者ID:eclipse，项目名称:che，代码行数:25，代码来源:PVCSubPathHelper.java

示例6: mockPod

import io.fabric8.kubernetes.api.model.Quantity; //导入依赖的package包/类
private static Pod mockPod(String machineName, long ramLimit) {
  final String containerName = "container_" + machineName;
  final Container containerMock = mock(Container.class);
  final ResourceRequirements resourcesMock = mock(ResourceRequirements.class);
  final Quantity quantityMock = mock(Quantity.class);
  final Pod podMock = mock(Pod.class);
  final PodSpec specMock = mock(PodSpec.class);
  final ObjectMeta metadataMock = mock(ObjectMeta.class);
  when(podMock.getSpec()).thenReturn(specMock);
  when(podMock.getMetadata()).thenReturn(metadataMock);
  when(quantityMock.getAmount()).thenReturn(String.valueOf(ramLimit));
  when(resourcesMock.getLimits()).thenReturn(ImmutableMap.of("memory", quantityMock));
  when(containerMock.getName()).thenReturn(containerName);
  when(containerMock.getResources()).thenReturn(resourcesMock);
  when(metadataMock.getAnnotations())
      .thenReturn(
          ImmutableMap.of(format(MACHINE_NAME_ANNOTATION_FMT, containerName), machineName));
  when(specMock.getContainers()).thenReturn(ImmutableList.of(containerMock));
  return podMock;
}

开发者ID:eclipse，项目名称:che，代码行数:21，代码来源:OpenShiftEnvironmentFactoryTest.java

示例7: createClaim

import io.fabric8.kubernetes.api.model.Quantity; //导入依赖的package包/类
private PersistentVolumeClaim createClaim(VolumeRequest volumeRequest) {
  final ClaimRequest spec = volumeRequest.spec();

  if (spec.useExisting()) {
    final String claimName = volumeRequest.id();
    final PersistentVolumeClaim existingClaim =
        client.persistentVolumeClaims().withName(claimName).get();

    if (existingClaim != null) {
      return existingClaim;
    }
  }

  final ResourceRequirements resources = new ResourceRequirementsBuilder()
      .addToRequests("storage", new Quantity(spec.size()))
      .build();

  final PersistentVolumeClaim claimTemplate = new PersistentVolumeClaimBuilder()
      .withNewMetadata()
      .withName(volumeRequest.id())
      .addToAnnotations(STORAGE_CLASS_ANNOTATION, spec.storageClass())
      .endMetadata()
      .withNewSpec()
      // todo: storageClassName: <class> // in 1.6
      .withAccessModes(READ_WRITE_ONCE, READ_ONLY_MANY)
      .withResources(resources)
      .endSpec()
      .build();

  final PersistentVolumeClaim claim = client.persistentVolumeClaims().create(claimTemplate);
  LOG.info("Created PersistentVolumeClaim {} for {}",
      claim.getMetadata().getName(),
      volumeRequest);

  return claim;
}

开发者ID:spotify，项目名称:hype，代码行数:37，代码来源:VolumeRepository.java

示例8: setsResourceRequests

import io.fabric8.kubernetes.api.model.Quantity; //导入依赖的package包/类
@Test
public void setsResourceRequests() throws Exception {
  RunEnvironment env = environment()
      .withRequest(CPU.of("250m"))
      .withRequest(MEMORY.of("2Gi"))
      .withRequest("gpu", "2");
  Pod pod = createPod(env);

  Container container = findHypeRunContainer(pod);
  ResourceRequirements resources = container.getResources();
  assertThat(resources.getRequests(), hasEntry("cpu", new Quantity("250m")));
  assertThat(resources.getRequests(), hasEntry("memory", new Quantity("2Gi")));
  assertThat(resources.getRequests(), hasEntry("gpu", new Quantity("2")));
}

开发者ID:spotify，项目名称:hype，代码行数:15，代码来源:KubernetesDockerRunnerTest.java

示例9: addsResourceRequestsWhenLoadedFromYaml

import io.fabric8.kubernetes.api.model.Quantity; //导入依赖的package包/类
@Test
public void addsResourceRequestsWhenLoadedFromYaml() throws Exception {
  RunEnvironment env = fromYaml("/minimal-pod.yaml")
      .withRequest(MEMORY.of("2Gi"))
      .withRequest("gpu", "2");
  Pod pod = createPod(env);

  Container container = findHypeRunContainer(pod);
  ResourceRequirements resources = container.getResources();
  assertThat(resources.getRequests(), hasEntry("cpu", new Quantity("100m")));
  assertThat(resources.getRequests(), hasEntry("memory", new Quantity("2Gi")));
  assertThat(resources.getRequests(), hasEntry("gpu", new Quantity("2")));
}

开发者ID:spotify，项目名称:hype，代码行数:14，代码来源:KubernetesDockerRunnerTest.java

示例10: overridesResourceRequestsWhenLoadedFromYaml

import io.fabric8.kubernetes.api.model.Quantity; //导入依赖的package包/类
@Test
public void overridesResourceRequestsWhenLoadedFromYaml() throws Exception {
  RunEnvironment env = fromYaml("/minimal-pod.yaml")
      .withRequest(CPU.of("250m"));
  Pod pod = createPod(env);

  Container container = findHypeRunContainer(pod);
  ResourceRequirements resources = container.getResources();
  assertThat(resources.getRequests(), hasEntry("cpu", new Quantity("250m")));
}

开发者ID:spotify，项目名称:hype，代码行数:11，代码来源:KubernetesDockerRunnerTest.java

示例11: createsNewVolumeClaim

import io.fabric8.kubernetes.api.model.Quantity; //导入依赖的package包/类
@Test
public void createsNewVolumeClaim() throws Exception {
  VolumeRequest request = VolumeRequest.volumeRequest("storage-class-name", "16Gi");
  PersistentVolumeClaim claim = volumeRepository.getClaim(request);

  assertThat(claim.getMetadata().getName(), equalTo(request.id()));
  assertThat(
      claim.getMetadata().getAnnotations(),
      hasEntry(VolumeRepository.STORAGE_CLASS_ANNOTATION, "storage-class-name"));
  assertThat(claim.getSpec().getAccessModes(), contains("ReadWriteOnce", "ReadOnlyMany"));
  assertThat(
      claim.getSpec().getResources().getRequests(),
      hasEntry("storage", new Quantity("16Gi")));
}

开发者ID:spotify，项目名称:hype，代码行数:15，代码来源:VolumeRepositoryTest.java

示例12: createWhenExistingClaimNotFound

import io.fabric8.kubernetes.api.model.Quantity; //导入依赖的package包/类
@Test
public void createWhenExistingClaimNotFound() throws Exception {
  VolumeRequest request = VolumeRequest.createIfNotExists("new-claim", "class", "16Gi");
  PersistentVolumeClaim claim = volumeRepository.getClaim(request);

  assertThat(claim, not(mockPvc));
  assertThat(
      claim.getSpec().getResources().getRequests(),
      hasEntry("storage", new Quantity("16Gi")));
}

开发者ID:spotify，项目名称:hype，代码行数:11，代码来源:VolumeRepositoryTest.java