Contents

require 'logstash-output-elasticsearch-ec2_jars.rb'

module LogStash::Outputs::ElasticSearch::Ec2

  def self.included(base)
    base.extend(self)
    base.create_options
  end

  def create_options

    config :aws_access_key, :validate => :string

    config :aws_secret_key, :validate => :string

    config :aws_protocol, :validate => ['http', 'https'], :default => 'https'

    config :s3_protocol, :validate => ['http', 'https']

    config :ec2_protocol, :validate => ['http', 'https']

    config :aws_proxy_host, :validate => :string

    config :aws_proxy_port, :validate => :number

    config :aws_region, :validate => ['us-east-1', 'us-west-1', 'us-west-2', 'ap-southeast-1', 'ap-southeast-2', 'ap-northeast-1', 'eu-west-1', 'sa-east-1' ]

  end

  def self.create_client_config(plugin)
     settings = {}
     settings['cloud.aws.access_key'] = plugin.aws_access_key if plugin.aws_access_key
     settings['cloud.aws.secret_key'] = plugin.aws_secret_key if plugin.aws_secret_key
     settings['cloud.aws.protocol'] = plugin.aws_protocol if plugin.aws_protocol
     settings['cloud.aws.protocol.s3.protocol'] = plugin.s3_protocol if plugin.s3_protocol
     settings['cloud.aws.protocol.ec2.protocol'] = plugin.ec2_protocol if plugin.ec2_protocol
     settings['cloud.aws.proxy_host'] = plugin.aws_proxy_host if plugin.aws_proxy_host
     settings['cloud.aws.proxy_port'] = plugin.aws_proxy_port if plugin.aws_proxy_port
     settings['cloud.aws.region'] = plugin.aws_region if plugin.aws_region
     settings
  end

end

LogStash::Outputs::ElasticSearch.instance_eval{ include LogStash::Outputs::ElasticSearch::Ec2 }

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
logstash-output-elasticsearch-ec2-0.2.4	lib/logstash/outputs/elasticsearch/ec2.rb
logstash-output-elasticsearch-ec2-0.2.3	lib/logstash/outputs/elasticsearch/ec2.rb
logstash-output-elasticsearch-ec2-0.2.2	lib/logstash/outputs/elasticsearch/ec2.rb
logstash-output-elasticsearch-ec2-0.2.1	lib/logstash/outputs/elasticsearch/ec2.rb
logstash-output-elasticsearch-ec2-0.2.0	lib/logstash/outputs/elasticsearch/ec2.rb