add support of request method

Author: HatsuneMiku3939

lib/fluent/plugin/in_http_pull.rb

@@ -20,7 +20,6 @@ module Fluent
   module Plugin
     class HttpPullInput < Fluent::Plugin::Input
       Fluent::Plugin.register_input("http_pull", self)
-
       helpers :timer, :parser, :compat_parameters
 
       def initialize
@@ -29,19 +28,28 @@ def initialize
 
       desc 'The tag of the event.'
       config_param :tag, :string
+
       desc 'The url of monitoring target'
       config_param :url, :string
+
       desc 'The interval time between periodic request'
       config_param :interval, :time
+
       desc 'status_only'
       config_param :status_only, :bool, default: false
-      desc 'The timeout stime of each request'
+
+      desc 'The http method for each request'
+      config_param :http_method, :enum, list: [:get, :post, :delete], default: :get
+
+      desc 'The timeout second of each request'
       config_param :timeout, :time, default: 10
+
       desc 'The HTTP proxy URL to use for each requests'
       config_param :proxy, :string, default: nil
 
       desc 'user of basic auth'
       config_param :user, :string, default: nil
+
       desc 'password of basic auth'
       config_param :password, :string, default: nil
 
@@ -69,6 +77,8 @@ def configure(conf)
 
           [header.to_sym, value]
         end.to_h
+
+        @http_method = :head if @status_only
       end
 
       def start
@@ -81,7 +91,7 @@ def on_timer
         record = { "url" => @url }
 
         begin
-          request_options = { method: :get, url: @url, timeout: @timeout }
+          request_options = { method: @http_method, url: @url, timeout: @timeout }
 
           request_options[:proxy] = @proxy if @proxy
           request_options[:user] = @user if @user

test/plugin/test_in_http_pull.rb

@@ -58,6 +58,13 @@ class HttpPullInputTest < Test::Unit::TestCase
 
       assert_equal(nil, d.instance.proxy)
     end
+
+    test 'http_method' do
+      d = create_driver TEST_DEFAULT_VALUE_CONFIG
+      assert_equal("test", d.instance.tag)
+
+      assert_equal(:get, d.instance.http_method)
+    end
   end
 
   sub_test_case "success case" do