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

Resource.createOrReplace介绍

暂无

代码示例

代码示例来源：origin: fabric8io/kubernetes-client

@Override
public T createOrReplace(T... items) {
 T item = getItem();
 if (items.length > 1) {
  throw new IllegalArgumentException("Too many items to create.");
 } else if (items.length == 1) {
  item = items[0];
 }
 if (item == null) {
  throw new IllegalArgumentException("Nothing to create.");
 }
 if (Utils.isNullOrEmpty(name) && item instanceof HasMetadata) {
  return withName(((HasMetadata)item).getMetadata().getName()).createOrReplace(item);
 }
 if (fromServer().get() == null) {
  return create(item);
 } else {
  return replace(item);
 }
}

代码示例来源：origin: fabric8io/kubernetes-client

.inNamespace(namespace)
.load(NetworkPolicyExample.class.getResourceAsStream("/network-policy.yml"))
.createOrReplace();

代码示例来源：origin: fabric8io/kubernetes-client

public static void main(String[] args) throws InterruptedException {
 Config config = new ConfigBuilder().build();
 KubernetesClient client = new DefaultKubernetesClient(config);
 String namespace = null;
 if (args.length > 0) {
  namespace = args[0];
 }
 if (namespace == null) {
  namespace = client.getNamespace();
 }
 if (namespace == null) {
  namespace = "default";
 }
 String name = "cheese";
 try {
  Resource<ConfigMap, DoneableConfigMap> configMapResource = client.configMaps().inNamespace(namespace).withName(name);
  ConfigMap configMap = configMapResource.createOrReplace(new ConfigMapBuilder().
    withNewMetadata().withName(name).endMetadata().
    addToData("foo", "" + new Date()).
    addToData("bar", "beer").
    build());
  log("Upserted ConfigMap at " + configMap.getMetadata().getSelfLink() + " data " + configMap.getData());
 } finally {
  client.close();
 }
}

代码示例来源：origin: org.domeos/kubernetes-client

@Override
public T createOrReplace(T... items) {
 T item = getItem();
 if (items.length > 1) {
  throw new IllegalArgumentException("Too many items to create.");
 } else if (items.length == 1) {
  item = items[0];
 }
 if (item == null) {
  throw new IllegalArgumentException("Nothing to create.");
 }
 if (Utils.isNullOrEmpty(name) && item instanceof HasMetadata) {
  return withName(((HasMetadata)item).getMetadata().getName()).createOrReplace(item);
 }
 if (fromServer().get() == null) {
  return create(item);
 } else {
  return replace(item);
 }
}

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

public static synchronized ConfigMap updateConfigMapStatus(KubernetesClient client, final Session session, final String status) {
  try {
    ConfigMap configMap = new ConfigMapBuilder().
        withNewMetadata().withName(FABRIC8_ARQUILLIAN).addToAnnotations(createConfigMapAnnotations(session, status)).endMetadata().
        build();
    return client.configMaps().inNamespace(session.getNamespace()).withName(FABRIC8_ARQUILLIAN).createOrReplace(configMap);
  } catch (Exception e) {
    LOG.warn("failed to update ConfigMap " + FABRIC8_ARQUILLIAN + ". " + e, e);
    return null;
  }
}

代码示例来源：origin: strimzi/strimzi-kafka-operator

verify(mockResource, never()).patch(any());
  verify(mockResource, never()).createNew();
  verify(mockResource, never()).createOrReplace(any());
  async.complete();
});

代码示例来源：origin: strimzi/strimzi-kafka-operator

public void createWhenExistsIsAPatch(TestContext context, boolean cascade) {
  T resource = resource();
  Resource mockResource = mock(resourceType());
  when(mockResource.get()).thenReturn(resource);
  when(mockResource.cascading(cascade)).thenReturn(mockResource);
  NonNamespaceOperation mockNameable = mock(NonNamespaceOperation.class);
  when(mockNameable.withName(matches(resource.getMetadata().getName()))).thenReturn(mockResource);
  MixedOperation mockCms = mock(MixedOperation.class);
  when(mockCms.inNamespace(matches(resource.getMetadata().getNamespace()))).thenReturn(mockNameable);
  C mockClient = mock(clientType());
  mocker(mockClient, mockCms);
  AbstractResourceOperator<C, T, L, D, R> op = createResourceOperations(vertx, mockClient);
  Async async = context.async();
  Future<ReconcileResult<T>> fut = op.createOrUpdate(resource());
  fut.setHandler(ar -> {
    if (!ar.succeeded()) {
      ar.cause().printStackTrace();
    }
    assertTrue(ar.succeeded());
    verify(mockResource).get();
    verify(mockResource).patch(any());
    verify(mockResource, never()).create(any());
    verify(mockResource, never()).createNew();
    verify(mockResource, never()).createOrReplace(any());
    verify(mockCms, never()).createOrReplace(any());
    async.complete();
  });
}

代码示例来源：origin: strimzi/strimzi-kafka-operator

verify(mockResource, never()).createOrReplace(any());
verify(mockCms, never()).createOrReplace(any());
async.complete();