File tree Expand file tree Collapse file tree 2 files changed +4
-1
lines changed
Expand file tree Collapse file tree 2 files changed +4
-1
lines changed Original file line number Diff line number Diff line change 11## 4.1.1
2- - Adds elastic-transport support [ #191 ] ( https://github.com/logstash-plugins/logstash-filter-elasticsearch/pull/191 )
2+ - Adds elastic-transport client support [ #191 ] ( https://github.com/logstash-plugins/logstash-filter-elasticsearch/pull/191 )
33
44## 4.1.0
55 - Added support for custom headers [ #188 ] ( https://github.com/logstash-plugins/logstash-filter-elasticsearch/pull/188 )
Original file line number Diff line number Diff line change 103103
104104 before ( :each ) do
105105 allow ( LogStash ::Filters ::ElasticsearchClient ) . to receive ( :new ) . and_return ( client )
106+ allow ( client ) . to receive ( :es_transport_client_type ) . and_return ( 'elasticsearch_transport' )
106107 allow ( client ) . to receive ( :search ) . and_return ( response )
107108 allow ( plugin ) . to receive ( :test_connection! )
108109 allow ( plugin ) . to receive ( :setup_serverless )
347348
348349 before do
349350 allow ( plugin ) . to receive ( :get_client ) . and_return ( client_double )
351+ allow ( client_double ) . to receive ( :es_transport_client_type ) . and_return ( 'elasticsearch_transport' )
350352 allow ( client_double ) . to receive ( :client ) . and_return ( transport_double )
351353 end
352354
@@ -821,6 +823,7 @@ def wait_receive_request
821823
822824 before ( :each ) do
823825 allow ( LogStash ::Filters ::ElasticsearchClient ) . to receive ( :new ) . and_return ( client )
826+ allow ( client ) . to receive ( :es_transport_client_type ) . and_return ( 'elasticsearch_transport' )
824827 allow ( plugin ) . to receive ( :test_connection! )
825828 allow ( plugin ) . to receive ( :setup_serverless )
826829 plugin . register
You can’t perform that action at this time.
0 commit comments