Class: LogStash::Outputs::Tracker

Inherits:
Object
  • Object
show all
Defined in:
lib/logstash/outputs/tracker.rb

Instance Method Summary collapse

Constructor Details

#initialize(emitter, base64 = true) ⇒ Tracker

Returns a new instance of Tracker.



4
5
6
7
8
 
# File 'lib/logstash/outputs/tracker.rb', line 4

def initialize(emitter, base64 = true)
  @emitter = emitter
  @trackers = {}
  @base64 = base64
end

Instance Method Details

#track(event) ⇒ Object 



10
11
12
13
 
# File 'lib/logstash/outputs/tracker.rb', line 10

def track(event)
  tracker_of(event).track_unstruct_event SnowplowTracker::SelfDescribingJson.new(
    event["schema"], JSON.parse(event["message"]))
end