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

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

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

Record.getStatus介绍

[英]Gets the current status of the service.
[中]获取服务的当前状态。

代码示例

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

@Override
public void getRecords(Function<Record, Boolean> filter, boolean includeOutOfService, Handler<AsyncResult<List<Record>>> resultHandler) {
 Objects.requireNonNull(filter);
 backend.getRecords(list -> {
  if (list.failed()) {
   resultHandler.handle(Future.failedFuture(list.cause()));
  } else {
   resultHandler.handle(Future.succeededFuture(
    list.result().stream()
     .filter(filter::apply)
     .filter(record -> includeOutOfService || record.getStatus() == Status.UP)
     .collect(Collectors.toList())
   ));
  }
 });
}

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

@Override
public void getRecords(Function<Record, Boolean> filter, boolean includeOutOfService, Handler<AsyncResult<List<Record>>> resultHandler) {
 Objects.requireNonNull(filter);
 backend.getRecords(list -> {
  if (list.failed()) {
   resultHandler.handle(Future.failedFuture(list.cause()));
  } else {
   resultHandler.handle(Future.succeededFuture(
    list.result().stream()
     .filter(filter::apply)
     .filter(record -> includeOutOfService || record.getStatus() == Status.UP)
     .collect(Collectors.toList())
   ));
  }
 });
}

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

@Override
public void getRecord(Function<Record, Boolean> filter, boolean includeOutOfService, Handler<AsyncResult<Record>>
 resultHandler) {
 Objects.requireNonNull(filter);
 backend.getRecords(list -> {
  if (list.failed()) {
   resultHandler.handle(Future.failedFuture(list.cause()));
  } else {
   Optional<Record> any = list.result().stream()
    .filter(filter::apply)
    .filter(record -> includeOutOfService || record.getStatus() == Status.UP)
    .findAny();
   if (any.isPresent()) {
    resultHandler.handle(Future.succeededFuture(any.get()));
   } else {
    resultHandler.handle(Future.succeededFuture(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: vert-x3/vertx-service-discovery

@Test
public void testPublicationWithoutStatus() {
 AtomicReference<Record> ref = new AtomicReference<>();
 Record record = HttpEndpoint.createRecord("some-service", "localhost");
 discovery.publish(record, ar -> {
  ref.set(ar.result());
 });
 await().untilAtomic(ref, is(notNullValue()));
 assertThat(ref.get().getRegistration()).isNotNull();
 assertThat(ref.get().getStatus()).isEqualTo(Status.UP);
}

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

@Test
public void testPublicationWithoutStatus() {
 AtomicReference<Record> ref = new AtomicReference<>();
 Record record = HttpEndpoint.createRecord("some-service", "localhost");
 discovery.publish(record, ar -> {
  ref.set(ar.result());
 });
 await().untilAtomic(ref, is(notNullValue()));
 assertThat(ref.get().getRegistration()).isNotNull();
 assertThat(ref.get().getStatus()).isEqualTo(Status.UP);
}

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

@Test
public void testPublicationWithStatusOutOfService() {
 AtomicReference<Record> ref = new AtomicReference<>();
 Record record = HttpEndpoint.createRecord("some-service", "localhost").setStatus(Status.OUT_OF_SERVICE);
 discovery.publish(record, ar -> {
  ref.set(ar.result());
 });
 await().untilAtomic(ref, is(notNullValue()));
 assertThat(ref.get().getRegistration()).isNotNull();
 assertThat(ref.get().getStatus()).isEqualTo(Status.OUT_OF_SERVICE);
}

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

@Test
public void testPublicationWithStatusUp() {
 AtomicReference<Record> ref = new AtomicReference<>();
 Record record = HttpEndpoint.createRecord("some-service", "localhost").setStatus(Status.UP);
 discovery.publish(record, ar -> {
  ref.set(ar.result());
 });
 await().untilAtomic(ref, is(notNullValue()));
 assertThat(ref.get().getRegistration()).isNotNull();
 assertThat(ref.get().getStatus()).isEqualTo(Status.UP);
}

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

@Test
public void testPublicationWithStatusDown() {
 AtomicReference<Record> ref = new AtomicReference<>();
 Record record = HttpEndpoint.createRecord("some-service", "localhost").setStatus(Status.DOWN);
 discovery.publish(record, ar -> {
  ref.set(ar.result());
 });
 await().untilAtomic(ref, is(notNullValue()));
 assertThat(ref.get().getRegistration()).isNotNull();
 assertThat(ref.get().getStatus()).isEqualTo(Status.DOWN);
}

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

@Test
public void testPublicationWithStatusUnknown() {
 AtomicReference<Record> ref = new AtomicReference<>();
 Record record = HttpEndpoint.createRecord("some-service", "localhost").setStatus(Status.UNKNOWN);
 discovery.publish(record, ar -> {
  ref.set(ar.result());
 });
 await().untilAtomic(ref, is(notNullValue()));
 assertThat(ref.get().getRegistration()).isNotNull();
 assertThat(ref.get().getStatus()).isEqualTo(Status.UP);
}

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

@Test
public void testPublicationWithStatusDown() {
 AtomicReference<Record> ref = new AtomicReference<>();
 Record record = HttpEndpoint.createRecord("some-service", "localhost").setStatus(Status.DOWN);
 discovery.publish(record, ar -> {
  ref.set(ar.result());
 });
 await().untilAtomic(ref, is(notNullValue()));
 assertThat(ref.get().getRegistration()).isNotNull();
 assertThat(ref.get().getStatus()).isEqualTo(Status.DOWN);
}

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

@Test
public void testPublicationWithStatusUp() {
 AtomicReference<Record> ref = new AtomicReference<>();
 Record record = HttpEndpoint.createRecord("some-service", "localhost").setStatus(Status.UP);
 discovery.publish(record, ar -> {
  ref.set(ar.result());
 });
 await().untilAtomic(ref, is(notNullValue()));
 assertThat(ref.get().getRegistration()).isNotNull();
 assertThat(ref.get().getStatus()).isEqualTo(Status.UP);
}

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

@Test
public void testPublicationWithStatusUnknown() {
 AtomicReference<Record> ref = new AtomicReference<>();
 Record record = HttpEndpoint.createRecord("some-service", "localhost").setStatus(Status.UNKNOWN);
 discovery.publish(record, ar -> {
  ref.set(ar.result());
 });
 await().untilAtomic(ref, is(notNullValue()));
 assertThat(ref.get().getRegistration()).isNotNull();
 assertThat(ref.get().getStatus()).isEqualTo(Status.UP);
}

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

@Test
public void testPublicationWithStatusOutOfService() {
 AtomicReference<Record> ref = new AtomicReference<>();
 Record record = HttpEndpoint.createRecord("some-service", "localhost").setStatus(Status.OUT_OF_SERVICE);
 discovery.publish(record, ar -> {
  ref.set(ar.result());
 });
 await().untilAtomic(ref, is(notNullValue()));
 assertThat(ref.get().getRegistration()).isNotNull();
 assertThat(ref.get().getStatus()).isEqualTo(Status.OUT_OF_SERVICE);
}

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

private void registerSchemaEventConsumers(
    ServiceDiscoveryOptions options, SchemaPublishedHandler<SchemaRegistration> publishedHandler,
    SchemaUnpublishedHandler<SchemaRegistration> unpublishedHandler) {
  SchemaAnnounceHandler announceHandler = record ->
      findRegistration(options.getName(), record.getName()).ifPresent(reg -> {
        if (Status.UP.equals(record.getStatus())) {
          publishedHandler.schemaPublished(reg);
        } else {
          unpublishedHandler.schemaUnpublished(reg);
        }
      });
  consumerManager.registerConsumer(options.getAnnounceAddress(), announceHandler);
}

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

@Test
public void testRetrievingMissingRecord() {
 HelloService svc = new HelloServiceImpl("stuff");
 ProxyHelper.registerService(HelloService.class, vertx, svc, "address");
 Record record = new Record()
  .setName("Hello")
  .setLocation(new JsonObject().put(Record.ENDPOINT, "address"));
 discovery.publish(record, (r) -> {
 });
 await().until(() -> record.getRegistration() != null);
 Record retrieved = retrieve(record.getRegistration());
 assertThat(retrieved.getStatus()).isEqualTo(Status.UP);
 // Unregister it
 Restafari.Response response2 = delete("/discovery/" + record.getRegistration());
 assertThat(response2.getStatusCode()).isEqualTo(204);
 Restafari.Response response = get("/discovery/" + record.getRegistration());
 assertThat(response.getStatusCode()).isEqualTo(404);
}

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

@Test
public void testRetrievingMissingRecord() {
 HelloService svc = new HelloServiceImpl("stuff");
 ProxyHelper.registerService(HelloService.class, vertx, svc, "address");
 Record record = new Record()
  .setName("Hello")
  .setLocation(new JsonObject().put(Record.ENDPOINT, "address"));
 discovery.publish(record, (r) -> {
 });
 await().until(() -> record.getRegistration() != null);
 Record retrieved = retrieve(record.getRegistration());
 assertThat(retrieved.getStatus()).isEqualTo(Status.UP);
 // Unregister it
 Restafari.Response response2 = delete("/discovery/" + record.getRegistration());
 assertThat(response2.getStatusCode()).isEqualTo(204);
 Restafari.Response response = get("/discovery/" + record.getRegistration());
 assertThat(response.getStatusCode()).isEqualTo(404);
}

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

@Test
public void testUpdateWithUUIDMismatch() throws UnsupportedEncodingException {
 HelloService svc = new HelloServiceImpl("stuff");
 ProxyHelper.registerService(HelloService.class, vertx, svc, "address");
 Record record = new Record()
  .setName("Hello")
  .setLocation(new JsonObject().put(Record.ENDPOINT, "address"));
 discovery.publish(record, (r) -> {
 });
 await().until(() -> record.getRegistration() != null);
 Record retrieved = retrieve(record.getRegistration());
 assertThat(retrieved.getStatus()).isEqualTo(Status.UP);
 retrieved.setStatus(Status.OUT_OF_SERVICE).setRegistration("not-the-right-one").getMetadata().put("foo", "bar");
 Restafari.Response response = given().body(retrieved.toJson().toString())
  .put("/discovery/" + record.getRegistration());
 assertThat(response.getStatusCode()).isEqualTo(400);
}

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

@Test
public void testUpdateWithUUIDMismatch() throws UnsupportedEncodingException {
 HelloService svc = new HelloServiceImpl("stuff");
 ProxyHelper.registerService(HelloService.class, vertx, svc, "address");
 Record record = new Record()
  .setName("Hello")
  .setLocation(new JsonObject().put(Record.ENDPOINT, "address"));
 discovery.publish(record, (r) -> {
 });
 await().until(() -> record.getRegistration() != null);
 Record retrieved = retrieve(record.getRegistration());
 assertThat(retrieved.getStatus()).isEqualTo(Status.UP);
 retrieved.setStatus(Status.OUT_OF_SERVICE).setRegistration("not-the-right-one").getMetadata().put("foo", "bar");
 Restafari.Response response = given().body(retrieved.toJson().toString())
  .put("/discovery/" + record.getRegistration());
 assertThat(response.getStatusCode()).isEqualTo(400);
}

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

record

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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