replace NoMatchMatch: a plugin (out_reemit) uses it...

fluent · Jan 10, 2017 · 1705933 · 1705933
1 parent e313703
commit 1705933
Show file tree

Hide file tree

Showing 2 changed files with 37 additions and 37 deletions.
diff --git a/lib/fluent/event_router.rb b/lib/fluent/event_router.rb
@@ -266,4 +266,41 @@ def find(tag)
       end
     end
   end
+
+  class NoMatchMatch
+    def initialize(log)
+      @log = log
+      @count = 0
+      @warn_not_matched = true
+    end
+
+    def suppress_missing_match!
+      # for <label @FLUENT_LOG>
+      @warn_not_matched = false
+    end
+
+    def emit_events(tag, es)
+      return unless @warn_not_matched
+      # TODO use time instead of num of records
+      c = (@count += 1)
+      if c < 512
+        if Math.log(c) / Math.log(2) % 1.0 == 0
+          @log.warn "no patterns matched", tag: tag
+          return
+        end
+      else
+        if c % 512 == 0
+          @log.warn "no patterns matched", tag: tag
+          return
+        end
+      end
+      @log.on_trace { @log.trace "no patterns matched", tag: tag }
+    end
+
+    def start
+    end
+
+    def shutdown
+    end
+  end
 end
diff --git a/lib/fluent/match.rb b/lib/fluent/match.rb
@@ -138,41 +138,4 @@ def match(str)
       @patterns.any? {|pattern| pattern.match(str) }
     end
   end
-
-  class NoMatchMatch
-    def initialize(log)
-      @log = log
-      @count = 0
-      @warn_not_matched = true
-    end
-
-    def suppress_missing_match!
-      # for <label @FLUENT_LOG>
-      @warn_not_matched = false
-    end
-
-    def emit_events(tag, es)
-      return unless @warn_not_matched
-      # TODO use time instead of num of records
-      c = (@count += 1)
-      if c < 512
-        if Math.log(c) / Math.log(2) % 1.0 == 0
-          @log.warn "no patterns matched", tag: tag
-          return
-        end
-      else
-        if c % 512 == 0
-          @log.warn "no patterns matched", tag: tag
-          return
-        end
-      end
-      @log.on_trace { @log.trace "no patterns matched", tag: tag }
-    end
-
-    def start
-    end
-
-    def shutdown
-    end
-  end
 end