lib/logstash-logger/device.rb in logstash-logger-0.6.2 vs lib/logstash-logger/device.rb in logstash-logger-0.7.0

@@ -10,25 +10,39 @@
     autoload :UDP, 'logstash-logger/device/udp'
     autoload :TCP, 'logstash-logger/device/tcp'
     autoload :Unix, 'logstash-logger/device/unix'
     autoload :Redis, 'logstash-logger/device/redis'
     autoload :File, 'logstash-logger/device/file'
+    autoload :IO, 'logstash-logger/device/io'
     autoload :Stdout, 'logstash-logger/device/stdout'
 
     def self.new(opts)
       opts = opts.dup
+
+      if parsed_uri_opts = parse_uri_config(opts)
+        opts = parsed_uri_opts
+      end
+
       type = opts.delete(:type) || DEFAULT_TYPE
 
       device_klass_for(type).new(opts)
     end
 
+    def self.parse_uri_config(opts)
+      if uri = opts[:uri]
+        parsed = ::URI.parse(uri)
+        {type: parsed.scheme, host: parsed.host, port: parsed.port, path: parsed.path}
+      end
+    end
+
     def self.device_klass_for(type)
       case type.to_sym
         when :udp then UDP
         when :tcp then TCP
         when :unix then Unix
         when :file then File
         when :redis then Redis
+        when :io then IO
         when :stdout then Stdout
         else fail ArgumentError, 'Invalid type'
       end
     end
   end