@Override
    public Set<byte[]> keys(RedisClusterNode node, byte[] pattern) {
        RedisClient entry = getEntry(node);
        RFuture<Collection<byte[]>> f = executorService.readAsync(entry, ByteArrayCodec.INSTANCE, KEYS, pattern);
        Collection<byte[]> keys = syncFuture(f);
        return new HashSet<>(keys);
    }
@Test
    public void testKeys() {
        RedisClusterNode node1 = connection.clusterGetNodeForSlot(1);
        for (int i = 0; i < 1000; i++) {
            connection.set(("test" + i).getBytes(), ("" + i).getBytes());
        }
        Set<byte[]> keys = connection.keys(node1, "test*".getBytes(StandardCharsets.UTF_8));
        assertThat(keys).hasSize(342);
    }