RubyGems - fluent-plugin-watch-process - Versions diffs - 0.1.1 → 0.2.0 - Mend

fluent-plugin-watch-process 0.1.1 → 0.2.0

This diff represents the content of publicly available package versions that have been released to one of the supported registries. The information contained in this diff is provided for informational purposes only and reflects changes between package versions as they appear in their respective public registries.

Files changed (9) hide show

checksums.yaml +7 -0
data/.travis.yml +0 -7
data/README.md +58 -4
data/fluent-plugin-watch-process.gemspec +3 -3
data/lib/fluent/plugin/in_watch_process.rb +167 -46
data/test/helper.rb +1 -9
data/test/plugin/test_in_watch_process.rb +99 -1
metadata +32 -41
data/gemfiles/fluentd_v0.12.gemfile +0 -7

checksums.yaml ADDED Viewed

@@ -0,0 +1,7 @@
+---
+SHA256:
+  metadata.gz: 2d114a31b165c3feca90dac92247785d9f757e8951ded1aac49bc30806e505a1
+  data.tar.gz: 9a2aab2afb95873873e3e3581b2f5f23b12bd0e7062d456b7eebe257c7f8473a
+SHA512:
+  metadata.gz: ad4b0bffb25faaed2082c8bab5904100750ee265113097a0f643d5c13305c53731a9afcb6bd0b661fba1d012b45e74294c57defd530a774fbaf052135bcb6f43
+  data.tar.gz: 8f4761bfec54a36ecb2f702d7749ce4fd21bb69f35834aaeef274167456de74e0e8c4d7d09bdaaa90dc9bc3647d66eafbeb16d81ca24aede35fb4d273edd7e43

data/.travis.yml CHANGED Viewed

@@ -10,11 +10,4 @@ before_install:
 gemfile:
   - Gemfile
-  - gemfiles/fluentd_v0.12.gemfile
   - gemfiles/fluentd_v0.14.gemfile
-matrix:
-  include:
-    - rvm: 2.0.0
-      gemfile: gemfiles/fluentd_v0.12.gemfile

data/README.md CHANGED Viewed

@@ -25,10 +25,10 @@ install with gem or fluent-gem command as:
 $ gem install fluent-plugin-watch-process
 # for td-agent
-$ sudo /usr/lib64/fluent/ruby/bin/fluent-gem install fluent-plugin-watch-process -v 0.1.0
+$ sudo /usr/lib64/fluent/ruby/bin/fluent-gem install fluent-plugin-watch-process -v 0.1.1
 # for td-agent2 (recommend)
-$ sudo td-agent-gem install fluent-plugin-watch-process -v 0.1.0
+$ sudo td-agent-gem install fluent-plugin-watch-process -v 0.1.1
 ```
 ## Configuration
@@ -68,14 +68,20 @@ $ tail -f /var/log/td-agent/td-agent.log
   * execute ps command with some options
   * [default] Linux: `LANG=en_US.UTF-8 && ps -ewwo lstart,user:20,pid,ppid,time,%cpu,%mem,rss,sz,s,comm,cmd`
   * [default] MacOSX: `LANG=en_US.UTF-8 && ps -ewwo lstart,user,pid,ppid,time,%cpu,%mem,rss,vsz,state,comm,command`
+  * [default] Windows: described in the next section, `About Windows`.
 * keys (Optional)
   * output record keys of the ps command results
-  * [default] start_time user pid parent_pid cpu_time cpu_percent memory_percent mem_rss mem_size state proc_name command
+  * [default] Linux, MacOSX: `start_time,user,pid,parent_pid,cpu_time,cpu_percent,memory_percent,mem_rss,mem_size,state,proc_name,command`
+    * need to modify `command` too if you modify this value.
+  * [default] Windows: `StartTime,UserName,SessionId,Id,CPU,WorkingSet,VirtualMemorySize,HandleCount,ProcessName`
+    * in Windows only, you can fix this without fixing `command`. These keys can be specified from the properties of `System.Diagnostics.Process` object of `.NET`.
+    * `UserName` key needs administrator privilege. You can exclude this to avoid needing administrator privilege.
 * types (Optional)
   * settings of converting types from string to integer/float.
-  * [default] pid:integer parent_pid:integer cpu_percent:float memory_percent:float mem_rss:integer mem_size:integer
+  * [default] Linux, MacOSX: `pid:integer,parent_pid:integer,cpu_percent:float,memory_percent:float,mem_rss:integer,mem_size:integer`
+  * [default] Windows: `SessionId:integer,Id:integer,CPU:float,WorkingSet:integer,VirtualMemorySize:integer,HandleCount:integer`
 * interval (Optional)
   * execute interval time
@@ -90,6 +96,54 @@ $ tail -f /var/log/td-agent/td-agent.log
   * to use short hostname, set `hostname -s` for this option on linux/mac.
   * [default] `hostname`
+* powershell_command (Optional)
+  * settings for powershell command name. PowerShell Core had been renamed its command to `pwsh` and PowerShell 7 continues to use `pwsh` as its command name.
+  * [default] `powershell`
+  * [avaliables] `powershell`, `pwsh`
+### About Windows
+Default `command` preset for Windows provides many of keys as below. Generally, you can pick up the columns with `keys` option.
+If you need additional keys, consider to update `command` option.
+`````powershell
+powershell -command "Get-Process -IncludeUserName
+ | ?{$_.StartTime -ne $NULL -and $_.CPU -ne $NULL}
+ | Select-Object -Property StartTime,UserName,SessionId,Id,CPU,WorkingSet,VirtualMemorySize,HandleCount,ProcessName
+ | %{$_.StartTime = $_.StartTime.ToString('o'); return $_;}
+ | ConvertTo-Csv -NoTypeInformation"
+`````
+Confirmed versions are:
+|  Windows version               |  PowerShell version information                                           | Note                                          |
+| ------------------------------ | ------------------------------------------------------------------------- |-----------------------------------------------|
+|  Windows 10 10.0.19042 (20H2)  |  PSVersion: 5.1.19041.906 (default installed version), PSEdition: Desktop | `powershell_command` as `powershell` (default)|
+|  Windows 10 10.0.19042 (20H2)  |  PSVersion: 7.1.2, PSEdition: Core                                        | `powershell_command` as `pwsh`                |
+Here are details of this default command.
+* `Get-Process -IncludeUserName`
+  * `Get-Process` powershell command takes `System.Diagnostics.Process` objects.
+  * `IncludeUserName` option is needed to take `UserName`.
+    * this needs administrator privilege.
+    * this will be omitted if `keys` does not contain `UserName`.
+* ` | ?{$_.StartTime -ne $NULL -and $_.CPU -ne $NULL}`
+  * this exlcludes some special processes that don't have some properties, such as the "Idle" process in Windows.
+* ` | Select-Object -Property ...`
+  * this takes the necessary parameters from `System.Diagnostics.Process` objects.
+  * `...` part will be automatically fixed by `keys`.
+* ` | %{$_.StartTime = $_.StartTime.ToString('o'); return $_;}`
+  * this fixes the format of `StartTime` value.
+  * note: in Windows, setting the "$env:Lang" environment variable is not effective in changing the format of the output.
+* ` | ConvertTo-Csv -NoTypeInformation`
+  * this formats objects to csv strings.
+  * currently, it is needed that `command` outputs the results in csv format.
+    * this is because white space delimiter is not suitable for Windows, in which empty values are often mixed.
+**Note:** When using with PowerShell 7 which is previously known as PowerShell Core, you must specify `powershell_command` parameter as `pwsh`. Otherwise, this plugin does not work correctly on PowerShell 7 (pwsh). This is because PowerShell Core and PowerShell 7 use different command name which is `pwsh` not `powershell`.
 ## FAQ
 * I need hostname key in the record.

data/fluent-plugin-watch-process.gemspec CHANGED Viewed

@@ -3,11 +3,11 @@ $:.push File.expand_path("../lib", __FILE__)
 Gem::Specification.new do |s|
   s.name        = "fluent-plugin-watch-process"
-  s.version     = "0.1.1"
+  s.version     = "0.2.0"
   s.authors     = ["Kentaro Yoshida"]
   s.email       = ["y.ken.studio@gmail.com"]
   s.homepage    = "https://github.com/y-ken/fluent-plugin-watch-process"
-  s.summary     = %q{Fluentd Input plugin to collect continual process information via ps command. It is useful for cron/barch process monitoring.}
+  s.summary     = %q{Fluentd Input plugin to collect continual process information via ps command or PowerShell pwsh command for Linux/osx/Windows. It is useful for cron/barch process monitoring.}
   s.files         = `git ls-files`.split("\n")
   s.test_files    = `git ls-files -- {test,spec,features}/*`.split("\n")
@@ -18,7 +18,7 @@ Gem::Specification.new do |s|
   s.add_development_dependency "rake"
   s.add_development_dependency "test-unit", ">= 3.1.0"
   s.add_development_dependency "appraisal"
-  s.add_runtime_dependency "fluentd", ">= 0.10.58"
+  s.add_runtime_dependency "fluentd", [">= 0.14.0", "< 2"]
   s.add_runtime_dependency "fluent-mixin-rewrite-tag-name"
   s.add_runtime_dependency "fluent-mixin-type-converter", ">= 0.1.0"
 end

data/lib/fluent/plugin/in_watch_process.rb CHANGED Viewed

@@ -1,99 +1,220 @@
-require "fluent/input"
+require 'time'
+require 'csv' if Fluent.windows?
+require "fluent/plugin/input"
 require 'fluent/mixin/rewrite_tag_name'
 require 'fluent/mixin/type_converter'
-module Fluent
-  class WatchProcessInput < Fluent::Input
-    Plugin.register_input('watch_process', self)
+module Fluent::Plugin
+  class WatchProcessInput < Fluent::Plugin::Input
+    Fluent::Plugin.register_input('watch_process', self)
+    helpers :timer
+    DEFAULT_KEYS = %w(start_time user pid parent_pid cpu_time cpu_percent memory_percent mem_rss mem_size state proc_name command)
+    DEFAULT_TYPES = %w(
+      pid:integer
+      parent_pid:integer
+      cpu_percent:float
+      memory_percent:float
+      mem_rss:integer
+      mem_size:integer
+    ).join(",")
     config_param :tag, :string
     config_param :command, :string, :default => nil
-    config_param :keys, :string, :default => nil
-    config_param :interval, :string, :default => '5s'
-    config_param :lookup_user, :string, :default => nil
+    config_param :keys, :array, :default => nil
+    config_param :interval, :time, :default => '5s'
+    config_param :lookup_user, :array, :default => nil
     config_param :hostname_command, :string, :default => 'hostname'
-    DEFAULT_KEYS = %w(start_time user pid parent_pid cpu_time cpu_percent memory_percent mem_rss mem_size state proc_name command)
-    DEFAULT_TYPES = "pid:integer,parent_pid:integer,cpu_percent:float,memory_percent:float,mem_rss:integer,mem_size:integer"
+    config_param :powershell_command, :enum, list: [:powershell, :pwsh], :default => :powershell
     include Fluent::HandleTagNameMixin
     include Fluent::Mixin::RewriteTagName
     include Fluent::Mixin::TypeConverter
-    config_set_default :types, DEFAULT_TYPES
     def initialize
       super
-      require 'time'
     end
     def configure(conf)
       super
-      @command = @command || get_ps_command
-      @keys = @keys.nil? ? DEFAULT_KEYS : @keys.to_s.gsub(' ', '').split(',')
-      @lookup_user = @lookup_user.gsub(' ', '').split(',') unless @lookup_user.nil?
-      @interval = Config.time_value(@interval)
+      @windows_watcher = WindowsWatcher.new(@keys, @command, @lookup_user, @powershell_command) if Fluent.windows?
+      @keys ||= Fluent.windows? ? @windows_watcher.keys : DEFAULT_KEYS
+      @command ||= get_ps_command
+      apply_default_types
       log.info "watch_process: polling start. :tag=>#{@tag} :lookup_user=>#{@lookup_user} :interval=>#{@interval} :command=>#{@command}"
     end
     def start
-      @thread = Thread.new(&method(:run))
+      super
+      timer_execute(:in_watch_process, @interval, &method(:on_timer))
     end
     def shutdown
-      Thread.kill(@thread)
+      super
+    end
+    def apply_default_types
+      return unless @types.nil?
+      @types = Fluent.windows? ? @windows_watcher.default_types : DEFAULT_TYPES
+      @type_converters = parse_types_parameter unless @types.nil?
     end
-    def run
-      loop do
-        io = IO.popen(@command, 'r')
+    def on_timer
+      io = IO.popen(@command, 'r')
+      begin
         io.gets
         while result = io.gets
-          keys_size = @keys.size
-          if result =~ /(?<lstart>(^\w+\s+\w+\s+\d+\s+\d\d:\d\d:\d\d \d+))/
-            lstart = Time.parse($~[:lstart])
-            result = result.sub($~[:lstart], '')
-            keys_size -= 1
+          if Fluent.windows?
+            data = @windows_watcher.parse_line(result)
+            next unless @windows_watcher.match_look_up_user?(data)
+          else
+            data = parse_line(result)
+            next unless match_look_up_user?(data)
           end
-          values = [lstart.to_s, result.chomp.strip.split(/\s+/, keys_size)]
-          data = Hash[@keys.zip(values.reject(&:empty?).flatten)]
-          data['elapsed_time'] = (Time.now - Time.parse(data['start_time'])).to_i if data['start_time']
-          next unless @lookup_user.nil? || @lookup_user.include?(data['user'])
           emit_tag = tag.dup
           filter_record(emit_tag, Fluent::Engine.now, data)
           router.emit(emit_tag, Fluent::Engine.now, data)
         end
+      ensure
         io.close
-        sleep @interval
       end
-      rescue StandardError => e
-        log.error "watch_process: error has occured. #{e.message}"
+    rescue StandardError => e
+      log.error "watch_process: error has occured. #{e.message}"
+    end
+    def parse_line(line)
+      keys_size = @keys.size
+      if line =~ /(?<lstart>(^\w+\s+\w+\s+\d+\s+\d\d:\d\d:\d\d \d+))/
+        lstart = Time.parse($~[:lstart])
+        line = line.sub($~[:lstart], '')
+        keys_size -= 1
+      end
+      values = [lstart.to_s, line.chomp.strip.split(/\s+/, keys_size)]
+      data = Hash[@keys.zip(values.reject(&:empty?).flatten)]
+      data['elapsed_time'] = (Time.now - Time.parse(data['start_time'])).to_i if data['start_time']
+      data
+    end
+    def match_look_up_user?(data)
+      return true if @lookup_user.nil?
+      @lookup_user.include?(data['user'])
     end
     def get_ps_command
-      if OS.linux?
-        "LANG=en_US.UTF-8 && ps -ewwo lstart,user:20,pid,ppid,time,%cpu,%mem,rss,sz,s,comm,cmd"
-      elsif OS.mac?
+      if mac?
         "LANG=en_US.UTF-8 && ps -ewwo lstart,user,pid,ppid,time,%cpu,%mem,rss,vsz,state,comm,command"
+      elsif Fluent.windows?
+        @windows_watcher.command
+      else
+        "LANG=en_US.UTF-8 && ps -ewwo lstart,user:20,pid,ppid,time,%cpu,%mem,rss,sz,s,comm,cmd"
       end
     end
-    module OS
-      # ref. http://stackoverflow.com/questions/170956/how-can-i-find-which-operating-system-my-ruby-program-is-running-on
-      def OS.windows?
-        (/cygwin|mswin|mingw|bccwin|wince|emx/ =~ RUBY_PLATFORM) != nil
+    def mac?
+      (/darwin/ =~ RUBY_PLATFORM) != nil
+    end
+    class WindowsWatcher
+      # Keys are from the "System.Diagnostics.Process" object properties that can be taken by the "Get-Process" command.
+      # You can check the all properties by the "(Get-Process)[0] | Get-Member" command.
+      DEFAULT_KEYS = %w(StartTime UserName SessionId Id CPU WorkingSet VirtualMemorySize HandleCount ProcessName)
+      DEFAULT_TYPES = %w(
+        SessionId:integer
+        Id:integer
+        CPU:float
+        WorkingSet:integer
+        VirtualMemorySize:integer
+        HandleCount:integer
+      ).join(",")
+      attr_reader :keys
+      attr_reader :command
+      def initialize(keys, command, lookup_user, powershell_command)
+        @keys = keys || DEFAULT_KEYS
+        @powershell_command = powershell_command
+        @command = command || default_command
+        @lookup_user = lookup_user
       end
-      def OS.mac?
-       (/darwin/ =~ RUBY_PLATFORM) != nil
+      def default_types
+        DEFAULT_TYPES
       end
-      def OS.unix?
-        !OS.windows?
+      def parse_line(line)
+        values = line.chomp.strip.parse_csv.map { |e| e ? e : "" }
+        data = Hash[@keys.zip(values)]
+        unless data["StartTime"].nil?
+          start_time = Time.parse(data['StartTime'])
+          data['ElapsedTime'] = (Time.now - start_time).to_i
+          data["StartTime"] = start_time.to_s
+        end
+        data
+      end
+      def match_look_up_user?(data)
+        return true if @lookup_user.nil?
+        @lookup_user.include?(data["UserName"])
+      end
+      def default_command
+        command = [
+          command_ps,
+          pipe_filtering_normal_ps,
+          pipe_select_columns,
+          pipe_fixing_locale,
+          pipe_formatting_output,
+        ].join
+        "#{@powershell_command} -command \"#{command}\""
+      end
+      def command_ps
+        if @keys.include?("UserName")
+          # The "IncludeUserName" option is needed to get the username, but this option requires Administrator privilege.
+          "Get-Process -IncludeUserName"
+        else
+          "Get-Process"
+        end
+      end
+      private
+      def pipe_filtering_normal_ps
+        # There are some special processes that don't have some properties, such as the "Idle" process.
+        # Normally, these are specific to the system and are not important, so exclude them.
+        # Note: The same situation can occur in some processes if there are no Administrator privilege.
+        " | ?{$_.StartTime -ne $NULL -and $_.CPU -ne $NULL}"
+      end
+      def pipe_select_columns
+        if @keys.nil? || @keys.empty?
+          raise "The 'keys' parameter is not specified correctly. [keys: #{@keys}]"
+        end
+        " | Select-Object -Property #{@keys.join(',')}"
+      end
+      def pipe_fixing_locale()
+        # In Windows, setting the "$env:Lang" environment variable is not effective in changing the format of the output.
+        # You can use "Datetime.ToString" method to change format of datetime values in for-each pipe.
+        # Note: About "DateTime.ToString" method: https://docs.microsoft.com/en-us/dotnet/api/system.datetime.tostring
+        return "" unless @keys.include?("StartTime")
+        " | %{$_.StartTime = $_.StartTime.ToString('o'); return $_;}"
       end
-      def OS.linux?
-        OS.unix? and not OS.mac?
+      def pipe_formatting_output
+        # In the "ConvertTo-Csv" command, there are 2 lines of type info and header info at the beginning in the outputs.
+        # By the "NoTypeInformation" option, the line of type info is excluded.
+        # This enables you to skip the just first line for parsing, like linux or mac.
+        " | ConvertTo-Csv -NoTypeInformation"
       end
     end
   end

data/test/helper.rb CHANGED Viewed

@@ -12,15 +12,7 @@ require 'test/unit'
 $LOAD_PATH.unshift(File.join(File.dirname(__FILE__), '..', 'lib'))
 $LOAD_PATH.unshift(File.dirname(__FILE__))
 require 'fluent/test'
-unless ENV.has_key?('VERBOSE')
-  nulllogger = Object.new
-  nulllogger.instance_eval {|obj|
-    def method_missing(method, *args)
-      # pass
-    end
-  }
-  $log = nulllogger
-end
+require 'fluent/test/driver/input'
 require 'fluent/plugin/in_watch_process'

data/test/plugin/test_in_watch_process.rb CHANGED Viewed

@@ -10,7 +10,7 @@ class WatchProcessInputTest < Test::Unit::TestCase
   ]
   def create_driver(conf = CONFIG)
-    Fluent::Test::InputTestDriver.new(Fluent::WatchProcessInput).configure(conf)
+    Fluent::Test::Driver::Input.new(Fluent::Plugin::WatchProcessInput).configure(conf)
   end
   def test_configure
@@ -23,5 +23,103 @@ class WatchProcessInputTest < Test::Unit::TestCase
     ]
     assert_equal 'input.watch_process', d.instance.tag
     assert_equal ['apache', 'mycron'], d.instance.lookup_user
+    assert_equal :powershell, d.instance.powershell_command
+  end
+  def test_windows_configure
+    omit "Only for UNIX like." unless Fluent.windows?
+    d = create_driver %[
+      tag          input.watch_process
+      lookup_user  apache, mycron
+      powershell_command pwsh
+    ]
+    assert_equal 'input.watch_process', d.instance.tag
+    assert_equal ['apache', 'mycron'], d.instance.lookup_user
+    assert_equal :pwsh, d.instance.powershell_command
+  end
+  def test_unixlike
+    omit "Only for UNIX like." if Fluent.windows?
+    whoami = `whoami`
+    d = create_driver %[
+      tag          input.watch_process
+      lookup_user  #{whoami}
+      interval 1s
+    ]
+    d.run(expect_emits: 1, timeout: 3)
+    assert(d.events.size > 1)
+  end
+  sub_test_case "Windows" do
+    def test_windows_default
+      omit "Only for Windows." unless Fluent.windows?
+      d = create_driver %[
+        tag input.watch_process
+        interval 1s
+      ]
+      default_keys = Fluent::Plugin::WatchProcessInput::WindowsWatcher::DEFAULT_KEYS + ["ElapsedTime"]
+      d.run(expect_records: 1, timeout: 10);
+      assert d.events.size > 0
+      tag, time, record = d.events[0]
+      assert_equal "input.watch_process", tag
+      assert time.is_a?(Fluent::EventTime)
+      assert_equal default_keys, record.keys
+    end
+    def test_windows_customized
+      omit "Only for Windows." unless Fluent.windows?
+      custom_keys = ["PM", "Id", "UserProcessorTime", "Path"]
+      d = create_driver %[
+        tag input.watch_process
+        interval 1s
+        keys #{custom_keys.join(",")}
+        types Id:integer
+      ]
+      d.run(expect_records: 1, timeout: 10);
+      assert d.events.size > 0
+      tag, time, record = d.events[0]
+      assert_equal "input.watch_process", tag
+      assert time.is_a?(Fluent::EventTime)
+      assert_equal custom_keys, record.keys
+      assert record["PM"].is_a?(String)
+      assert record["Id"].is_a?(Integer)
+    end
+    def test_windows_lookup
+      omit "Only for Windows." unless Fluent.windows?
+      d = create_driver %[
+        tag input.watch_process
+        interval 1s
+      ]
+      d.run(expect_records: 1, timeout: 10);
+      assert d.events.size > 0
+      tag, time, record = d.events[0]
+      lookup_user = record["UserName"]
+      d = create_driver %[
+        tag input.watch_process
+        interval 1s
+        lookup_user #{lookup_user}
+      ]
+      d.run(expect_records: 1, timeout: 10);
+      assert d.events.size > 0
+      other_user_records = d.events.reject do |tag, time, record|
+        lookup_user.include?(record["UserName"])
+      end
+      assert other_user_records.size == 0
+    end
   end
 end

metadata CHANGED Viewed

@@ -1,110 +1,103 @@
 --- !ruby/object:Gem::Specification
 name: fluent-plugin-watch-process
 version: !ruby/object:Gem::Version
-  version: 0.1.1
-  prerelease:
+  version: 0.2.0
 platform: ruby
 authors:
 - Kentaro Yoshida
 autorequire:
 bindir: bin
 cert_chain: []
-date: 2017-03-30 00:00:00.000000000 Z
+date: 2021-05-30 00:00:00.000000000 Z
 dependencies:
 - !ruby/object:Gem::Dependency
   name: rake
   requirement: !ruby/object:Gem::Requirement
-    none: false
     requirements:
-    - - ! '>='
+    - - ">="
       - !ruby/object:Gem::Version
         version: '0'
   type: :development
   prerelease: false
   version_requirements: !ruby/object:Gem::Requirement
-    none: false
     requirements:
-    - - ! '>='
+    - - ">="
       - !ruby/object:Gem::Version
         version: '0'
 - !ruby/object:Gem::Dependency
   name: test-unit
   requirement: !ruby/object:Gem::Requirement
-    none: false
     requirements:
-    - - ! '>='
+    - - ">="
       - !ruby/object:Gem::Version
         version: 3.1.0
   type: :development
   prerelease: false
   version_requirements: !ruby/object:Gem::Requirement
-    none: false
     requirements:
-    - - ! '>='
+    - - ">="
       - !ruby/object:Gem::Version
         version: 3.1.0
 - !ruby/object:Gem::Dependency
   name: appraisal
   requirement: !ruby/object:Gem::Requirement
-    none: false
     requirements:
-    - - ! '>='
+    - - ">="
       - !ruby/object:Gem::Version
         version: '0'
   type: :development
   prerelease: false
   version_requirements: !ruby/object:Gem::Requirement
-    none: false
     requirements:
-    - - ! '>='
+    - - ">="
       - !ruby/object:Gem::Version
         version: '0'
 - !ruby/object:Gem::Dependency
   name: fluentd
   requirement: !ruby/object:Gem::Requirement
-    none: false
     requirements:
-    - - ! '>='
+    - - ">="
       - !ruby/object:Gem::Version
-        version: 0.10.58
+        version: 0.14.0
+    - - "<"
+      - !ruby/object:Gem::Version
+        version: '2'
   type: :runtime
   prerelease: false
   version_requirements: !ruby/object:Gem::Requirement
-    none: false
     requirements:
-    - - ! '>='
+    - - ">="
+      - !ruby/object:Gem::Version
+        version: 0.14.0
+    - - "<"
       - !ruby/object:Gem::Version
-        version: 0.10.58
+        version: '2'
 - !ruby/object:Gem::Dependency
   name: fluent-mixin-rewrite-tag-name
   requirement: !ruby/object:Gem::Requirement
-    none: false
     requirements:
-    - - ! '>='
+    - - ">="
       - !ruby/object:Gem::Version
         version: '0'
   type: :runtime
   prerelease: false
   version_requirements: !ruby/object:Gem::Requirement
-    none: false
     requirements:
-    - - ! '>='
+    - - ">="
       - !ruby/object:Gem::Version
         version: '0'
 - !ruby/object:Gem::Dependency
   name: fluent-mixin-type-converter
   requirement: !ruby/object:Gem::Requirement
-    none: false
     requirements:
-    - - ! '>='
+    - - ">="
       - !ruby/object:Gem::Version
         version: 0.1.0
   type: :runtime
   prerelease: false
   version_requirements: !ruby/object:Gem::Requirement
-    none: false
     requirements:
-    - - ! '>='
+    - - ">="
       - !ruby/object:Gem::Version
         version: 0.1.0
 description:
@@ -114,8 +107,8 @@ executables: []
 extensions: []
 extra_rdoc_files: []
 files:
-- .gitignore
-- .travis.yml
+- ".gitignore"
+- ".travis.yml"
 - Appraisals
 - Gemfile
 - LICENSE.txt
@@ -124,36 +117,34 @@ files:
 - example1.conf
 - example2.conf
 - fluent-plugin-watch-process.gemspec
-- gemfiles/fluentd_v0.12.gemfile
 - gemfiles/fluentd_v0.14.gemfile
 - lib/fluent/plugin/in_watch_process.rb
 - test/helper.rb
 - test/plugin/test_in_watch_process.rb
 homepage: https://github.com/y-ken/fluent-plugin-watch-process
 licenses: []
+metadata: {}
 post_install_message:
 rdoc_options: []
 require_paths:
 - lib
 required_ruby_version: !ruby/object:Gem::Requirement
-  none: false
   requirements:
-  - - ! '>='
+  - - ">="
     - !ruby/object:Gem::Version
       version: '0'
 required_rubygems_version: !ruby/object:Gem::Requirement
-  none: false
   requirements:
-  - - ! '>='
+  - - ">="
     - !ruby/object:Gem::Version
       version: '0'
 requirements: []
-rubyforge_project:
-rubygems_version: 1.8.23
+rubygems_version: 3.1.6
 signing_key:
-specification_version: 3
-summary: Fluentd Input plugin to collect continual process information via ps command.
-  It is useful for cron/barch process monitoring.
+specification_version: 4
+summary: Fluentd Input plugin to collect continual process information via ps command
+  or PowerShell pwsh command for Linux/osx/Windows. It is useful for cron/barch process
+  monitoring.
 test_files:
 - test/helper.rb
 - test/plugin/test_in_watch_process.rb

data/gemfiles/fluentd_v0.12.gemfile DELETED Viewed

@@ -1,7 +0,0 @@
-# This file was generated by Appraisal
-source "http://rubygems.org"
-gem "fluentd", "~> 0.12.0"
-gemspec :path => "../"