Sha256: 2ed3e8409ca03bbf13fcd8b2e91b2685af2f097b1a2cbef9847621788efc142e
Contents?: true
Size: 860 Bytes
Versions: 59
Compression:
Stored size: 860 Bytes
Contents
require 'flydata/helper/base_action'
require 'flydata/util/file_util'
require 'flydata/api_client'
module Flydata
module Helper
module Action
class SendLogs < BaseAction
include Util::FileUtil
DEFAULT_NUM_OF_LINES = 100
def initialize(config)
super
@api_client = ApiClient.instance
end
def execute(opts = {})
log_debug("Sending logs")
num_of_lines = DEFAULT_NUM_OF_LINES
action_id = opts[:id]
begin
num_of_lines = JSON.parse(opts[:config])["num_of_lines"].to_i
rescue
# Use default number of lines if config is nil, mal-formed etc
end
tailed_lines = tail(FLYDATA_LOG, num_of_lines)
@api_client.agent.send_logs(action_id, tailed_lines)
end
end
end
end
end
Version data entries
59 entries across 59 versions & 1 rubygems