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

KeyValue.getKey介绍

[英]Get the key
[中]拿到钥匙

代码示例

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

private static JsonObject getTree(KeyValueList list, int prefix, String delimiter) {
 JsonObject tree = new JsonObject();
 for (KeyValue keyValue : list.getList()) {
  if (keyValue.getKey().endsWith(delimiter)) {
   continue;
  }
  JsonObject json = tree;
  String[] arr = keyValue.getKey().substring(prefix).split(delimiter);
  for (int i = 0; i < arr.length; i++) {
   String key = arr[i];
   if (i == arr.length - 1) {
    json.put(key, keyValue.getValue());
   } else {
    JsonObject next = json.getJsonObject(key);
    if (next == null) {
     next = new JsonObject();
     json.put(key, next);
    }
    json = next;
   }
  }
 }
 return tree;
}

代码示例来源：origin: io.vertx/vertx-consul-client

public static void toJson(KeyValue obj, java.util.Map<String, Object> json) {
  json.put("createIndex", obj.getCreateIndex());
  json.put("flags", obj.getFlags());
  if (obj.getKey() != null) {
   json.put("key", obj.getKey());
  }
  json.put("lockIndex", obj.getLockIndex());
  json.put("modifyIndex", obj.getModifyIndex());
  if (obj.getSession() != null) {
   json.put("session", obj.getSession());
  }
  if (obj.getValue() != null) {
   json.put("value", obj.getValue());
  }
 }
}

代码示例来源：origin: io.vertx/vertx-consul-client

private List<String> getKeys(TxnResponse resp) {
 return resp.getResults().stream()
  .map(kv -> ((KeyValue) kv).getKey()).collect(Collectors.toList());
}

代码示例来源：origin: io.vertx/vertx-consul-client

private void getEntries(TestContext tc, String prefix, Handler<List<String>> resultHandler) {
 ctx.readClient().getValues(prefix, tc.asyncAssertSuccess(list -> {
  resultHandler.handle(list.getList().stream()
   .map(kv -> kv.getKey() + "/" + kv.getValue()).collect(Collectors.toList()));
 }));
}

代码示例来源：origin: io.vertx/vertx-consul-client

private void valuesAccess(TestContext tc, ConsulClient accessClient) {
 String key1 = randomFooBarAlpha();
 String value1 = randomAlphaString(10);
 String key2 = randomFooBarAlpha();
 String value2 = randomAlphaString(10);
 ctx.writeClient().putValue(key1, value1, tc.asyncAssertSuccess(b1 -> {
  tc.assertTrue(b1);
  ctx.writeClient().putValue(key2, value2, tc.asyncAssertSuccess(b2 -> {
   tc.assertTrue(b2);
   accessClient.getValues("foo/bar", tc.asyncAssertSuccess(kvList -> {
    List<KeyValue> list = kvList.getList();
    tc.assertEquals(list.size(), 2);
    tc.assertTrue(list.stream()
     .filter(kv -> kv.getKey().equals(key1) && kv.getValue().equals(value1))
     .count() == 1);
    tc.assertTrue(list.stream()
     .filter(kv -> kv.getKey().equals(key2) && kv.getValue().equals(value2))
     .count() == 1);
    ctx.writeClient().deleteValues("foo/bar", tc.asyncAssertSuccess());
   }));
  }));
 }));
}

代码示例来源：origin: io.vertx/vertx-consul-client

private void checkKeyValue(KeyValue expected, KeyValue actual) {
 assertEquals(expected, actual);
 assertEquals(expected.hashCode(), actual.hashCode());
 assertEquals(expected.getKey(), actual.getKey());
 assertEquals(expected.getValue(), actual.getValue());
 assertEquals(expected.getSession(), actual.getSession());
 assertEquals(expected.getCreateIndex(), actual.getCreateIndex());
 assertEquals(expected.getFlags(), actual.getFlags());
 assertEquals(expected.getModifyIndex(), actual.getModifyIndex());
 assertEquals(expected.getLockIndex(), actual.getLockIndex());
}

代码示例来源：origin: io.vertx/vertx-consul-client

@Test
public void readClientEmptyValue(TestContext tc) {
 String key = randomFooBarAlpha();
 ctx.writeClient()
  .putValue(key, "", tc.asyncAssertSuccess(b -> {
   tc.assertTrue(b);
   ctx.readClient().getValue(key, tc.asyncAssertSuccess(pair -> {
    tc.assertEquals(key, pair.getKey());
    tc.assertEquals("", pair.getValue());
    ctx.writeClient().deleteValue(key, tc.asyncAssertSuccess());
   }));
  }));
}

代码示例来源：origin: io.vertx/vertx-consul-client

@Test
public void readClientCanReadOneValue(TestContext tc) {
 String key = randomFooBarUnicode();
 String value = randomUnicodeString(10);
 ctx.writeClient()
  .putValue(key, value, tc.asyncAssertSuccess(b -> {
   tc.assertTrue(b);
   ctx.readClient().getValue(key, tc.asyncAssertSuccess(pair -> {
    tc.assertEquals(key, pair.getKey());
    tc.assertEquals(value, pair.getValue());
    ctx.writeClient().deleteValue(key, tc.asyncAssertSuccess());
   }));
  }));
}

代码示例来源：origin: io.vertx/vertx-consul-client

@Test
public void canSetAllFlags(TestContext tc) {
 String key = randomFooBarAlpha();
 String value = randomAlphaString(10);
 KeyValueOptions opts = new KeyValueOptions().setFlags(-1);
 ctx.writeClient()
  .putValueWithOptions(key, value, opts, tc.asyncAssertSuccess(b -> {
   tc.assertTrue(b);
   ctx.readClient().getValue(key, tc.asyncAssertSuccess(pair -> {
    tc.assertEquals(key, pair.getKey());
    tc.assertEquals(value, pair.getValue());
    assertEquals(opts.getFlags(), pair.getFlags());
    ctx.writeClient().deleteValue(key, tc.asyncAssertSuccess());
   }));
  }));
}

代码示例来源：origin: io.vertx/vertx-consul-client

@Test
public void writeClientHaveFullAccessToOneValue(TestContext tc) {
 String key = randomFooBarAlpha();
 String value = randomAlphaString(10);
 KeyValueOptions opts = new KeyValueOptions().setFlags(randomLong());
 ctx.writeClient()
  .putValueWithOptions(key, value, opts, tc.asyncAssertSuccess(b -> {
   tc.assertTrue(b);
   ctx.readClient().getValue(key, tc.asyncAssertSuccess(pair -> {
    tc.assertEquals(key, pair.getKey());
    tc.assertEquals(value, pair.getValue());
    assertEquals(opts.getFlags(), pair.getFlags());
    ctx.writeClient().deleteValue(key, tc.asyncAssertSuccess());
   }));
  }));
}