lib/logstash/plugin_mixins/elasticsearch/common.rb
def discover_cluster_uuid
      return unless defined?(plugin_metadata)
      cluster_info = client.get('/')
      plugin_metadata.set(:cluster_uuid, cluster_info['cluster_uuid'])
    rescue => e
      @logger.error("Unable to retrieve Elasticsearch cluster uuid", message: e.message, exception: e.class, backtrace: e.backtrace)
    end
# This module defines common methods that can be reused by alternate elasticsearch output plugins such as the elasticsearch_data_streams output.
This module defines common methods that can be reused by alternate elasticsearch output plugins such as the elasticsearch_data_streams output.
This module defines common methods that can be reused by alternate elasticsearch output plugins such as the elasticsearch_data_streams output .
def discover_cluster_uuid
      return unless defined?(plugin_metadata)
      cluster_info = client.get('/')
      plugin_metadata.set(:cluster_uuid, cluster_info['cluster_uuid'])
    rescue => e
      @logger.error("Unable to retrieve Elasticsearch cluster uuid", message: e.message, exception: e.class, backtrace: e.backtrace)
    end
def discover_cluster_uuid return unless defined? ( plugin_metadata ) cluster_info = client . get ( '/' ) plugin_metadata . set ( :cluster_uuid , cluster_info [ 'cluster_uuid' ] ) rescue => e @logger . error ( "Unable to retrieve Elasticsearch cluster uuid" , message : e . message , exception : e . class , backtrace : e . backtrace ) end
This module defines common methods that can be reused by alternate elasticsearch output plugins such as the elasticsearch_data_streams output.
This module defines common methods that can be reused by alternate elasticsearch output plugins such as the elasticsearch_data_streams output .