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

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

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

Record.getName介绍

[英]Gets the name of the service. It can reflect the service name of the name of the provider.
[中]获取服务的名称。它可以反映提供者名称的服务名称。

代码示例

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

@Override
public void start() {
 Router router = Router.router(vertx);
 router.get("/").handler(this::invoke);
 // Retrieve the service discovery
 ServiceDiscovery.create(vertx, discovery ->
  // Retrieve a web client
  HttpEndpoint.getWebClient(discovery, svc -> svc.getName().equals("vertx-greeting"), ar -> {
   if (ar.failed()) {
    System.out.println("D'oh the service is not available");
   } else {
    client = ar.result();
    vertx.createHttpServer().requestHandler(router).listen(8080);
   }
  }));
}

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

System.out.println("\"" + record1.getName() + "\" successfully published!");
  Record publishedRecord = ar.result();
 } else {
  System.out.println("\"" + record2.getName() + "\" successfully published!");
  Record publishedRecord = ar.result();
 } else {
  System.out.println("\"" + record1.getName() + "\" successfully unpublished");
 } else {
discovery.getRecord(r -> r.getName().equals(record2.getName()), ar -> {
 if (ar.succeeded()) {
  if (ar.result() != null) {
   System.out.println("Consuming \"" + record2.getName() + "\"");

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

private List<Record> findRecords() {
    final ConcurrentMap<String, Record> address = ORIGIN.getRegistryData();
    final String name = this.getValue("name");
    // Find service records
    return address.values().stream()
        .filter(item -> name.equals(item.getName()))
        .collect(Collectors.toList());
  }
}

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

private List<Record> findRecords() {
    final ConcurrentMap<String, Record> address = ORIGIN.getRegistryData();
    final String name = this.getValue("name");
    // Find service records
    return address.values().stream()
        .filter(item -> name.equals(item.getName()))
        .collect(Collectors.toList());
  }
}

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

private boolean thisEquals(SchemaRegistration test) {
  // Record does not yet override equals() (https://github.com/vert-x3/vertx-service-discovery/pull/35)
  return (schemaEquals(schemaDefinition, test.schemaDefinition)) &&
      fieldEquals(serviceConsumer, test.serviceConsumer) &&
      (record == null ? test.record == null : fieldEquals(record.getName(), test.record.getName()));
}

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

private void assertThatListContains(List<Record> records, String name) {
 for (Record rec : records) {
  if (rec.getName().equalsIgnoreCase(name)) {
   return;
  }
 }
 throw new AssertionError("Cannot find service '" + name + "' in the list");
}

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

private void assertThatListDoesNotContain(List<Record> records, String name) {
 for (Record rec : records) {
  if (rec.getName().equalsIgnoreCase(name)) {
   throw new AssertionError("Found service '" + name + "' in the list");
  }
 }
}

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

private void assertThatListContains(List<Record> records, String name) {
 for (Record rec : records) {
  if (rec.getName().equalsIgnoreCase(name)) {
   return;
  }
 }
 throw new AssertionError("Cannot find service '" + name + "' in the list");
}

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

private void assertThatListDoesNotContain(List<Record> records, String name) {
 for (Record rec : records) {
  if (rec.getName().equalsIgnoreCase(name)) {
   throw new AssertionError("Found service '" + name + "' in the list");
  }
 }
}

代码示例来源：origin: sczyh30/vertx-blueprint-microservice

private Single<Void> publish(Record record) {
 return discovery.rxPublish(record)
  .doOnSuccess(rec -> {
   registeredRecords.add(record);
   logger.info("Service <" + rec.getName() + "> published");
  })
  .map(r -> null);
}

代码示例来源：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: 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: 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

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: 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-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-zookeeper

private void fetchRecords(AtomicBoolean marker, TestContext tc) {
 sd.getRecords(x -> true, l -> {
  if (l.succeeded() && l.result().size() == 1) {
   tc.assertEquals("foo-service", l.result().get(0).getName());
   marker.set(true);
  } else {
   vertx.setTimer(100, x -> fetchRecords(marker, tc));
  }
 });
}

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

private void fetchRecords(AtomicBoolean marker, TestContext tc) {
 sd.getRecords(x -> true, l -> {
  if (l.succeeded() && l.result().size() == 1) {
   tc.assertEquals("foo-service", l.result().get(0).getName());
   marker.set(true);
  } else {
   vertx.setTimer(100, x -> fetchRecords(marker, tc));
  }
 });
}

代码示例来源：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");
}

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

record

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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