Sha256: 4f06e735df6f46d0868a3d5abebfc6b5debced2fab361459302086492d2542ac
Contents?: true
Size: 1.61 KB
Versions: 35
Compression:
Stored size: 1.61 KB
Contents
# encoding: utf-8
require 'forwardable'
require 'one_apm/support/rules_engine/replacement_rule'
require 'one_apm/support/rules_engine/segment_terms_rule'
module OneApm
module Support
class RulesEngine
SEGMENT_SEPARATOR = '/'.freeze
LEADING_SLASH_REGEX = %r{^/}.freeze
include Enumerable
extend Forwardable
def_delegators :@rules, :size, :inspect, :each, :clear
def self.create_metric_rules(connect_response)
specs = connect_response['metric_name_rules'] || []
rules = specs.map { |spec| ReplacementRule.new(spec) }
self.new(rules)
end
def self.create_transaction_rules(connect_response)
txn_name_specs = connect_response['transaction_name_rules'] || []
segment_rule_specs = connect_response['transaction_segment_terms'] || []
txn_name_rules = txn_name_specs.map { |s| ReplacementRule.new(s) }
segment_rules = segment_rule_specs.map { |s| SegmentTermsRule.new(s) }
self.new(txn_name_rules, segment_rules)
end
def initialize(rules=[], segment_term_rules=[])
@rules = rules.sort
@segment_term_rules = segment_term_rules
end
def apply_rules(rules, string)
rules.each do |rule|
if rule.matches?(string)
string = rule.apply(string)
break if rule.terminal?
end
end
string
end
def rename(original_string)
renamed = apply_rules(@rules, original_string)
return nil unless renamed
renamed = apply_rules(@segment_term_rules, renamed)
renamed
end
end
end
end
Version data entries
35 entries across 35 versions & 1 rubygems