From f2781d2344301d2f6064f37d66a396b77aff4382 Mon Sep 17 00:00:00 2001 From: Roger Butenuth Date: Wed, 1 Mar 2017 15:26:41 +0100 Subject: [PATCH] Path and prefix of sincedb configurable (#14) --- README.md | 4 +++- lib/logstash/inputs/cloudhub.rb | 8 +++++++- 2 files changed, 10 insertions(+), 2 deletions(-) diff --git a/README.md b/README.md index d32a451..8206be3 100644 --- a/README.md +++ b/README.md @@ -31,7 +31,9 @@ input { type => "CloudHub" username => "anypoint-user" password => "anypoint-password" - environments => "ints|prod" + environments => "ints|prod" + sincedb_folder => "/temp/cloudhub_db" + sincedb_prefix => "since_" interval => 30 proxy_host => "proxy-host" proxy_port => 8080 diff --git a/lib/logstash/inputs/cloudhub.rb b/lib/logstash/inputs/cloudhub.rb index 92c2df1..f45b92e 100644 --- a/lib/logstash/inputs/cloudhub.rb +++ b/lib/logstash/inputs/cloudhub.rb @@ -34,6 +34,12 @@ class LogStash::Inputs::Cloudhub < LogStash::Inputs::Base # Default: 100 config :events_per_call, :validate => :number, :default => 100 + # Folder for sincedb files, default is /data/plugins/cloudhub + config :sincedb_folder, :validate => :string, :default => nil + + # File name prefix for sincedb files, default is 'sincedb-' + config :sincedb_prefix, :validate => :string, :default => 'sincedb-' + # Host name of web proxy config :proxy_host, :validate => :string @@ -51,7 +57,7 @@ class LogStash::Inputs::Cloudhub < LogStash::Inputs::Base public def register @host = Socket.gethostname - @sincedb = SinceDB.new + @sincedb = SinceDB.new @sincedb_folder, @sincedb_prefix end def run(queue)