out_tdlog.rb in fluent-plugin-td-0.10.3

- old
+ new

@@ -2,22 +2,10 @@
 
 
 class TreasureDataLogOutput < BufferedOutput
   Plugin.register_output('tdlog', self)
 
-  host = 'api.treasure-data.com'
-  port = 80
-  if e = ENV['TD_API_SERVER']
-    host, port_ = e.split(':',2)
-    port_ = port_.to_i
-    port = port_ if port_ != 0
-  end
-
-  HOST = host
-  PORT = port
-  USE_SSL = false
-  BASE_URL = ''
   IMPORT_SIZE_LIMIT = 32*1024*1024
 
   def initialize
     require 'fileutils'
     require 'tempfile'
@@ -33,10 +21,11 @@
     @key = nil
     @key_num_limit = 5120  # TODO
     @record_size_limit = 32*1024*1024  # TODO
     @table_list = []
     @auto_create_table = true
+    @use_ssl = false
     @buffer_type = 'file'  # overwrite default buffer_type
     @flush_interval = 300  # overwrite default flush_interval to 5mins
   end
 
   def configure(conf)
@@ -68,10 +57,21 @@
           raise ConfigError, "'true' or 'false' is required for auto_create_table option on tdlog output"
         end
       end
     end
 
+    if use_ssl = conf['use_ssl']
+      if use_ssl.empty?
+        @use_ssl = true
+      else
+        @use_ssl = Config.bool_value(use_ssl)
+        if @use_ssl == nil
+          raise ConfigError, "'true' or 'false' is required for use_ssl option on tdlog output"
+        end
+      end
+    end
+
     unless @auto_create_table
       database = conf['database']
       table = conf['table']
 
       if !database || !table
@@ -91,10 +91,10 @@
     end
   end
 
   def start
     super
-    @client = TreasureData::Client.new(@apikey)
+    @client = TreasureData::Client.new(@apikey, :ssl=>@use_ssl)
     unless @auto_create_table
       check_table_exists(@key)
     end
   end
 