Method: Fluent::Plugin::TailInput::GroupWatch#find_group

Defined in:
lib/fluent/plugin/in_tail/group_watch.rb

#find_group(metadata) ⇒ Object 



111
112
113
114
115
116
117
 
# File 'lib/fluent/plugin/in_tail/group_watch.rb', line 111

def find_group(metadata)
  metadata_key = construct_group_key(metadata)
  gw_key = @group_watchers.keys.find { |regexp| metadata_key.match?(regexp) && regexp != @default_group_key }
  gw_key ||= @default_group_key

  @group_watchers[gw_key]
end