Class: Analytics::UsageTrends::Measurement

Inherits:
ApplicationRecord show all
Defined in:
app/models/analytics/usage_trends/measurement.rb

Constant Summary

Constants inherited from ApplicationRecord

ApplicationRecord::MAX_PLUCK

Constants included from HasCheckConstraints

HasCheckConstraints::NOT_NULL_CHECK_PATTERN

Constants included from ResetOnColumnErrors

ResetOnColumnErrors::MAX_RESET_PERIOD

Class Method Summary collapse

Methods inherited from ApplicationRecord

===, cached_column_list, #create_or_load_association, current_transaction, declarative_enum, default_select_columns, delete_all_returning, #deleted_from_database?, id_in, id_not_in, iid_in, nullable_column?, primary_key_in, #readable_by?, safe_ensure_unique, safe_find_or_create_by, safe_find_or_create_by!, #to_ability_name, underscore, where_exists, where_not_exists, with_fast_read_statement_timeout, without_order

Methods included from Organizations::Sharding

#sharding_organization

Methods included from ResetOnColumnErrors

#reset_on_union_error, #reset_on_unknown_attribute_error

Methods included from Gitlab::SensitiveSerializableHash

#serializable_hash

Class Method Details

.find_latest_or_fallback(identifier) ⇒ Object 



60
61
62
 
# File 'app/models/analytics/usage_trends/measurement.rb', line 60

def self.find_latest_or_fallback(identifier)
  with_identifier(identifier).order_by_latest.first || identifier_query_mapping[identifiers[identifier]].call
end

.identifier_min_max_queries ⇒ Object

Customized min and max calculation, in some cases using the original scope is too slow.



46
47
48
49
50
51
52
53
54
 
# File 'app/models/analytics/usage_trends/measurement.rb', line 46

def self.identifier_min_max_queries
  {
    # Increase query performance by not using filters when fetching min/max ids
    identifiers[:issues] => {
      minimum_query: -> { ::Issue.minimum(:id) },
      maximum_query: -> { ::Issue.maximum(:id) }
    }
  }
end

.identifier_query_mapping ⇒ Object 



30
31
32
33
34
35
36
37
38
39
40
41
42
43
 
# File 'app/models/analytics/usage_trends/measurement.rb', line 30

def self.identifier_query_mapping
  {
    identifiers[:projects] => -> { Project },
    identifiers[:users] => -> { User },
    identifiers[:issues] => -> { Issue.where.not(project_id: nil) }, # Excludes group-level issues
    identifiers[:merge_requests] => -> { MergeRequest },
    identifiers[:groups] => -> { Group },
    identifiers[:pipelines] => -> { Ci::Pipeline },
    identifiers[:pipelines_succeeded] => -> { Ci::Pipeline.success },
    identifiers[:pipelines_failed] => -> { Ci::Pipeline.failed },
    identifiers[:pipelines_canceled] => -> { Ci::Pipeline.canceled },
    identifiers[:pipelines_skipped] => -> { Ci::Pipeline.skipped }
  }
end

.measurement_identifier_values ⇒ Object 



56
57
58
 
# File 'app/models/analytics/usage_trends/measurement.rb', line 56

def self.measurement_identifier_values
  identifiers.values
end