io.fabric8.utils.Objects.notNull()方法的使用及代码示例

x33g5p2x  于2022-01-26 转载在 其他  
字(8.1k)|赞(0)|评价(0)|浏览(186)

本文整理了Java中io.fabric8.utils.Objects.notNull()方法的一些代码示例，展示了Objects.notNull()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Objects.notNull()方法的具体详情如下：
包路径：io.fabric8.utils.Objects
类名称：Objects
方法名：notNull

Objects.notNull介绍

[英]Asserts whether the value is not null
[中]断言该值是否为空

代码示例

代码示例来源：origin: fabric8io/jube

  1. protected String getMandatoryId(T entity) {
  2.   String id = entityModel.getId(entity);
  3.   Objects.notNull(id, "id for entity " + entity);
  4.   return id;
  5. }

代码示例来源：origin: io.fabric8/gateway-fabric

  1. @PostConstruct
  2. public void activate()  {
  3.   vertx = vertxFactory.createVertx();
  4.   Objects.notNull(vertx, "vertx");
  5. }

代码示例来源：origin: fabric8io/jube

  1. @Override
  2.   public File downloadContent(final OpenMavenURL sourceUrl, final File installDir) throws IOException {
  3.     Objects.notNull(sourceUrl, "sourceUrl");
  4.     // copy the URL to the install dir
  5.     File archive = new File(installDir, INSTALLED_BINARY);
  6.     InputStream from = sourceUrl.getInputStream(remoteRepositoryUrls);
  7.     if (from == null) {
  8.       throw new FileNotFoundException("Could not open URL: " + sourceUrl);
  9.     }
  10.     copy(from, new FileOutputStream(archive));
  11.     return archive;
  12.   }
  13. };

代码示例来源：origin: io.fabric8/taiga-api

  1. public static void addUser(ProjectDTO project, UserDTO user) {
  2.     if (user != null) {
  3.       Objects.notNull(project, "project");
  4.       List<UserDTO> users = project.getUsers();
  5.       if (users == null) {
  6.         users = new ArrayList<>();
  7.       }
  8.       users.add(user);
  9.       project.setUsers(users);
  10.     }
  11.   }
  12. }

代码示例来源：origin: io.fabric8/kubernetes-mbeans

  1. Objects.notNull(beanServer, "MBeanServer");
  2. if (!beanServer.isRegistered(KUBERNETES_OBJECT_NAME)) {
  3.   LOG.warn("No MBean is available for: " + KUBERNETES_OBJECT_NAME);

代码示例来源：origin: fabric8io/jube

  1. /**
  2.  * Returns the desired state; lazily creating one if required
  3.  */
  4. public static PodSpec getOrCreatePodSpec(Pod pod) {
  5.   Objects.notNull(pod, "pod");
  6.   PodSpec desiredState = pod.getSpec();
  7.   if (desiredState == null) {
  8.     desiredState = new PodSpec();
  9.     pod.setSpec(desiredState);
  10.   }
  11.   return desiredState;
  12. }

代码示例来源：origin: fabric8io/jube

  1. /**
  2.  * Returns the current state of the given pod; lazily creating one if required
  3.  */
  4. public static PodStatus getOrCreatetStatus(Pod pod) {
  5.   Objects.notNull(pod, "pod");
  6.   PodStatus currentState = pod.getStatus();
  7.   if (currentState == null) {
  8.     currentState = new PodStatus();
  9.     pod.setStatus(currentState);
  10.   }
  11.   return currentState;
  12. }

代码示例来源：origin: fabric8io/ipaas-quickstarts

  1. /**
  2.  * Iterates through all projects in the given github organisation and generates an archetype for it
  3.  */
  4. public void generateArchetypesFromGithubOrganisation(String githubOrg, File outputDir, List<String> dirs) throws IOException {
  5.   GitHub github = GitHub.connectAnonymously();
  6.   GHOrganization organization = github.getOrganization(githubOrg);
  7.   Objects.notNull(organization, "No github organisation found for: " + githubOrg);
  8.   Map<String, GHRepository> repositories = organization.getRepositories();
  9.   Set<Map.Entry<String, GHRepository>> entries = repositories.entrySet();
  10.   File cloneParentDir = new File(outputDir, "../git-clones");
  11.   if (cloneParentDir.exists()) {
  12.     Files.recursiveDelete(cloneParentDir);
  13.   }
  14.   for (Map.Entry<String, GHRepository> entry : entries) {
  15.     String repoName = entry.getKey();
  16.     GHRepository repo = entry.getValue();
  17.     String url = repo.getGitTransportUrl();
  18.     generateArchetypeFromGitRepo(outputDir, dirs, cloneParentDir, repoName, url, null);
  19.   }
  20. }

代码示例来源：origin: fabric8io/jube

  1. @Override
  2.   public String call() throws Exception {
  3.     System.out.println("Updating pod " + pod);
  4.     PodSpec desiredState = pod.getSpec();
  5.     Objects.notNull(desiredState, "desiredState");
  6.     PodStatus currentState = NodeHelper.getOrCreatetStatus(pod);
  7.     List<Container> containers = KubernetesHelper.getContainers(pod);
  8.     model.updatePod(podId, pod);
  9.     return NodeHelper.createMissingContainers(processManager, model, pod, currentState, containers);
  10.   }
  11. });

代码示例来源：origin: fabric8io/jube

  1. public ServiceInstance(Service service) {
  2.   this.service = service;
  3.   this.id = getName(service);
  4.   ServiceSpec spec = KubernetesHelper.getOrCreateSpec(service);
  5.   List<ServicePort> ports = spec.getPorts();
  6.   if (spec.getPortalIP().equals(HEADLESS_PORTAL_IP)) {
  7.     //do nothing service is headless
  8.   } else if (ports != null && !ports.isEmpty()) {
  9.     for (ServicePort servicePort : ports) {
  10.       servicePorts.add(toNamedServicePort(id, servicePort));
  11.     }
  12.   } else {
  13.     throw new IllegalArgumentException("Service: " + id + " doesn't have a valid port configuration.");
  14.   }
  15.   this.selector = KubernetesHelper.getSelector(service);
  16.   Objects.notNull(this.selector, "No selector for service " + id);
  17.   if (selector.isEmpty()) {
  18.     throw new IllegalArgumentException("Empty selector for service " + id);
  19.   }
  20.   this.filter = KubernetesHelper.createPodFilter(selector);
  21.   // TODO should we use some service metadata to choose the load balancer?
  22.   this.loadBalancer = new RoundRobinLoadBalancer();
  23. }

代码示例来源：origin: fabric8io/jube

  1. protected void unpackBaseImage(File buildDir, boolean useDefaultPrefix) throws Exception {
  2.   String imageName = project.getProperties().getProperty(DOCKER_BASE_IMAGE_PROPERTY);
  3.   Objects.notNull(imageName, DOCKER_BASE_IMAGE_PROPERTY);
  4.   ImageMavenCoords baseImageCoords = ImageMavenCoords.parse(imageName, useDefaultPrefix);
  5.   String coords = baseImageCoords.getAetherCoords();
  6.   Artifact artifact = repositorySystem.createArtifactWithClassifier(baseImageCoords.getGroupId(),
  7.       baseImageCoords.getArtifactId(), baseImageCoords.getVersion(), baseImageCoords.getType(),
  8.       baseImageCoords.getClassifier());
  9.   getLog().info("Resolving Jube image: " + artifact);
  10.   ArtifactResolutionRequest request = new ArtifactResolutionRequest();
  11.   request.setArtifact(artifact);
  12.   request.setLocalRepository(localRepository);
  13.   request.setRemoteRepositories(pomRemoteRepositories);
  14.   ArtifactResolutionResult result = artifactResolver.resolve(request);
  15.   if (!result.isSuccess()) {
  16.     throw new ArtifactNotFoundException("Cannot download Jube image", artifact);
  17.   }
  18.   getLog().info("Resolved Jube image: " + artifact);
  19.   if (artifact.getFile() != null) {
  20.     File file = artifact.getFile();
  21.     getLog().info("File: " + file);
  22.     if (!file.exists() || file.isDirectory()) {
  23.       throw new MojoExecutionException("Resolved file for " + coords + " is not a valid file: " + file.getAbsolutePath());
  24.     }
  25.     getLog().info("Unpacking base image " + file.getAbsolutePath() + " to build dir: " + buildDir);
  26.     Zips.unzip(new FileInputStream(file), buildDir);
  27.   }
  28. }

代码示例来源：origin: io.fabric8.forge/openshift

  1. public KubernetesClient getKubernetes() {
  2.   if (kubernetes == null) {
  3.     String kubernetesAddress = kubernetesUrl.getValue();
  4.     if (Strings.isNotBlank(kubernetesAddress)) {
  5.       kubernetes = new KubernetesClient(new KubernetesFactory(kubernetesAddress));
  6.     } else {
  7.       kubernetes = new KubernetesClient();
  8.     }
  9.   }
  10.   Objects.notNull(kubernetes, "kubernetes");
  11.   return kubernetes;
  12. }

代码示例来源：origin: funktionio/funktion-connectors

  1. public SubscribeResponse subscribe(SubscribeRequest request) throws InternalException {
  2.   String namespace = request.getNamespace();
  3.   Objects.notNull(namespace, "namespace");
  4.   ConfigMap configMap = createSubscriptionResource(request, namespace);
  5.   kubernetesClient.configMaps().inNamespace(namespace).create(configMap);
  6.   return new SubscribeResponse(namespace, KubernetesHelper.getName(configMap));
  7. }

代码示例来源：origin: funktionio/funktion-connectors

  1. Objects.notNull(funktion, "funktion");
  2. try {
  3.   String yaml = createYamlMapper().writeValueAsString(funktion);

代码示例来源：origin: io.fabric8.forge/devops

  1. public KubernetesClient getKubernetes() {
  2.   if (kubernetes == null) {
  3.     String kubernetesAddress = kubernetesUrl.getValue();
  4.     if (Strings.isNotBlank(kubernetesAddress)) {
  5.       kubernetes = new DefaultKubernetesClient(new ConfigBuilder().withMasterUrl(kubernetesAddress).build());
  6.     } else {
  7.       kubernetes = new DefaultKubernetesClient();
  8.     }
  9.   }
  10.   Objects.notNull(kubernetes, "kubernetes");
  11.   return kubernetes;
  12. }

代码示例来源：origin: fabric8io/jube

  1. public String updateLocalPod(@NotNull final String podId, final Pod pod) throws Exception {
  2.   System.out.println("Updating pod " + pod);
  3.   PodSpec desiredState = pod.getSpec();
  4.   Objects.notNull(desiredState, "desiredState");

代码示例来源：origin: fabric8io/jube

  1. Objects.notNull(currentState, "currentState");
  2. currentState.setHostIP(host);

代码示例来源：origin: fabric8io/jube

  1. Strings.notEmpty(image);
  2. OpenMavenURL mavenUrl = ImageMavenCoords.dockerImageToMavenURL(image);
  3. Objects.notNull(mavenUrl, "mavenUrl");
  4.     LOG.debug("Cannot find image at {} - trying with default prefix", mavenUrl);
  5.     mavenUrl = ImageMavenCoords.dockerImageToMavenURL(image, true);
  6.     Objects.notNull(mavenUrl, "mavenUrl");
  7.     builder = new InstallOptions.InstallOptionsBuilder().
  8.         url(mavenUrl).environment(envVarMap);

内容来源于网络，如有侵权，请联系作者删除！

Objects

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com