Add controllers/models snippet for filter plugins

Signed-off-by: Kenji Okimoto <okimoto@clear-code.com>
This commit is contained in:
Kenji Okimoto 2018-09-10 18:15:49 +09:00
parent 19d62678b5
commit feafc35d48
No known key found for this signature in database
GPG Key ID: F9E3E329A5C5E4A1
8 changed files with 145 additions and 0 deletions

View File

@ -0,0 +1,9 @@
class Fluentd::Settings::FilterGrepController < ApplicationController
include SettingConcern
private
def target_class
Fluentd::Setting::FilterGrep
end
end

View File

@ -0,0 +1,9 @@
class Fluentd::Settings::FilterParserController < ApplicationController
include SettingConcern
private
def target_class
Fluentd::Setting::FilterParser
end
end

View File

@ -0,0 +1,9 @@
class Fluentd::Settings::FilterRecordTransformerController < ApplicationController
include SettingConcern
private
def target_class
Fluentd::Setting::FilterRecordTransformer
end
end

View File

@ -0,0 +1,9 @@
class Fluentd::Settings::FilterStdoutController < ApplicationController
include SettingConcern
private
def target_class
Fluentd::Setting::FilterStdout
end
end

View File

@ -0,0 +1,28 @@
class Fluentd
module Setting
class FilterGrep
include Fluentd::Setting::Plugin
register_plugin("filter", "grep")
def self.initial_params
{
}
end
def common_options
[
:pattern,
]
end
def hidden_options
regexps = (1..20).map {|n| :"regexp#{n}"}
excludes = (1..20).map {|n| :"exclude#{n}"}
[
*regexps, *excludes, :regexp, :exclude, :and, :or
].tap{|s| p s}
end
end
end
end

View File

@ -0,0 +1,24 @@
class Fluentd
module Setting
class FilterParser
include Fluentd::Setting::Plugin
register_plugin("filter", "parser")
def self.initial_params
{
}
end
def common_options
[
:pattern,
]
end
def hidden_options
[]
end
end
end
end

View File

@ -0,0 +1,24 @@
class Fluentd
module Setting
class FilterRecordTransformer
include Fluentd::Setting::Plugin
register_plugin("filter", "record_transformer")
def self.initial_params
{
}
end
def common_options
[
:pattern,
]
end
def hidden_options
[]
end
end
end
end

View File

@ -0,0 +1,33 @@
class Fluentd
module Setting
class FilterStdout
include Fluentd::Setting::Plugin
register_plugin("filter", "stdout")
def self.initial_params
{
format_type: "stdout",
format: {
"0" => {
"@type" => "stdout",
"output_type" => "json"
}
}
}
end
def common_options
[
:pattern,
]
end
def hidden_options
[
:inject
]
end
end
end
end