本文整理了Java中io.fabric8.kubernetes.client.dsl.Resource.replace
方法的一些代码示例,展示了Resource.replace
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Resource.replace
方法的具体详情如下:
包路径:io.fabric8.kubernetes.client.dsl.Resource
类名称: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;
}
内容来源于网络,如有侵权,请联系作者删除!