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

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

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

Resource.watch介绍

暂无

代码示例

代码示例来源:origin: spring-cloud/spring-cloud-kubernetes

public void start() {
  if (watch == null) {
    synchronized (lock) {
      if (watch == null) {
        LOGGER.debug("Starting leader record watcher");
        watch = kubernetesClient
          .configMaps()
          .inNamespace(leaderProperties.getNamespace(kubernetesClient.getNamespace()))
          .withName(leaderProperties.getConfigMapName())
          .watch(this);
      }
    }
  }
}

代码示例来源:origin: fabric8io/spring-cloud-kubernetes

public void start() {
  ConfigMap map = Strings.isNullOrEmpty(namespace)
      ? client.configMaps().withName(name).get()
      : client.configMaps().inNamespace(namespace).withName(name).get();
  if (map != null) {
    currentData.set(asObjectMap(map.getData()));
  }
  watch = Strings.isNullOrEmpty(namespace)
      ? client.configMaps().withName(name).watch(watcher)
      : client.configMaps().inNamespace(namespace).withName(namespace).watch(watcher);
  started.set(true);
}

代码示例来源:origin: org.springframework.cloud/spring-cloud-kubernetes-archaius

public void start() {
  ConfigMap map = StringUtils.isEmpty(namespace)
      ? client.configMaps().withName(name).get()
      : client.configMaps().inNamespace(namespace).withName(name).get();
  if (map != null) {
    currentData.set(asObjectMap(map.getData()));
  }
  watch = StringUtils.isEmpty(namespace)
      ? client.configMaps().withName(name).watch(watcher)
      : client.configMaps().inNamespace(namespace).withName(name).watch(watcher);
  started.set(true);
}

代码示例来源:origin: io.fabric8/spring-cloud-kubernetes-archaius

public void start() {
  ConfigMap map = Strings.isNullOrEmpty(namespace)
      ? client.configMaps().withName(name).get()
      : client.configMaps().inNamespace(namespace).withName(name).get();
  if (map != null) {
    currentData.set(asObjectMap(map.getData()));
  }
  watch = Strings.isNullOrEmpty(namespace)
      ? client.configMaps().withName(name).watch(watcher)
      : client.configMaps().inNamespace(namespace).withName(namespace).watch(watcher);
  started.set(true);
}

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

public void start() {
  ConfigMap initial = openshiftClient.configMaps().withName(configName).get();
  if (initial != null) {
    eventReceived(Action.ADDED, initial);
  }
  watch = openshiftClient.configMaps().withName(configName).watch(this);
}

相关文章