Repository Analysis

fluent/fluentd

Fluentd: Unified Logging Layer (project under CNCF)

4.2 Likely human-written View on GitHub
4.2
Adjusted Score
4.2
Raw Score
100%
Time Factor
2026-05-25
Last Push
13,545
Stars
Ruby
Language
111,872
Lines of Code
471
Files
441
Pattern Hits
2026-05-31
Scan Date

Score History

Severity Breakdown

CRITICAL 0HIGH 0MEDIUM 11LOW 430

Pattern Findings

441 matches across 7 categories. Click a row to expand file-level details.

Over-Commented Block264 hits · 264 pts
SeverityFileLineSnippet
LOWtest/test_configdsl.rb1require_relative 'helper'
LOWtest/config/test_configurable.rb101 ary + [@nodes, @description1, @description2, @description3]
LOWtest/plugin/test_in_tail.rb3101
LOWtest/plugin/test_in_tail.rb3121 # tail.txt: TailWatcher(path: "tail.txt", inode: inode_1)
LOWtest/plugin/test_buffer.rb881 # Write 42 events in 1 event stream, last one is for triggering `ShouldRetry`
LOWtest/plugin/test_buffer.rb941 # Write 42 events in 1 event stream, last one is for triggering `ShouldRetry`
LOWtest/scripts/fluent/plugin/out_test.rb1#
LOWtest/scripts/fluent/plugin/out_test2.rb1#
LOW.github/workflows/scorecards.yml41 # - you want to enable the Branch-Protection check on a *public* repository, or
LOWlib/fluent/counter.rb1#
LOWlib/fluent/match.rb1#
LOWlib/fluent/match.rb81 escape = true
LOWlib/fluent/output.rb1#
LOWlib/fluent/timezone.rb1#
LOWlib/fluent/timezone.rb41 # such as PST and JST are not supported intentionally.
LOWlib/fluent/plugin_id.rb1#
LOWlib/fluent/fluent_log_event_router.rb1#
LOWlib/fluent/source_only_buffer_agent.rb1#
LOWlib/fluent/label.rb1#
LOWlib/fluent/input.rb1#
LOWlib/fluent/agent.rb1#
LOWlib/fluent/static_config_analysis.rb1#
LOWlib/fluent/filter.rb1#
LOWlib/fluent/root_agent.rb1#
LOWlib/fluent/root_agent.rb21require 'fluent/label'
LOWlib/fluent/process.rb1#
LOWlib/fluent/system_config.rb1#
LOWlib/fluent/plugin.rb1#
LOWlib/fluent/output_chain.rb1#
LOWlib/fluent/parser.rb1#
LOWlib/fluent/tls.rb1#
LOWlib/fluent/engine.rb1#
LOWlib/fluent/rpc.rb1#
LOWlib/fluent/capability.rb1#
LOWlib/fluent/winsvc.rb1#
LOWlib/fluent/ext_monitor_require.rb1#
LOWlib/fluent/daemonizer.rb1#
LOWlib/fluent/variable_store.rb1#
LOWlib/fluent/test.rb1#
LOWlib/fluent/registry.rb1#
LOWlib/fluent/msgpack_factory.rb1#
LOWlib/fluent/supervisor.rb1#
LOWlib/fluent/win32api.rb1#
LOWlib/fluent/unique_id.rb1#
LOWlib/fluent/configurable.rb1#
LOWlib/fluent/clock.rb1#
LOWlib/fluent/config.rb1#
LOWlib/fluent/env.rb1#
LOWlib/fluent/version.rb1#
LOWlib/fluent/error.rb1#
LOWlib/fluent/event_router.rb1#
LOWlib/fluent/event_router.rb21
LOWlib/fluent/mixin.rb1#
LOWlib/fluent/log.rb1#
LOWlib/fluent/log.rb101 # ERROR = 3
LOWlib/fluent/time.rb1#
LOWlib/fluent/event.rb1#
LOWlib/fluent/plugin_helper.rb1#
LOWlib/fluent/formatter.rb1#
LOWlib/fluent/file_wrapper.rb1#
204 more matches not shown…
Hyper-Verbose Identifiers161 hits · 166 pts
SeverityFileLineSnippet
LOWtasks/backport.rb18def append_additional_arguments(commands)
LOWtest/test_formatter.rb237 def test_config_params_with_customized_delimiters(data)
LOWtest/test_formatter.rb288 def test_format_with_empty_fields(data)
LOWtest/test_formatter.rb300 def test_config_params_with_fields(data)
LOWtest/test_supervisor.rb490 def test_fluentsigdump_get_path_with_pid(data)
LOWtest/test_supervisor.rb569 def test_invalid_rpc_endpoint(data)
LOWtest/test_supervisor.rb745 def test_logger_with_rotate_age_and_rotate_size(rotate_age)
LOWtest/test_supervisor.rb958 def test_zero_downtime_restart((daemonize, wait_success, wait_sleep, restart_canceled))
LOWtest/test_event.rb8 def assert_duplicated_records(es1, es2)
LOWtest/test_log.rb85 def test_output_with_serverengine_loglevel(data)
LOWtest/test_log.rb150 def test_output_with_block_with_serverengine_loglevel(data)
LOWtest/test_log.rb214 def test_execute_block_with_serverengine_loglevel(data)
LOWtest/test_log.rb290 def test_backtrace_with_serverengine_loglevel(data)
LOWtest/plugin_helper/test_server.rb957 def create_server_pair_signed_by_self(cert_path, private_key_path, passphrase)
LOWtest/plugin_helper/test_server.rb963 def create_ca_pair_signed_by_self(cert_path, private_key_path, passphrase)
LOWtest/plugin_helper/test_server.rb968 def create_server_pair_signed_by_ca(ca_cert_path, ca_key_path, ca_key_passphrase, cert_path, private_key_path, passphr
LOWtest/plugin_helper/test_server.rb974 def create_server_pair_chained_with_root_ca(ca_cert_path, ca_key_path, ca_key_passphrase, cert_path, private_key_path,
LOWtest/plugin_helper/test_service_discovery.rb11 def service_discovery_create_manager(title, configurations:, load_balancer: nil, custom_build_method: nil, interval:
LOWtest/plugin_helper/data/cert/generate_cert.rb41def create_server_pair_signed_by_self(cert_path, private_key_path, passphrase)
LOWtest/plugin_helper/data/cert/generate_cert.rb47def create_ca_pair_signed_by_self(cert_path, private_key_path, passphrase)
LOWtest/plugin_helper/data/cert/generate_cert.rb53def create_server_pair_signed_by_ca(ca_cert_path, ca_key_path, ca_key_passphrase, cert_path, private_key_path, passphras
LOWtest/plugin_helper/data/cert/generate_cert.rb87def create_cert_pair_chained_with_root_ca(ca_cert_path, ca_key_path, ca_key_passphrase, cert_path, private_key_path, pas
LOWtest/compat/test_parser.rb86 def test_regexp_parser_config(options)
LOWtest/config/assertions.rb17 def assert_text_parsed_as_json(expected, actual)
LOWtest/config/test_config_parser.rb231 def test_rejects_at_prefix_in_the_parameter_name(data)
LOWtest/config/test_config_parser.rb244 def test_not_reject_at_prefix_in_the_parameter_name(data)
LOWtest/plugin/test_formatter_csv.rb42 def test_config_params_with_customized_delimiters(data)
LOWtest/plugin/test_formatter_csv.rb106 def test_format_with_empty_fields(data)
LOWtest/plugin/test_formatter_csv.rb116 def test_config_params_with_fields(data)
LOWtest/plugin/test_in_syslog.rb61 def test_configure_resolve_hostname(param)
LOWtest/plugin/test_in_syslog.rb252 def test_msg_size_with_severity_key(param_name)
LOWtest/plugin/test_in_syslog.rb410 def compare_unmatched_lines_test_result(events, tests, options = {})
LOWtest/plugin/test_base.rb157 def assert_system_config_workers_value(data)
LOWtest/plugin/test_in_tail.rb490 def test_emit_with_read_lines_limit(data)
LOWtest/plugin/test_in_tail.rb530 def test_emit_with_read_bytes_limit_per_second(data)
LOWtest/plugin/test_in_tail.rb595 def test_emit_with_read_bytes_limit_per_second(data)
LOWtest/plugin/test_in_tail.rb728 def test_emit_with_read_from_head(data)
LOWtest/plugin/test_in_tail.rb754 def test_emit_without_watch_timer(data)
LOWtest/plugin/test_in_tail.rb812 def test_emit_with_disable_stat_watcher(data)
LOWtest/plugin/test_in_tail.rb929 def test_rotate_file_with_read_from_head(data)
LOWtest/plugin/test_in_tail.rb938 def test_rotate_file_with_open_on_every_update(data)
LOWtest/plugin/test_in_tail.rb947 def test_rotate_file_with_write_old(data)
LOWtest/plugin/test_in_tail.rb969 def test_rotate_file_with_write_old_and_no_new_file(data)
LOWtest/plugin/test_in_tail.rb1281 def test_multiline_with_emit_unmatched_lines_true(data)
LOWtest/plugin/test_in_tail.rb1338 def test_multiline_with_flush_interval(data)
LOWtest/plugin/test_in_tail.rb1372 def test_multiline_encoding_of_flushed_record(data)
LOWtest/plugin/test_in_tail.rb1435 def test_multiline_with_multiple_formats(data)
LOWtest/plugin/test_in_tail.rb1476 def test_multilinelog_with_multiple_paths(data)
LOWtest/plugin/test_in_tail.rb1521 def test_multiline_without_firstline(data)
LOWtest/plugin/test_in_tail.rb2712 def test_lines_collected_with_no_throttling(data)
LOWtest/plugin/test_formatter_json.rb55 def test_format_with_symbolic_record(data)
LOWtest/plugin/test_in_forward.rb1191 def execute_test_with_source_hostname_key(*keys, &block)
LOWtest/plugin/test_parser_json.rb56 def test_parse_with_large_float(data)
LOWtest/plugin/test_parser_json.rb90 def test_parse_with_colon_string(data)
LOWtest/plugin/test_parser_json.rb98 def test_parse_with_invalid_time(data)
LOWtest/plugin/test_parser_json.rb117 def test_parse_with_keep_time_key(data)
LOWtest/plugin/test_parser_json.rb133 def test_parse_with_keep_time_key_without_time_format(data)
LOWtest/plugin/test_out_copy.rb198 def test_copy_mode_with_event_streams(data)
LOWtest/plugin/test_parser_syslog.rb29 def test_parse_with_time_format(param)
LOWtest/plugin/test_parser_syslog.rb58 def test_parse_with_subsecond_time(param)
101 more matches not shown…
Self-Referential Comments8 hits · 24 pts
SeverityFileLineSnippet
MEDIUMlib/fluent/timezone.rb98 # Create a formatter for a timezone and optionally a format.
MEDIUMlib/fluent/fluent_log_event_router.rb35 # This class is for handling fluentd's inner log
MEDIUMlib/fluent/supervisor.rb992 # This method is the only method to set signal handlers in Fluentd worker process.
MEDIUMlib/fluent/log.rb72 # Create a unique path for each process.
MEDIUMlib/fluent/time.rb115 # This method is called many time. so call Process.clock_gettime directly instead of Fluent::Clock.real_now
MEDIUMlib/fluent/plugin/buf_file_single.rb134 # This method is called only when multi worker is configured
MEDIUMlib/fluent/plugin/buf_file.rb113 # This method is called only when multi worker is configured
MEDIUMlib/fluent/plugin/in_tail/position_file.rb94 # This method is similar to #compact but it tries to get less lock to avoid a lock contention
Decorative Section Separators2 hits · 6 pts
SeverityFileLineSnippet
MEDIUMlib/fluent/plugin/in_http.rb504 # ==========
MEDIUMlib/fluent/plugin/in_http.rb516 # =================
AI Slop Vocabulary2 hits · 4 pts
SeverityFileLineSnippet
MEDIUMlib/fluent/compat/file_util.rb35 # Check file is writable in conjunction with mkdir_p(dirname(path))
LOWlib/fluent/plugin/in_tail.rb377 # When file is not created yet, Dir.glob returns an empty array. So just add when path is static.
Redundant / Tautological Comments2 hits · 3 pts
SeverityFileLineSnippet
LOWtasks/benchmark.rb36 # Output the results with markdown format
LOWtest/plugin/test_out_http.rb196 # Check if an exception is raised on not JSON format use
Slop Phrases2 hits · 2 pts
SeverityFileLineSnippet
LOWtest/command/test_fluentd.rb1520 sleep 5 # make sure to flush each chunk (1s flush interval for 1chunk)
LOWlib/fluent/fluent_log_event_router.rb130 # to make sure to emit all log events into router, before shutting down