From feafc35d4809b4e49d72d945165d9637018b7e67 Mon Sep 17 00:00:00 2001 From: Kenji Okimoto Date: Mon, 10 Sep 2018 18:15:49 +0900 Subject: [PATCH] Add controllers/models snippet for filter plugins Signed-off-by: Kenji Okimoto --- .../settings/filter_grep_controller.rb | 9 +++++ .../settings/filter_parser_controller.rb | 9 +++++ .../filter_record_transformer_controller.rb | 9 +++++ .../settings/filter_stdout_controller.rb | 9 +++++ app/models/fluentd/setting/filter_grep.rb | 28 ++++++++++++++++ app/models/fluentd/setting/filter_parser.rb | 24 ++++++++++++++ .../setting/filter_record_transformer.rb | 24 ++++++++++++++ app/models/fluentd/setting/filter_stdout.rb | 33 +++++++++++++++++++ 8 files changed, 145 insertions(+) create mode 100644 app/controllers/fluentd/settings/filter_grep_controller.rb create mode 100644 app/controllers/fluentd/settings/filter_parser_controller.rb create mode 100644 app/controllers/fluentd/settings/filter_record_transformer_controller.rb create mode 100644 app/controllers/fluentd/settings/filter_stdout_controller.rb create mode 100644 app/models/fluentd/setting/filter_grep.rb create mode 100644 app/models/fluentd/setting/filter_parser.rb create mode 100644 app/models/fluentd/setting/filter_record_transformer.rb create mode 100644 app/models/fluentd/setting/filter_stdout.rb diff --git a/app/controllers/fluentd/settings/filter_grep_controller.rb b/app/controllers/fluentd/settings/filter_grep_controller.rb new file mode 100644 index 0000000..cbce51c --- /dev/null +++ b/app/controllers/fluentd/settings/filter_grep_controller.rb @@ -0,0 +1,9 @@ +class Fluentd::Settings::FilterGrepController < ApplicationController + include SettingConcern + + private + + def target_class + Fluentd::Setting::FilterGrep + end +end diff --git a/app/controllers/fluentd/settings/filter_parser_controller.rb b/app/controllers/fluentd/settings/filter_parser_controller.rb new file mode 100644 index 0000000..6666928 --- /dev/null +++ b/app/controllers/fluentd/settings/filter_parser_controller.rb @@ -0,0 +1,9 @@ +class Fluentd::Settings::FilterParserController < ApplicationController + include SettingConcern + + private + + def target_class + Fluentd::Setting::FilterParser + end +end diff --git a/app/controllers/fluentd/settings/filter_record_transformer_controller.rb b/app/controllers/fluentd/settings/filter_record_transformer_controller.rb new file mode 100644 index 0000000..fdd605f --- /dev/null +++ b/app/controllers/fluentd/settings/filter_record_transformer_controller.rb @@ -0,0 +1,9 @@ +class Fluentd::Settings::FilterRecordTransformerController < ApplicationController + include SettingConcern + + private + + def target_class + Fluentd::Setting::FilterRecordTransformer + end +end diff --git a/app/controllers/fluentd/settings/filter_stdout_controller.rb b/app/controllers/fluentd/settings/filter_stdout_controller.rb new file mode 100644 index 0000000..1c6088d --- /dev/null +++ b/app/controllers/fluentd/settings/filter_stdout_controller.rb @@ -0,0 +1,9 @@ +class Fluentd::Settings::FilterStdoutController < ApplicationController + include SettingConcern + + private + + def target_class + Fluentd::Setting::FilterStdout + end +end diff --git a/app/models/fluentd/setting/filter_grep.rb b/app/models/fluentd/setting/filter_grep.rb new file mode 100644 index 0000000..1384ba8 --- /dev/null +++ b/app/models/fluentd/setting/filter_grep.rb @@ -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 diff --git a/app/models/fluentd/setting/filter_parser.rb b/app/models/fluentd/setting/filter_parser.rb new file mode 100644 index 0000000..61f745e --- /dev/null +++ b/app/models/fluentd/setting/filter_parser.rb @@ -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 diff --git a/app/models/fluentd/setting/filter_record_transformer.rb b/app/models/fluentd/setting/filter_record_transformer.rb new file mode 100644 index 0000000..36f3ee9 --- /dev/null +++ b/app/models/fluentd/setting/filter_record_transformer.rb @@ -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 diff --git a/app/models/fluentd/setting/filter_stdout.rb b/app/models/fluentd/setting/filter_stdout.rb new file mode 100644 index 0000000..7be6e1d --- /dev/null +++ b/app/models/fluentd/setting/filter_stdout.rb @@ -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