Class: Sentiero::Analytics::StatsAggregator

Inherits:
Analyzer
  • Object
show all
Defined in:
lib/sentiero/analytics/stats_aggregator.rb,
lib/sentiero/analytics/stats_aggregator/result_builder.rb

Defined Under Namespace

Classes: Accumulator, ResultBuilder

Constant Summary collapse

TOP_LIST_LIMIT = 
10
TOP_TAGS_LIMIT = 
20
TOP_PROBLEMS_LIMIT = 
5
"navigation"
INTERNAL_METADATA_KEYS = 
%w[userAgent url referrer viewport has_errors entry_url entry_referrer].freeze
MAX_NAV_KEYS = 
200
MAX_METADATA_KEYS = 
50
MAX_METADATA_VALUES_PER_KEY = 
50
MAX_TAG_SERIES_KEYS = 
200
MAX_OVERLAY_PROBLEMS = 
200
MAX_OCCURRENCES_PER_PROBLEM = 
500
DURATION_BUCKETS = 
[
  ["0-30s", 30_000],
  ["30s-2m", 120_000],
  ["2-5m", 300_000],
  ["5-15m", 900_000],
  ["15m+", nil]
].freeze
WEEK_BUCKET_THRESHOLD_DAYS = 
45

Constants included from Events

Events::CUSTOM, Events::INCREMENTAL, Events::META, Events::SOURCE_INPUT, Events::SOURCE_MOUSE_INTERACTION, Events::SOURCE_SCROLL

Instance Attribute Summary

Attributes inherited from Analyzer

#store

Instance Method Summary collapse

Methods inherited from Analyzer

#initialize

Methods included from EntryAttribution

#earlier?, #first_meta_href, #same_origin?, #update_entry_candidate

Methods included from Bounded

#bounded_fetch, #bounded_increment

Methods included from Stats

#mean, #offset_ms, #percentile, #top_counts

Constructor Details

This class inherits a constructor from Sentiero::Analytics::Analyzer

Instance Method Details

#aggregate(range_days: 30, since: nil, until_time: nil, server_exception_overlay: false) ⇒ Object 



40
41
42
43
44
45
46
47
48
49
50
51
52
 
# File 'lib/sentiero/analytics/stats_aggregator.rb', line 40

def aggregate(range_days: 30, since: nil, until_time: nil, server_exception_overlay: false)
  scan_cap = store.limits.analytics_max_scan_sessions
  since ||= default_since(range_days, until_time)

  acc = new_accumulator(since, until_time)
  seen_sessions = {}

  store.each_session_events(limit: scan_cap, since: since, until_time: until_time) do |summary, _window_id, events|
    accumulate_window(acc, seen_sessions, summary, events)
  end

  finalize(acc, seen_sessions, scan_cap, overlay: server_exception_overlay)
end

#aggregate_with_prior(range_days: 30, since: nil, until_time: nil) ⇒ Object

Derives BOTH the current-window aggregate and the equal-length prior-window aggregate from a SINGLE widened scan over [prior_since, until_time], partitioning each session into the current or prior bucket by its updated_at. Returns prior:; prior is nil when no comparison is possible (zero-length window) or when the widened scan is truncated — in which case the current aggregate is recomputed from an exact single-window scan so the displayed numbers stay correct (deltas are dropped on truncation anyway).



62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
 
# File 'lib/sentiero/analytics/stats_aggregator.rb', line 62

def aggregate_with_prior(range_days: 30, since: nil, until_time: nil)
  scan_cap = store.limits.analytics_max_scan_sessions
  since ||= default_since(range_days, until_time)
  window_until = until_time || Time.now.to_f
  span = window_until - since

  return {current: aggregate(since: since, until_time: until_time, server_exception_overlay: true), prior: nil} unless span > 0

  prior_since = since - span
  prior_until = since - 0.001

  current = {acc: new_accumulator(since, until_time), seen: {}}
  prior = {acc: new_accumulator(prior_since, prior_until), seen: {}}

  store.each_session_events(limit: scan_cap, since: prior_since, until_time: until_time) do |summary, _window_id, events|
    bucket = (summary[:updated_at] >= since) ? current : prior
    accumulate_window(bucket[:acc], bucket[:seen], summary, events)
  end

  if current[:seen].size + prior[:seen].size >= scan_cap
    return {current: aggregate(since: since, until_time: until_time, server_exception_overlay: true), prior: nil}
  end

  {
    current: finalize(current[:acc], current[:seen], scan_cap, overlay: true),
    prior: finalize(prior[:acc], prior[:seen], scan_cap, overlay: false)
  }
end