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

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

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

Record.getMetadata介绍

[英]Gets the metadata attached to the record.
[中]获取附加到记录的元数据。

代码示例

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

private String getID(final Record record) {
  final JsonObject metadata = record.getMetadata();
  return metadata.getString(Origin.ID);
}

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

private String getID(final Record record) {
  final JsonObject metadata = record.getMetadata();
  return metadata.getString(Origin.ID);
}

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

/**
 * Gets the name of the publisher that registered the schema, {@code null} if published independently.
 *
 * @return the publisher name, or null
 */
public Optional<String> getPublisherId() {
  return Optional.ofNullable(record.getMetadata().getString("publisherId"));
}

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

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

@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: 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 testUnknownExternalServiceRecordCreation() {
 // JDBC Example
 int servicePort = 5432;
 Service service = getExternalService(servicePort);
 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(JDBCDataSource.TYPE);
 assertThat(record.getLocation().getString("host")).isEqualTo("my-external-service");
 assertThat(record.getLocation().getInteger("port")).isEqualTo(servicePort);
}

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

@Test
public void testHttpWithSSLExternalServiceRecordCreation() {
 int servicePort = 443;
 Service service = getExternalService(servicePort);
 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().getString("host")).isEqualTo("my-external-service");
 assertThat(record.getLocation().getInteger("port")).isEqualTo(servicePort);
 assertThat(record.getLocation().getBoolean("ssl")).isTrue();
 assertThat(record.getLocation().getString("endpoint")).isEqualTo("https://my-external-service:" + servicePort);
}

代码示例来源：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: vert-x3/vertx-service-discovery

@Test
public void testHttpWithSSLExternalServiceRecordCreation() {
 int servicePort = 443;
 Service service = getExternalService(servicePort);
 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().getString("host")).isEqualTo("my-external-service");
 assertThat(record.getLocation().getInteger("port")).isEqualTo(servicePort);
 assertThat(record.getLocation().getBoolean("ssl")).isTrue();
 assertThat(record.getLocation().getString("endpoint")).isEqualTo("https://my-external-service:" + servicePort);
}

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

@Test
public void testNoUriSpec() throws Exception {
 ServiceInstance<JsonObject> instance = ServiceInstance.<JsonObject>builder()
   .name("foo-service")
   .payload(new JsonObject().put("foo", "bar"))
   .sslPort(42406)
   .address("localhost")
   .build();
 Record record = ZookeeperServiceImporter.createRecordForInstance(instance);
 assertThat(record.getName()).isEqualTo("foo-service");
 assertThat(record.getType()).isEqualTo("unknown");
 assertThat(record.getMetadata().getString("foo")).isEqualTo("bar");
 assertThat(record.getMetadata().getString("zookeeper-id")).isNotEmpty();
 assertThat(record.getLocation())
   .contains(entry("endpoint", "https://localhost:42406"))
   .contains(entry("ssl-port", 42406));
}

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

/**
 * Creates a Redis client for the service.
 *
 * @return the Redis client, configured to access the service
 */
@Override
protected RedisClient retrieve() {
 JsonObject result = record().getMetadata().copy();
 result.mergeIn(record().getLocation());
 if (config != null) {
  result.mergeIn(config);
 }
 return RedisClient.create(vertx, new RedisOptions(result));
}

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

/**
 * Creates a Redis client for the service.
 *
 * @return the Redis client, configured to access the service
 */
@Override
protected RedisClient retrieve() {
 JsonObject result = record().getMetadata().copy();
 result.mergeIn(record().getLocation());
 if (config != null) {
  result.mergeIn(config);
 }
 return RedisClient.create(vertx, new RedisOptions(result));
}

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

@Override
public JDBCClient retrieve() {
 JsonObject result = record().getMetadata().copy();
 result.mergeIn(record().getLocation());
 if (config != null) {
  result.mergeIn(config);
 }
 if (result.getBoolean("shared", false)) {
  return JDBCClient.createShared(vertx, result);
 } else {
  return JDBCClient.createNonShared(vertx, result);
 }
}

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

@Override
public MongoClient retrieve() {
 JsonObject result = record().getMetadata().copy();
 result.mergeIn(record().getLocation());
 if (config != null) {
  result.mergeIn(config);
 }
 if (result.getBoolean("shared", false)) {
  return MongoClient.createShared(vertx, result);
 } else {
  return MongoClient.createNonShared(vertx, result);
 }
}

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

@Override
public JDBCClient retrieve() {
 JsonObject result = record().getMetadata().copy();
 result.mergeIn(record().getLocation());
 if (config != null) {
  result.mergeIn(config);
 }
 if (result.getBoolean("shared", false)) {
  return JDBCClient.createShared(vertx, result);
 } else {
  return JDBCClient.createNonShared(vertx, result);
 }
}

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

@Override
public MongoClient retrieve() {
 JsonObject result = record().getMetadata().copy();
 result.mergeIn(record().getLocation());
 if (config != null) {
  result.mergeIn(config);
 }
 if (result.getBoolean("shared", false)) {
  return MongoClient.createShared(vertx, result);
 } else {
  return MongoClient.createNonShared(vertx, result);
 }
}

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

record

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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