io.fabric8.utils.Objects类的使用及代码示例

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

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

Objects介绍

[英]Some helper classes for objects comparing and equality
[中]一些用于对象比较和相等的帮助器类

代码示例

代码示例来源：origin: io.jenkins.updatebot/updatebot-core

  1. /**
  2.  * Returns true if this and that object have the same underlying status
  3.  */
  4. public boolean equalStatus(StatusInfo that) {
  5.   return Objects.equal(this.status, that.status) &&
  6.       Objects.equal(this.issueState, that.issueState) &&
  7.       Objects.equal(this.pullRequestState, that.pullRequestState);
  8. }

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

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

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

  1. /**
  2.  * Returns a client for the first working pod for the given service  or throws an assertion error if one could not be found
  3.  */
  4. public J4pClient assertClientForService(String serviceName, String namespace) {
  5.   J4pClient client = clientForService(serviceName, namespace);
  6.   assertNotNull(client, "No client for service: " + serviceName);
  7.   return client;
  8. }

代码示例来源：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: jenkinsci/kubernetes-pipeline-plugin

  1. String username = env.get(userEnvVar);
  2. if (io.fabric8.utils.Objects.equal("BUILD_URL", envVarName)) {
  3.   String jobUrl = projectConfig.getLink("Job");
  4.   if (Strings.isNullOrBlank(jobUrl)) {
  5.     String name = projectConfig.getBuildName();
  6.     if (Strings.isNullOrBlank(name)) {
  7.       if (Strings.isNotBlank(repoName)) {
  8.         name = repoName;
  9.         if (Strings.isNotBlank(username)) {
  10.     if (Strings.isNotBlank(name)) {
  11.       String jenkinsUrl = KubernetesHelper.getServiceURLInCurrentNamespace(getKubernetes(), ServiceNames.JENKINS, "http", null, true);
  12.       jobUrl = URLUtils.pathJoin(jenkinsUrl, "/job", name);
  13. } else if (io.fabric8.utils.Objects.equal("GIT_URL", envVarName)) {
  14.   String gitUrl = projectConfig.getLinks().get("Git");
  15.   if (Strings.isNullOrBlank(gitUrl)) {
  16. } else if (io.fabric8.utils.Objects.equal("GIT_COMMIT", envVarName)) {
  17.   String gitCommit = gitConfig.getCommit();
  18.   if (Strings.isNullOrBlank(gitCommit)) {
  19. } else if (io.fabric8.utils.Objects.equal("GIT_BRANCH", envVarName)) {
  20.   String gitBranch = gitConfig.getBranch();
  21.   if (Strings.isNullOrBlank(gitBranch)) {

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

  1. public static void substituteEnvironmentVariableExpressions(Map<String, String> map, Map<String, String> environmentVariables) {
  2.   Set<Map.Entry<String, String>> envEntries = environmentVariables.entrySet();
  3.   for (String key : map.keySet()) {
  4.     String text = map.get(key);
  5.     String oldText = text;
  6.     if (Strings.isNotBlank(text)) {
  7.       for (Map.Entry<String, String> envEntry : envEntries) {
  8.         String envKey = envEntry.getKey();
  9.         String envValue = envEntry.getValue();
  10.         if (Strings.isNotBlank(envKey) && Strings.isNotBlank(envValue)) {
  11.           text = text.replace("${env:" + envKey + "}", envValue);
  12.         }
  13.       }
  14.       if (!Objects.equal(oldText, text)) {
  15.         map.put(key, text);
  16.       }
  17.     }
  18.   }
  19. }

代码示例来源：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: fabric8io/jube

  1. protected static void createContainer(ProcessManager processManager, KubernetesModel model, Container container, Pod pod, PodStatus currentState) throws Exception {
  2.   String containerName = container.getName();
  3.   String image = container.getImage();
  4.   Strings.notEmpty(image);
  5.   OpenMavenURL mavenUrl = ImageMavenCoords.dockerImageToMavenURL(image);
  6.   Objects.notNull(mavenUrl, "mavenUrl");
  7.   InstallOptions.InstallOptionsBuilder builder = new InstallOptions.InstallOptionsBuilder().
  8.       url(mavenUrl).environment(envVarMap);
  9.   if (Strings.isNotBlank(containerName)) {
  10.     builder = builder.name(containerName).id(containerName);
  11.       LOG.debug("Cannot find image at {} - trying with default prefix", mavenUrl);
  12.       mavenUrl = ImageMavenCoords.dockerImageToMavenURL(image, true);
  13.       Objects.notNull(mavenUrl, "mavenUrl");
  14.       builder = new InstallOptions.InstallOptionsBuilder().
  15.           url(mavenUrl).environment(envVarMap);
  16.       if (Strings.isNotBlank(containerName)) {
  17.         builder = builder.name(containerName).id(containerName);
  18.     container.setEnv(createEnvironmentVariables(environment));
  19.     createInstallationPorts(environment, installation, container);
  20.     model.updatePod(getName(pod), pod);
  21.   } catch (Exception e) {
  22.     setPodTerminated(currentState, e);
  23.     System.out.println("ERROR: Failed to create pod: " + getName(pod) + ". " + e);
  24.     e.printStackTrace();
  25.     LOG.error("Failed to create pod: " + getName(pod) + ". " + e.getMessage(), e);

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

  1. /**
  2.  * Returns the maven plugin for the given artifact id or returns null if it cannot be found
  3.  */
  4. public static Plugin findPlugin(List<Plugin> plugins, String artifactId) {
  5.   if (plugins != null) {
  6.     for (Plugin plugin : plugins) {
  7.       String groupId = plugin.getGroupId();
  8.       if (Strings.isNullOrBlank(groupId) || Objects.equal(groupId, mavenPluginsGroupId)) {
  9.         if (Objects.equal(artifactId, plugin.getArtifactId())) {
  10.           return plugin;
  11.         }
  12.       }
  13.     }
  14.   }
  15.   return null;
  16. }

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

  1. @Override
  2. public Result execute(UIExecutionContext context) throws Exception {
  3.   String buildConfigName = buildName.getValue();
  4.   Objects.assertNotNull(buildConfigName, "buildName");
  5.   Map<String, String> labels = BuildConfigs.createBuildLabels(buildConfigName);
  6.   String ouputImageName = imageName.getValue();
  7.   String gitUrlText = getOrFindGitUrl(context, gitUri.getValue());
  8.   String imageText = outputImage.getValue();
  9.   Model mavenModel = getMavenModel(context);
  10.   if (Strings.isNullOrBlank(imageText) && mavenModel != null) {
  11.     imageText = mavenModel.getProperties().getProperty("docker.image");
  12.   }
  13.   String webhookSecretText = webHookSecret.getValue();
  14.   if (Strings.isNullOrBlank(webhookSecretText)) {
  15.     // TODO generate a really good secret!
  16.     webhookSecretText = "secret101";
  17.   }
  18.   BuildConfig buildConfig = BuildConfigs.createBuildConfig(buildConfigName, labels, gitUrlText, ouputImageName, imageText, webhookSecretText);
  19.   System.out.println("Generated BuildConfig: " + toJson(buildConfig));
  20.   ImageStream imageRepository = BuildConfigs.imageRepository(buildConfigName, labels);
  21.   Controller controller = createController();
  22.   controller.applyImageStream(imageRepository, "generated ImageStream: " + toJson(imageRepository));
  23.   controller.applyBuildConfig(buildConfig, "generated BuildConfig: " + toJson(buildConfig));
  24.   return Results.success("Added BuildConfig: " + Builds.getName(buildConfig) + " to OpenShift at master: " + getKubernetes().getMasterUrl());
  25. }

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

  1. if (Strings.isNullOrBlank(serviceId)) {
  2.   return null;
  3. Objects.notNull(beanServer, "MBeanServer");
  4. if (!beanServer.isRegistered(KUBERNETES_OBJECT_NAME)) {
  5.   LOG.warn("No MBean is available for: " + KUBERNETES_OBJECT_NAME);

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

  1. @Override
  2. public Node node(@NotNull String name) {
  3.   NodeList minionList = getNodes();
  4.   List<Node> minions = notNullList(minionList.getItems());
  5.   for (Node minion : minions) {
  6.     if (Objects.equal(getName(minion), name)) {
  7.       return minion;
  8.     }
  9.   }
  10.   return null;
  11. }

代码示例来源：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");
  5.   String namespace = KubernetesHelper.getNamespace(pod);
  6.   if (Strings.isBlank(namespace)) {
  7.     getOrCreateMetadata(pod).setNamespace(DEFAULT_NAMESPACE);
  8.   final List<Container> containers = KubernetesHelper.getContainers(pod);

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

  1. list.add(pod);
  2. List<Container> containers = KubernetesHelper.getContainers(podTemplateSpec);
  3. for (Container container : containers) {
  4.   String containerName = getName(pod) + "-" + container.getName();
  5.   Objects.notNull(currentState, "currentState");
  6.   currentState.setHostIP(host);
  7.   getOrCreateMetadata(pod).setLabels(KubernetesHelper.getLabels(podTemplate.getMetadata()));

代码示例来源：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: io.fabric8/gateway-core

  1. List<String> urlStrings = serviceDetails.getServices();
  2. for (String urlString : urlStrings) {
  3.   if (Strings.notEmpty(urlString)) {
  4.       if (Objects.equal(protocol, urlProtocol)) {
  5.         Handler<AsyncResult<NetSocket>> handler = new Handler<AsyncResult<NetSocket>>() {
  6.           public void handle(final AsyncResult<NetSocket> asyncSocket) {

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

  1. @Override
  2. public Boolean call() throws Exception {
  3.   boolean result = true;
  4.   List<Pod> pods = kubernetesClient.getPods(session.getNamespace()).getItems();
  5.   if (pods.isEmpty()) {
  6.     result = false;
  7.     session.getLogger().warn("No pods are available yet, waiting...");
  8.   }
  9.   for (Pod pod : pods) {
  10.     result = result && Objects.equal(PodStatus.OK, KubernetesHelper.getPodStatus(pod));
  11.     if (!result) {
  12.       if (pod.getCurrentState().getInfo() != null) {
  13.         for (Map.Entry<String, ContainerStatus> entry : pod.getCurrentState().getInfo().entrySet()) {
  14.           String containerId = entry.getKey();
  15.           ContainerStatus status = entry.getValue();
  16.           if (status.getState().getWaiting() != null) {
  17.             session.getLogger().warn("Waiting for container:" + containerId + ". Reason:" + status.getState().getWaiting().getReason());
  18.           }
  19.         }
  20.       }
  21.     }
  22.   }
  23.   return result;
  24. }

代码示例来源：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: io.fabric8.forge/openshift

  1. @Override
  2. public Result execute(UIExecutionContext context) throws Exception {
  3.   String buildConfigName = buildName.getValue();
  4.   Objects.assertNotNull(buildConfigName, "buildName");
  5.   Map<String, String> labels = BuildConfigs.createBuildLabels(buildConfigName);
  6.   String gitUrlText = getOrFindGitUrl(context, gitUri.getValue());
  7.   String imageText = image.getValue();
  8.   List<EnvVar> envVars = createEnvVars(buildConfigName, gitUrlText, mavenCommand.getValue());
  9.   BuildConfig buildConfig = BuildConfigs.createIntegrationTestBuildConfig(buildConfigName, labels, gitUrlText, imageText, envVars);
  10.   System.out.println("Generated BuildConfig: " + toJson(buildConfig));
  11.   ImageStream imageRepository = BuildConfigs.imageRepository(buildConfigName, labels);
  12.   Controller controller = createController();
  13.   controller.applyImageStream(imageRepository, "generated ImageStream: " + toJson(imageRepository));
  14.   controller.applyBuildConfig(buildConfig, "generated BuildConfig: " + toJson(buildConfig));
  15.   return Results.success("Added BuildConfig: " + Builds.getName(buildConfig) + " to OpenShift at master: " + getKubernetes().getAddress());
  16. }

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

  1. public static <T extends Comparable<T>> int compare(List<T> a, List<T> b) {
  2.   if (a == b) {
  3.     return 0;
  4.   }
  5.   else if (a == null) {
  6.     return -1;
  7.   }
  8.   else if (b == null) {
  9.     return 1;
  10.   }
  11.   int size = a.size();
  12.   int answer = size - b.size();
  13.   if (answer == 0) {
  14.     for (int i = 0; i < size; i++) {
  15.       answer = compare(a.get(i), b.get(i));
  16.       if (answer != 0) {
  17.         break;
  18.       }
  19.     }
  20.   }
  21.   return answer;
  22. }

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

Objects

相关文章

    查看更多

    热门标签

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

    最新文章

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