cpovirk <******@****.***> 1763415091 -0800

            docMeta.id(hit.getId());
            docMeta.version(hit.getVersion());
            docMeta.seqNo(hit.getSeqNo());
            docMeta.primaryTerm(hit.getPrimaryTerm());
            list.add(entity);
        });

        list.setPageSize(size);
        list.setAllRecordCount((int) searchHits.getTotalHits().value());
        list.setCurrentPageNumber(cb.getFetchPageNumber());

        return search(index, condition, (searchRequestBuilder, execTime, searchResponse) -> {
            final List<T> list = new ArrayList<>();
            searchResponse.ifPresent(response -> response.getHits().forEach(hit -> {
                list.add(creator.build(response, hit));
            }));
            return list;
        });
    }

    /**
     * Updates a specific field in a document.
     *

# Maximum concurrent group results for collapse queries.
query.collapse.max.concurrent.group.results=4
# Inner hits name for collapse queries.
query.collapse.inner.hits.name=similar_docs
# Inner hits size for collapse queries.
query.collapse.inner.hits.size=0
# Sorts for inner hits in collapse queries.
query.collapse.inner.hits.sorts=
# Default languages for queries.
query.default.languages=
# Default preference for JSON queries.

   *     of range.
   */
  public static HostAndPort fromParts(String host, int port) {
    checkArgument(isValidPort(port), "Port out of range: %s", port);
    HostAndPort parsedHost = fromString(host);
    checkArgument(!parsedHost.hasPort(), "Host has a port: %s", host);
    return new HostAndPort(parsedHost.host, port, parsedHost.hasBracketlessColons);

        }
    }

    /**
     * Sets the list of duplicate host rules.
     *
     * @param duplicateHostList the list of duplicate host rules to use
     */
    public void setDuplicateHostList(final List<DuplicateHost> duplicateHostList) {
        this.duplicateHostList = duplicateHostList;
    }

    /**
     * Adds a new duplicate host rule to the list.
     * Initializes the list if it doesn't exist.
     *

        this.scheme = scheme;
    }

    /**
     * Gets the host name.
     *
     * @return the host
     */
    public String getHost() {
        return host;
    }

    /**
     * Sets the host name.
     *
     * @param host the host
     */
    public void setHost(final String host) {
        this.host = host;
    }

    /**

      .assertLogEqual("Content-Length: 0")
      .assertLogEqual("<-- END HTTP")
      .assertNoMoreLogs()
    networkLogs
      .assertLogEqual("--> GET $url http/1.1")
      .assertLogEqual("Host: $host")
      .assertLogEqual("Connection: Keep-Alive")
      .assertLogEqual("Accept-Encoding: gzip")
      .assertLogMatch(Regex("""User-Agent: okhttp/.+"""))
      .assertLogEqual("--> END GET")

            docMeta.id(hit.getId());
            docMeta.version(hit.getVersion());
            docMeta.seqNo(hit.getSeqNo());
            docMeta.primaryTerm(hit.getPrimaryTerm());
            list.add(entity);
        });

        list.setPageSize(size);
        list.setAllRecordCount((int) searchHits.getTotalHits().value());
        list.setCurrentPageNumber(cb.getFetchPageNumber());

          )
      }

    /**
     * @param host either a regular hostname, International Domain Name, IPv4 address, or IPv6
     * address.
     */
    fun host(host: String) =
      apply {
        val encoded =
          host.percentDecode().toCanonicalHost()
            ?: throw IllegalArgumentException("unexpected host: $host")
        this.host = encoded
      }

    fun port(port: Int) =