Path and prefix of sincedb configurable (#14)

yevmel · Mar 1, 2017 · f2781d2 · f2781d2
1 parent b0c3a8a
commit f2781d2
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git 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
@@ -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 <logstash>/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)