diff --git a/CHANGELOG.md b/CHANGELOG.md index bc6127cbe..1495da5d5 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -4,10 +4,12 @@ Inspired from [Keep a Changelog](https://keepachangelog.com/en/1.0.0/) ## [Unreleased] ### Added - Added support for Ruby 3.3 ([#220](https://github.com/opensearch-project/opensearch-ruby/pull/220)) +- Added `search_pipeline` parameter to `search` API ([#227](https://github.com/opensearch-project/opensearch-ruby/pull/227)) ### Changed ### Deprecated ### Removed - Removed dependency on the base64 gem ([#221](https://github.com/opensearch-project/opensearch-ruby/pull/221)) +- Removed logging of hosts in `transport` base ([#227](https://github.com/opensearch-project/opensearch-ruby/pull/227)) ### Fixed - Switch back to the latest OpenSearch version when testing in CI ([#219](https://github.com/opensearch-project/opensearch-ruby/pull/219)) ### Security diff --git a/lib/opensearch/api/actions/search.rb b/lib/opensearch/api/actions/search.rb index dec2f1c55..d639cffd1 100644 --- a/lib/opensearch/api/actions/search.rb +++ b/lib/opensearch/api/actions/search.rb @@ -48,6 +48,7 @@ module Actions # @option arguments [String] :q Query in the Lucene query string syntax # @option arguments [List] :routing A comma-separated list of specific routing values # @option arguments [Time] :scroll Specify how long a consistent view of the index should be maintained for scrolled search + # @option arguments [String] :search_pipeline Customizable sequence of processing stages applied to search queries. # @option arguments [String] :search_type Search operation type (options: query_then_fetch, dfs_query_then_fetch) # @option arguments [Number] :size Number of hits to return (default: 10) # @option arguments [List] :sort A comma-separated list of : pairs @@ -128,6 +129,7 @@ def search(arguments = {}) q routing scroll + search_pipeline search_type size sort diff --git a/lib/opensearch/transport/transport/base.rb b/lib/opensearch/transport/transport/base.rb index dd0c71e2e..fd96e37e8 100644 --- a/lib/opensearch/transport/transport/base.rb +++ b/lib/opensearch/transport/transport/base.rb @@ -104,9 +104,7 @@ def get_connection(options = {}) # @see Sniffer#hosts # def reload_connections! - puts hosts hosts = sniffer.hosts - puts hosts __rebuild_connections hosts: hosts, options: options self rescue SnifferTimeoutError