io.vertx.servicediscovery.Record.getLocation()方法的使用及代码示例

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

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

Record.getLocation介绍

暂无

代码示例

代码示例来源：origin: io.vertx/vertx-service-discovery

HttpEndpointReference(Vertx vertx, ServiceDiscovery discovery, Record record, JsonObject config) {
 super(vertx, discovery, record);
 this.config = config;
 this.location = new HttpLocation(record.getLocation());
}

代码示例来源：origin: vert-x3/vertx-service-discovery

private boolean areTheSameService(Record record1, Record record2) {
 String uuid = record1.getMetadata().getString(KUBERNETES_UUID, "");
 String uuid2 = record2.getMetadata().getString(KUBERNETES_UUID, "");
 String endpoint = record1.getLocation().getString(Record.ENDPOINT, "");
 String endpoint2 = record2.getLocation().getString(Record.ENDPOINT, "");
 // Check the uuid and location
 return uuid.equals(uuid2) && endpoint.equals(endpoint2);
}

代码示例来源：origin: silentbalanceyh/vertx-zero

@Override
public ConcurrentMap<String, Record> getRegistryData() {
  final ConcurrentMap<String, Record> map = this.readData(EtcdPath.IPC);
  for (final Record record : map.values()) {
    record.setStatus(Status.UP);
    record.setType("IPC");
    // Alpn Enabled for Rpc, ssl must be true.
    record.getLocation().put("ssl", Boolean.TRUE);
  }
  return map;
}

代码示例来源：origin: cn.vertxup/vertx-up

@Override
public ConcurrentMap<String, Record> getRegistryData() {
  final ConcurrentMap<String, Record> map = this.readData(EtcdPath.IPC);
  for (final Record record : map.values()) {
    record.setStatus(Status.UP);
    record.setType("IPC");
    // Alpn Enabled for Rpc, ssl must be true.
    record.getLocation().put("ssl", Boolean.TRUE);
  }
  return map;
}

代码示例来源：origin: cn.vertxup/vertx-up

public static void in(final IpcData data, final Record record) {
  if (null != record) {
    data.setHost(record.getLocation().getString("host"));
    data.setPort(record.getLocation().getInteger("port"));
    data.setName(record.getName());
  }
}

代码示例来源：origin: silentbalanceyh/vertx-zero

@Override
public boolean erasing(final Record record) {
  final String host = record.getLocation().getString(HOST);
  final Integer port = record.getLocation().getInteger(PORT);
  final String name = record.getName();
  if (!Ut.netOk(host, port)) {
    this.registry.erasingStatus(name, host, port, this.getPath());
  }
  return true;
}

代码示例来源：origin: silentbalanceyh/vertx-zero

public static void in(final IpcData data, final Record record) {
  if (null != record) {
    data.setHost(record.getLocation().getString("host"));
    data.setPort(record.getLocation().getInteger("port"));
    data.setName(record.getName());
  }
}

代码示例来源：origin: vert-x3/vertx-service-discovery

/**
 * Creates the event bus consumer for the service.
 *
 * @return the consumer
 */
@Override
public MessageConsumer<X> retrieve() {
 return vertx.eventBus().consumer(record().getLocation().getString(Record.ENDPOINT));
}

代码示例来源：origin: cn.vertxup/vertx-up

@Override
public boolean erasing(final Record record) {
  final String host = record.getLocation().getString(HOST);
  final Integer port = record.getLocation().getInteger(PORT);
  final String name = record.getName();
  if (!Ut.netOk(host, port)) {
    this.registry.erasingStatus(name, host, port, this.getPath());
  }
  return true;
}

代码示例来源：origin: io.vertx/vertx-service-discovery

/**
 * Creates the event bus consumer for the service.
 *
 * @return the consumer
 */
@Override
public MessageConsumer<X> retrieve() {
 return vertx.eventBus().consumer(record().getLocation().getString(Record.ENDPOINT));
}

代码示例来源：origin: engagingspaces/vertx-graphql-service-discovery

/**
 * Unregisters the published schema indicated by the provided registration.
 *
 * @param registration the schema registration
 */
@Override
protected void unregister(SchemaRegistration registration) {
  consumerManager.unregisterConsumer(registration.getRecord().getLocation().getString(Record.ENDPOINT));
  super.unregister(registration);
}

代码示例来源：origin: silentbalanceyh/vertx-zero

private void successLog(final Record record) {
  final String key = this.getID(record);
  final String id = record.getRegistration();
  final String endpoint = MessageFormat.format("http://{0}:{1}{2}",
      record.getLocation().getString(Origin.HOST),
      String.valueOf(record.getLocation().getInteger(Origin.PORT)),
      record.getMetadata().getString(Origin.PATH));
  LOGGER.debug(Info.REG_SUCCESS, record.getStatus(),
      record.getType(), record.getName(),
      endpoint, key, id);
}

代码示例来源：origin: cn.vertxup/vertx-up

private void successLog(final Record record) {
  final String key = this.getID(record);
  final String id = record.getRegistration();
  final String endpoint = MessageFormat.format("http://{0}:{1}{2}",
      record.getLocation().getString(Origin.HOST),
      String.valueOf(record.getLocation().getInteger(Origin.PORT)),
      record.getMetadata().getString(Origin.PATH));
  LOGGER.debug(Info.REG_SUCCESS, record.getStatus(),
      record.getType(), record.getName(),
      endpoint, key, id);
}

代码示例来源：origin: io.vertx/vertx-service-discovery-bridge-docker-links

private void assertRedis(Record record) {
 assertThat(record.getName()).isEqualTo("DISCOVERY_REDIS");
 assertThat(record.getLocation().getString("endpoint")).isEqualToIgnoringCase("tcp://172.17.0.2:6379");
 assertThat(record.getMetadata().getString("PORT_6379_TCP_PORT")).isEqualToIgnoringCase("6379");
}

代码示例来源：origin: io.vertx/vertx-service-discovery-bridge-kubernetes

@Test
public void testHttpRecordCreation() {
 Service service = getHttpService();
 Record record = KubernetesServiceImporter.createRecord(new JsonObject(Json.encodeToBuffer(service)));
 assertThat(record).isNotNull();
 assertThat(record.getName()).isEqualTo("my-service");
 assertThat(record.getMetadata().getString("kubernetes.name")).isEqualTo("my-service");
 assertThat(record.getMetadata().getString("kubernetes.namespace")).isEqualTo("my-project");
 assertThat(record.getMetadata().getString("kubernetes.uuid")).isEqualTo("uuid");
 assertThat(record.getType()).isEqualTo(HttpEndpoint.TYPE);
 assertThat(record.getLocation().getInteger("port")).isEqualTo(8080);
 assertThat(record.getLocation().getBoolean("ssl")).isFalse();
}

代码示例来源：origin: vert-x3/vertx-service-discovery

private void assertRedis(Record record) {
 assertThat(record.getName()).isEqualTo("DISCOVERY_REDIS");
 assertThat(record.getLocation().getString("endpoint")).isEqualToIgnoringCase("tcp://172.17.0.2:6379");
 assertThat(record.getMetadata().getString("PORT_6379_TCP_PORT")).isEqualToIgnoringCase("6379");
}

代码示例来源：origin: cn.vertxup/vertx-up

static RequestOptions getOptions(final Record record, final String normalizedUri) {
    final RequestOptions options = new RequestOptions();
    options.setURI(normalizedUri);
    // Extract host / port
    final JsonObject location = record.getLocation();
    options.setHost(location.getString("host"));
    options.setPort(location.getInteger("port"));
    LOGGER.info("[ ZERO ] Found remote host: {0}, port: {1}, uri: {2}",
        options.getHost(), String.valueOf(options.getPort()), options.getURI());
    return options;
  }
}

代码示例来源：origin: silentbalanceyh/vertx-zero

static RequestOptions getOptions(final Record record, final String normalizedUri) {
    final RequestOptions options = new RequestOptions();
    options.setURI(normalizedUri);
    // Extract host / port
    final JsonObject location = record.getLocation();
    options.setHost(location.getString("host"));
    options.setPort(location.getInteger("port"));
    LOGGER.info("[ ZERO ] Found remote host: {0}, port: {1}, uri: {2}",
        options.getHost(), String.valueOf(options.getPort()), options.getURI());
    return options;
  }
}

代码示例来源：origin: io.vertx/vertx-service-discovery-bridge-consul

@Test
public void testHttpImport() {
 services.add(buildService("172.17.0.2", "web", "web", new String[]{"rails", "http-endpoint"}, 80, "passing"));
 discovery = ServiceDiscovery.create(vertx)
   .registerServiceImporter(new ConsulServiceImporter(),
     new JsonObject().put("host", "localhost").put("port", 5601));
 await().until(() -> getAllRecordsBlocking().size() > 0);
 List<Record> list = getAllRecordsBlocking();
 assertThat(list).hasSize(1);
 assertThat(list.get(0).getType()).isEqualTo(HttpEndpoint.TYPE);
 assertThat(list.get(0).getLocation().getString("endpoint")).isEqualTo("http://172.17.0.2:80");
}

代码示例来源：origin: vert-x3/vertx-service-discovery

@Test
public void testHttpImport() {
 services.add(buildService("172.17.0.2", "web", "web", new String[]{"rails", "http-endpoint"}, 80, "passing"));
 discovery = ServiceDiscovery.create(vertx)
   .registerServiceImporter(new ConsulServiceImporter(),
     new JsonObject().put("host", "localhost").put("port", 5601));
 await().until(() -> getAllRecordsBlocking().size() > 0);
 List<Record> list = getAllRecordsBlocking();
 assertThat(list).hasSize(1);
 assertThat(list.get(0).getType()).isEqualTo(HttpEndpoint.TYPE);
 assertThat(list.get(0).getLocation().getString("endpoint")).isEqualTo("http://172.17.0.2:80");
}

内容来源于网络，如有侵权，请联系作者删除！

record

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com