class TagUpdater
Public Instance Methods
update_tag(tag, remove_tag_prefix, add_tag_prefix)
click to toggle source
# File lib/fluent/plugin/tag_updater.rb, line 3 def update_tag(tag, remove_tag_prefix, add_tag_prefix) new_tag = tag if (remove_tag_prefix && tag.start_with?(remove_tag_prefix)) new_tag = new_tag.sub(remove_tag_prefix, "") end if (add_tag_prefix) new_tag = "#{add_tag_prefix}#{new_tag}" end new_tag end