io.fabric8.kubernetes.client.dsl.Resource.replace()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(4.5k)|赞(0)|评价(0)|浏览(97)

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

Resource.replace介绍

暂无

代码示例

代码示例来源:origin: EnMasseProject/enmasse

existing.setCount(existing.getCount() + 1);
  existing.setLastTimestamp(timestamp);
  kubeClient.events().inNamespace(namespace).withName(eventName).replace(existing);
} else {
  Event newEvent = new EventBuilder()

代码示例来源:origin: EnMasseProject/enmasse

@Override
public boolean replaceAddressSpace(AddressSpace addressSpace) {
  ConfigMap newMap = null;
  try {
    String name = getConfigMapName(addressSpace.getMetadata().getNamespace(), addressSpace.getMetadata().getName());
    newMap = create(addressSpace);
    ConfigMap result;
    if (addressSpace.getMetadata().getResourceVersion() != null) {
      result = client.configMaps()
          .withName(name)
          .lockResourceVersion(addressSpace.getMetadata().getResourceVersion())
          .replace(newMap);
    } else {
      result = client.configMaps()
          .withName(name)
          .replace(newMap);
    }
    cache.replace(newMap);
    return result != null;
  } catch (KubernetesClientException e) {
    if (e.getStatus().getCode() == 404) {
      return false;
    } else {
      throw e;
    }
  }
}

代码示例来源:origin: fabric8io/fabric8-maven-plugin

metadata.setNamespace(namespace);
  metadata.setResourceVersion(resourceVersion);
  Object answer = openShiftClient.roleBindings().inNamespace(namespace).withName(id).replace(entity);
  logGeneratedEntity("Updated RoleBinding: ", namespace, entity, answer);
} catch (Exception e) {

代码示例来源:origin: EnMasseProject/enmasse

@Override
public boolean replaceAddress(Address address) {
  ConfigMap newMap = null;
  try {
    String name = getConfigMapName(address.getMetadata().getNamespace(), address.getMetadata().getName());
    newMap = create(address);
    ConfigMap result;
    if (address.getMetadata().getResourceVersion() != null) {
      result = client.configMaps()
          .withName(name)
          .lockResourceVersion(address.getMetadata().getResourceVersion())
          .replace(newMap);
    } else {
      result = client.configMaps()
          .withName(name)
          .replace(newMap);
    }
    cache.replace(newMap);
    return result != null;
  } catch (KubernetesClientException e) {
    if (e.getStatus().getCode() == 404) {
      return false;
    } else {
      throw e;
    }
  }
}

代码示例来源:origin: fabric8io/fabric8-maven-plugin

log.info("Updating " + kind + " from " + sourceName);
try {
  Object answer = resources.inNamespace(namespace).withName(id).replace(resource);
  logGeneratedEntity("Updated " + kind + ": ", namespace, resource, answer);
} catch (Exception e) {

代码示例来源:origin: fabric8io/fabric8-maven-plugin

} else {
  try {
    Object answer = openShiftClient.oAuthClients().withName(id).replace(entity);
    log.info("Updated OAuthClient result: " + answer);
  } catch (Exception e) {

代码示例来源:origin: fabric8io/fabric8-maven-plugin

log.info("Updating a ServiceAccount from " + sourceName);
try {
  Object answer = kubernetesClient.serviceAccounts().inNamespace(namespace).withName(id).replace(serviceAccount);
  logGeneratedEntity("Updated ServiceAccount: ", namespace, serviceAccount, answer);
} catch (Exception e) {

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

client.serviceAccounts().inNamespace(session.getNamespace())
    .withName(serviceAccountName)
    .replace(new ServiceAccountBuilder(serviceAccount)
        .withNewMetadata()
        .withName(serviceAccountName)

代码示例来源:origin: EnMasseProject/enmasse

@Override
public AddressSpace handle(AddressSpace addressSpace) throws Exception {
  NetworkPolicy networkPolicy = null;
  InfraConfig infraConfig = parseCurrentInfraConfig(schemaProvider.getSchema(), addressSpace);
  if (infraConfig != null) {
    networkPolicy = infraConfig.getNetworkPolicy();
  }
  if (addressSpace.getSpec().getNetworkPolicy() != null) {
    networkPolicy = addressSpace.getSpec().getNetworkPolicy();
  }
  io.fabric8.kubernetes.api.model.networking.NetworkPolicy existingPolicy = kubernetesClient.network().networkPolicies().withName(KubeUtil.getNetworkPolicyName(addressSpace)).get();
  if (networkPolicy != null) {
    String infraUuid = addressSpace.getAnnotation(AnnotationKeys.INFRA_UUID);
    List<Service> services = kubernetesClient.services().withLabel(LabelKeys.INFRA_UUID, infraUuid).list().getItems();
    io.fabric8.kubernetes.api.model.networking.NetworkPolicy newPolicy = createNetworkPolicy(networkPolicy, addressSpace, services);
    if (existingPolicy == null) {
      kubernetesClient.network().networkPolicies().create(newPolicy);
    } else if (hasChanged(existingPolicy, newPolicy)) {
      kubernetesClient.network().networkPolicies().withName(existingPolicy.getMetadata().getName()).replace(newPolicy);
    }
  } else if (existingPolicy != null) {
    kubernetesClient.network().networkPolicies().delete(existingPolicy);
  }
  return addressSpace;
}

相关文章