lib/fluent/plugin/out_couch.rb in fluent-plugin-couch-0.3.0 vs lib/fluent/plugin/out_couch.rb in fluent-plugin-couch-0.3.2

@@ -12,10 +12,13 @@
 
         config_param :host, :string, :default => 'localhost'
         config_param :port, :string, :default => '5984'
 
         config_param :refresh_view_index , :string, :default => nil
+        
+        config_param :user, :string, :default => nil
+        config_param :password, :string, :default => nil
 
         def initialize
             super
             Encoding.default_internal = 'UTF-8'
             require 'msgpack'
@@ -26,14 +29,22 @@
             super
         end
 
         def start
             super
-            @db = CouchRest.database("http://#{@host}:#{@port}/#{@database}")
+            if @user && @password
+                @db = CouchRest.database!("http://#{@user}:#{@password}@#{@host}:#{@port}/#{@database}")
+            else
+                @db = CouchRest.database!("http://#{@host}:#{@port}/#{@database}")
+            end
             @views = []
-            unless @refresh_view_index.nil?
-                @db.get("_design/#{@refresh_view_index}")['views'].each do |view_name,func|
-                    @views.push([@refresh_view_index,view_name])
+            if @refresh_view_index
+                begin
+                    @db.get("_design/#{@refresh_view_index}")['views'].each do |view_name,func|
+                        @views.push([@refresh_view_index,view_name])
+                    end
+                rescue
+                    puts 'design document not found!'
                 end
             end
         end
 
         def shutdown