raise exception after exiting watcher.each (#214)

* raise exception after exiting watcher.each

* raise exception when ERROR received while watching

* reset watch_retry_count after resourceVersion retrieved from API server

* remove watch_retry_count resets, it was handled in another PR which is already merged

Author: mszabo

lib/fluent/plugin/kubernetes_metadata_watch_namespaces.rb

@@ -113,6 +113,9 @@ def process_namespace_watcher_notices(watcher)
             # ignore and let age out for cases where
             # deleted but still processing logs
             @stats.bump(:namespace_cache_watch_deletes_ignored)
+          when 'ERROR'
+            message = notice['object']['message'] if notice['object'] && notice['object']['message']
+            raise "Error while watching namespaces: #{message}"
           else
             # Don't pay attention to creations, since the created namespace may not
             # be used by any namespace on this node.

lib/fluent/plugin/kubernetes_metadata_watch_pods.rb

@@ -120,6 +120,9 @@ def process_pod_watcher_notices(watcher)
             # ignore and let age out for cases where pods
             # deleted but still processing logs
             @stats.bump(:pod_cache_watch_delete_ignored)
+          when 'ERROR'
+            message = notice['object']['message'] if notice['object'] && notice['object']['message']
+            raise "Error while watching pods: #{message}"
           else
             Thread.current[:pod_watch_retry_count] = 0
             # Don't pay attention to creations, since the created pod may not