Module: LogStash::Outputs::SumoLogic::Common

Included in:
LogStash::Outputs::SumoLogic, Compressor, HeaderBuilder, MessageQueue, Monitor, PayloadBuilder, Piler, Sender, Statistics
Defined in:
lib/logstash/outputs/sumologic/common.rb

Constant Summary collapse

DEFAULT_LOG_FORMAT =

global constants

"%{@timestamp} %{host} %{message}"
METRICS_NAME_PLACEHOLDER = 
"*"
GRAPHITE = 
"graphite"
CARBON2 = 
"carbon2"
DEFLATE = 
"deflate"
GZIP = 
"gzip"
STATS_TAG = 
"STATS_TAG"
STOP_TAG = 
"PLUGIN STOPPED"
CONTENT_TYPE = 
"Content-Type"
CONTENT_TYPE_LOG = 
"text/plain"
CONTENT_TYPE_GRAPHITE = 
"application/vnd.sumologic.graphite"
CONTENT_TYPE_CARBON2 = 
"application/vnd.sumologic.carbon2"
CONTENT_ENCODING = 
"Content-Encoding"
CATEGORY_HEADER = 
"X-Sumo-Category"
CATEGORY_HEADER_DEFAULT = 
"Logstash"
CATEGORY_HEADER_DEFAULT_STATS = 
"Logstash.stats"
HOST_HEADER = 
"X-Sumo-Host"
NAME_HEADER = 
"X-Sumo-Name"
NAME_HEADER_DEFAULT = 
"logstash-output-sumologic"
CLIENT_HEADER = 
"X-Sumo-Client"
CLIENT_HEADER_VALUE = 
"logstash-output-sumologic"
LOG_TO_CONSOLE =

for debugging test

false
@@logger = 
nil

Instance Method Summary collapse

Instance Method Details

#blank?(value) ⇒ Boolean

def log_dbg

Returns:

  • (Boolean) 


73
74
75
76
77
78
79
80
81
 
# File 'lib/logstash/outputs/sumologic/common.rb', line 73

def blank?(value)
  if value.kind_of?(NilClass)
    true
  elsif value.kind_of?(String)
    value !~ /\S/
  else
    value.respond_to?(:empty?) ? value.empty? : !value
  end
end

#log_dbg(message, *opts) ⇒ Object

def log_err



65
66
67
68
69
70
71
 
# File 'lib/logstash/outputs/sumologic/common.rb', line 65

def log_dbg(message, *opts)
  if LOG_TO_CONSOLE
    puts "\e[36m[DBG :#{DateTime::now}]#{message} #{opts.to_s}\e[0m"
  else
    @@logger && @@logger.debug(message, *opts)
  end
end

#log_err(message, *opts) ⇒ Object

def log_warn



57
58
59
60
61
62
63
 
# File 'lib/logstash/outputs/sumologic/common.rb', line 57

def log_err(message, *opts)
  if LOG_TO_CONSOLE
    puts "\e[31m[ERR :#{DateTime::now}]#{message} #{opts.to_s}\e[0m"
  else
    @@logger && @@logger.error(message, *opts)
  end
end

#log_info(message, *opts) ⇒ Object 



41
42
43
44
45
46
47
 
# File 'lib/logstash/outputs/sumologic/common.rb', line 41

def log_info(message, *opts)
  if LOG_TO_CONSOLE
    puts "[INFO:#{DateTime::now}]#{message} #{opts.to_s}"
  else
    @@logger && @@logger.info(message, *opts)
  end
end

#log_warn(message, *opts) ⇒ Object

def log_info



49
50
51
52
53
54
55
 
# File 'lib/logstash/outputs/sumologic/common.rb', line 49

def log_warn(message, *opts)
  if LOG_TO_CONSOLE
    puts "\e[33m[WARN:#{DateTime::now}]#{message} #{opts.to_s}\e[0m"
  else
    @@logger && @@logger.warn(message, *opts)
  end
end

#set_logger(logger) ⇒ Object 



37
38
39
 
# File 'lib/logstash/outputs/sumologic/common.rb', line 37

def set_logger(logger)
  @@logger = logger
end