Method: Fluent::Plugin::TailInput::GroupWatch#find_group_from_metadata

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

#find_group_from_metadata(path) ⇒ Object 



119
120
121
122
123
124
125
126
127
128
129
 
# File 'lib/fluent/plugin/in_tail/group_watch.rb', line 119

def find_group_from_metadata(path)
  begin
    metadata = @group.pattern.match(path).named_captures
    group_watcher = find_group(metadata)
  rescue
    log.warn "Cannot find group from metadata, Adding file in the default group"
    group_watcher = @group_watchers[@default_group_key]
  end

  group_watcher
end