Class: Loggr::FluentEvent

Inherits:
Object
  • Object
show all
Defined in:
lib/loggr-rb/events.rb

Instance Method Summary collapse

Constructor Details

#initialize(callback = nil) ⇒ FluentEvent

Returns a new instance of FluentEvent.



52
53
54
55
 
# File 'lib/loggr-rb/events.rb', line 52

def initialize(callback=nil)
	  @callback = callback
  @event = Event.new()
end

Instance Method Details

#add_data(text) ⇒ Object 



112
113
114
115
 
# File 'lib/loggr-rb/events.rb', line 112

def add_data(text)
  @event.data = sprintf("%s%s", @event.data, text)
  return self
end

#add_dataf(fmt, *args) ⇒ Object 



117
118
119
120
 
# File 'lib/loggr-rb/events.rb', line 117

def add_dataf(fmt, *args)
  self.add_data(sprintf(fmt, args))
  return self
end

#add_tags(tags) ⇒ Object 



137
138
139
140
 
# File 'lib/loggr-rb/events.rb', line 137

def add_tags(tags)
  @event.tags = sprintf("%s %s", @event.tags, tags)
  return self
end

#add_text(text) ⇒ Object 



75
76
77
78
 
# File 'lib/loggr-rb/events.rb', line 75

def add_text(text)
  @event.text = sprintf("%s%s", @event.text, text)
  return self
end

#add_textf(fmt, *args) ⇒ Object 



80
81
82
83
 
# File 'lib/loggr-rb/events.rb', line 80

def add_textf(fmt, *args)
  self.add_text(sprintf(fmt, args))
  return self
end

#assign_w_macros(input, base) ⇒ Object 



162
163
164
165
166
167
 
# File 'lib/loggr-rb/events.rb', line 162

def assign_w_macros(input, base)
  if base.nil?
    base = ""
  end
  return input.gsub("$$", base)
end

#data(text) ⇒ Object 



103
104
105
106
 
# File 'lib/loggr-rb/events.rb', line 103

def data(text)
  @event.data = self.assign_w_macros(text, @event.data)
  return self
end

#dataf(fmt, *args) ⇒ Object 



108
109
110
 
# File 'lib/loggr-rb/events.rb', line 108

def dataf(fmt, *args)
  self.data(sprintf(fmt, args))
end

#datatype(t) ⇒ Object 



142
143
144
145
 
# File 'lib/loggr-rb/events.rb', line 142

def datatype(t)
  @event.datatype = t
  return self
end

#geo(lat, lon) ⇒ Object 



147
148
149
150
 
# File 'lib/loggr-rb/events.rb', line 147

def geo(lat, lon)
  @event.geo = sprintf("%d,%d", lat, lon)
  return self
end

#geo_clear ⇒ Object 



157
158
159
160
 
# File 'lib/loggr-rb/events.rb', line 157

def geo_clear()
  @event.geo = nil
  return self
end

#geo_ip(ip) ⇒ Object 



152
153
154
155
 
# File 'lib/loggr-rb/events.rb', line 152

def geo_ip(ip)
  @event.geo = sprintf("ip:%s", ip)
  return self
end

#link(text) ⇒ Object 



94
95
96
97
 
# File 'lib/loggr-rb/events.rb', line 94

def link(text)
  @event.link = self.assign_w_macros(text, @event.link)
  return self
end

#linkf(fmt, *args) ⇒ Object 



99
100
101
 
# File 'lib/loggr-rb/events.rb', line 99

def linkf(fmt, *args)
  self.link(sprintf(fmt, args))
end

#post(async = true) ⇒ Object 



57
58
59
60
61
62
63
 
# File 'lib/loggr-rb/events.rb', line 57

def post(async=true)
	  if !@callback.nil?
 @callback.call(self)
	  end
  client = LogClient.new()
  client.post(@event, async)
end

#source(text) ⇒ Object 



85
86
87
88
 
# File 'lib/loggr-rb/events.rb', line 85

def source(text)
  @event.source = self.assign_w_macros(text, @event.source)
  return self
end

#sourcef(fmt, *args) ⇒ Object 



90
91
92
 
# File 'lib/loggr-rb/events.rb', line 90

def sourcef(fmt, *args)
  self.source(sprintf(fmt, args))
end

#tags(tags) ⇒ Object 



132
133
134
135
 
# File 'lib/loggr-rb/events.rb', line 132

def tags(tags)
  @event.tags = tags
  return self
end

#text(text) ⇒ Object 



65
66
67
68
 
# File 'lib/loggr-rb/events.rb', line 65

def text(text)
  @event.text = self.assign_w_macros(text, @event.text)
  return self
end

#textf(fmt, *args) ⇒ Object 



70
71
72
73
 
# File 'lib/loggr-rb/events.rb', line 70

def textf(fmt, *args)
  self.text(sprintf(fmt, args))
  return self
end

#value(val) ⇒ Object 



122
123
124
125
 
# File 'lib/loggr-rb/events.rb', line 122

def value(val)
  @event.value = val
  return self
end

#value_clear ⇒ Object 



127
128
129
130
 
# File 'lib/loggr-rb/events.rb', line 127

def value_clear()
  @event.value = nil
  return self
end