Class: LaunchDarkly::EventSummarizer

Inherits:
Object
  • Object
show all
Defined in:
lib/ldclient-rb/event_summarizer.rb

Overview

Manages the state of summarizable information for the EventProcessor, including the event counters and user deduplication. Note that the methods of this class are deliberately not thread-safe; the EventProcessor is responsible for enforcing synchronization across both the summarizer and the event queue.

Instance Method Summary collapse

Constructor Details

#initialize ⇒ EventSummarizer

Returns a new instance of EventSummarizer.



10
11
12
 
# File 'lib/ldclient-rb/event_summarizer.rb', line 10

def initialize
  clear
end

Instance Method Details

#clear ⇒ Object 



46
47
48
49
50
 
# File 'lib/ldclient-rb/event_summarizer.rb', line 46

def clear
  @start_date = 0
  @end_date = 0
  @counters = {}
end

#snapshot ⇒ Object

Returns a snapshot of the current summarized event data, and resets this state.



41
42
43
44
 
# File 'lib/ldclient-rb/event_summarizer.rb', line 41

def snapshot
  ret = EventSummary.new(@start_date, @end_date, @counters)
  ret
end

#summarize_event(event) ⇒ Object

Adds this event to our counters, if it is a type of event we need to count.



15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
 
# File 'lib/ldclient-rb/event_summarizer.rb', line 15

def summarize_event(event)
  if event[:kind] == "feature"
    counter_key = {
      key: event[:key],
      version: event[:version],
      variation: event[:variation]
    }
    c = @counters[counter_key]
    if c.nil?
      @counters[counter_key] = {
        value: event[:value],
        default: event[:default],
        count: 1
      }
    else
      c[:count] = c[:count] + 1
    end
    time = event[:creationDate]
    if !time.nil?
      @start_date = time if @start_date == 0 || time < @start_date
      @end_date = time if time > @end_date
    end
  end
end