cli.rb in fluentd-server-0.3.0

- old
+ new

@@ -21,15 +21,19 @@
 JOB_DIR=#{JOB_DIR}
 LOG_PATH=#{LOG_FILE}
 LOG_LEVEL=warn
 LOG_SHIFT_AGE=0
 LOG_SHIFT_SIZE=1048576
+LOCAL_STORAGE=false
+DATA_DIR=#{DATA_DIR}
+SYNC_INTERVAL=60
 EOS
 
   DEFAULT_PROCFILE =<<-EOS
 web: unicorn -E production -p $PORT -o $HOST -c config/unicorn.conf
 job: fluentd-server job
+sync: fluentd-server sync
 serf: $(gem path serf-td-agent)/bin/serf agent
 EOS
 
   default_command :start
 
@@ -101,9 +105,16 @@
   def job_clear
     Dotenv.load
     require 'delayed_job'
     require 'fluentd_server/model'
     Delayed::Job.delete_all
+  end
+
+  desc "sync", "Sartup fluentd_server sync worker"
+  def sync
+    Dotenv.load
+    require 'fluentd_server/sync_worker'
+    FluentdServer::SyncWorker.start
   end
 
   no_tasks do
     def abort(msg)
       $stderr.puts msg