com.vmware.admiral.common.util.QueryUtil.extractQueryResult()方法的使用及代码示例

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

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

QueryUtil.extractQueryResult介绍

[英]Extracts the service documents from the given query result.
[中]从给定的查询结果中提取服务文档。

代码示例

代码示例来源:origin: vmware/admiral

private DeferredResult<List<ClusterDto>> getInfoFromHostsWithinPlacementZone(String projectLink,
    ServiceDocumentQueryResult queryResult, Operation get) {
  Map<String, ElasticPlacementZoneConfigurationState> ePZstates = QueryUtil
      .extractQueryResult(
          queryResult, ElasticPlacementZoneConfigurationState.class);
  List<DeferredResult<ClusterDto>> clusterDtoList = ePZstates.keySet().stream()
      .map(key -> ClusterUtils.getHostsWithinPlacementZone(ePZstates.get(key)
              .resourcePoolState.documentSelfLink, projectLink, get, getHost())
          .thenApply(computeStates -> {
            return ClusterUtils.placementZoneAndItsHostsToClusterDto(
                ePZstates.get(key).resourcePoolState, computeStates);
          }))
      .collect(Collectors.toList());
  return DeferredResult.allOf(clusterDtoList);
}

代码示例来源:origin: vmware/admiral

Map<String, ResourcePoolState> rpByLink = QueryUtil.extractQueryResult(
    ops.get(operationsToJoin.get(0).getId())
        .getBody(ServiceDocumentQueryResult.class),
    ResourcePoolState.class);
Map<String, ElasticPlacementZoneState> epzByLink = QueryUtil.extractQueryResult(
    ops.get(operationsToJoin.get(1).getId())
        .getBody(ServiceDocumentQueryResult.class),

代码示例来源:origin: vmware/admiral

@Override
public void handlePost(Operation post) {
  URI serviceUri = UriUtils.buildUri(ElasticPlacementZoneConfigurationService.SELF_LINK);
  Operation.createGet(this, UriUtils.buildExpandLinksQueryUri(serviceUri).toString())
      .setReferer(UriUtils.buildUri(getHost(), SELF_LINK))
      .setCompletion((op, ex) -> {
        if (ex != null) {
          logSevere("Failed to get resource pool states");
          post.fail(ex);
        } else {
          ServiceDocumentQueryResult queryResult = op
              .getBody(ServiceDocumentQueryResult.class);
          Map<String, ElasticPlacementZoneConfigurationState> states = QueryUtil
              .extractQueryResult(
                  queryResult, ElasticPlacementZoneConfigurationState.class);
          logInfo("Number of resource pool states found %d", states.size());
          if (states.isEmpty()) {
            logInfo("No resource pools found. Tranformation completed successfully");
            post.complete();
            return;
          }
          poolsCount = new AtomicInteger(states.size());
          processPools(states.values(), post);
        }
      }).sendWith(getHost());
}

代码示例来源:origin: vmware/admiral

@Test
public void testGetAllExpand() throws Throwable {
  String rp1Link = createRp().documentSelfLink;
  String rp2Link = createRp().documentSelfLink;
  String epzLink = createEpz(rp2Link, "tag1").documentSelfLink;
  URI serviceUri = UriUtils.buildUri(host, ElasticPlacementZoneConfigurationService.SELF_LINK);
  ServiceDocumentQueryResult queryResult = doOperation(null,
      UriUtils.buildExpandLinksQueryUri(serviceUri),
      ServiceDocumentQueryResult.class, false, Action.GET);
  assertNotNull(queryResult);
  assertNotNull(queryResult.documents);
  assertTrue(queryResult.documentCount >= 2);
  Map<String, ElasticPlacementZoneConfigurationState> states = QueryUtil.extractQueryResult(
      queryResult, ElasticPlacementZoneConfigurationState.class);
  ElasticPlacementZoneConfigurationState state1 = states.get(rp1Link);
  assertNotNull(state1);
  assertNotNull(state1.resourcePoolState);
  assertNull(state1.epzState);
  assertEquals(rp1Link, state1.documentSelfLink);
  assertEquals(rp1Link, state1.resourcePoolState.documentSelfLink);
  ElasticPlacementZoneConfigurationState state2 = states.get(rp2Link);
  assertNotNull(state2);
  assertNotNull(state2.resourcePoolState);
  assertNotNull(state2.epzState);
  assertEquals(rp2Link, state2.documentSelfLink);
  assertEquals(rp2Link, state2.resourcePoolState.documentSelfLink);
  assertEquals(epzLink, state2.epzState.documentSelfLink);
  assertEquals(state2.resourcePoolState.documentSelfLink, state2.epzState.resourcePoolLink);
  assertEquals(tagSet("tag1"), state2.epzState.tagLinksToMatch);
}

相关文章