Fluentd: Unified Logging Layer (project under CNCF)
This report summarizes scanner evidence for fluent/fluentd, a Ruby project with 13,612 GitHub stars. SynthScan examined 123,047 lines of code across 489 source files, recording 540 pattern matches distributed across 10 syntactic categories. The legacy adjusted pattern signal is 4.6 (Low pattern signal); it is not an authorship estimate.
Use the findings to ask whether maintainers can explain intent, verify dependencies, simplify unnecessary scaffolding, and focus review effort. Risk Payload v1 adds ownership, supply-chain, over-engineering, and review-effort vectors when available. These are prompts for human verification, not probabilities, security findings, or measured maintenance costs.
Use each vector to guide manual verification of the underlying findings.
Payload schema: 1.0.0 · Engine: 2.0.0 · Scoring: heuristic-density-v1 · Scan date: 2026-10-31.
Can maintainers explain intent, assumptions, and trade-offs? 476 finding(s).
Are imports declared and package/API names verified? 62 finding(s).
Are wrappers, guards, and repeated structures necessary? 186 finding(s).
Which changes need focused human review? 540 finding(s).
This chart tracks the legacy adjusted pattern score across scan runs. Changes can reflect source changes, scan coverage, or detector/scoring versions; they do not measure AI adoption or prove that a team refactored code. Compare runs only when their scoring versions are compatible. The dashed line tracks the raw pattern-hit count.
Groups findings by configured severity weight. Severity is not a confidence estimate, security rating, or proof that a package is missing. Verify imports against the project's manifests and inspect each finding in its local design context.
This horizontal bar chart shows where configured pattern scores accumulate across directories. Treat the bars as locations to inspect, not as evidence of authorship or code quality. Use the file-level findings to decide whether a directory needs a focused ownership, dependency, complexity, or review check.
The scanner identified 540 distinct pattern matches across 10 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a detector match to inspect in context. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.
Reading the findings table: The Severity column indicates the configured finding weight (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — legacy comment-context matches receive a ×1.5 score weight. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier under the legacy scoring model.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | test/helper.rb | 81 | unused_port_tcp_udp(num) | COMMENT |
| LOW | test/test_configdsl.rb | 1 | require_relative 'helper' | COMMENT |
| LOW | test/config/test_configurable.rb | 101 | ary + [@nodes, @description1, @description2, @description3] | COMMENT |
| LOW | test/plugin/test_in_tail.rb | 5101 | # | COMMENT |
| LOW | test/plugin/test_in_tail.rb | 5441 | Fluent::FileWrapper.open("#{@tmp_dir}/tail.txt", "wb") {|f| f.puts "file1 log1"} | COMMENT |
| LOW | test/plugin/test_in_tail.rb | 5461 | # TailWatcher(path: "tail.txt1", inode: inode_0) is not added because the first TailWatcher | COMMENT |
| LOW | test/plugin/test_buffer.rb | 1061 | COMMENT | |
| LOW | test/plugin/test_buffer.rb | 1121 | COMMENT | |
| LOW | test/scripts/fluent/plugin/out_test.rb | 1 | # | COMMENT |
| LOW | test/scripts/fluent/plugin/out_test2.rb | 1 | # | COMMENT |
| LOW | .github/workflows/scorecards.yml | 41 | # - you want to enable the Branch-Protection check on a *public* repository, or | COMMENT |
| LOW | lib/fluent/counter.rb | 1 | # | COMMENT |
| LOW | lib/fluent/match.rb | 1 | # | COMMENT |
| LOW | lib/fluent/match.rb | 81 | escape = true | COMMENT |
| LOW | lib/fluent/output.rb | 1 | # | COMMENT |
| LOW | lib/fluent/timezone.rb | 1 | # | COMMENT |
| LOW | lib/fluent/timezone.rb | 41 | # such as PST and JST are not supported intentionally. | COMMENT |
| LOW | lib/fluent/plugin_id.rb | 1 | # | COMMENT |
| LOW | lib/fluent/fluent_log_event_router.rb | 1 | # | COMMENT |
| LOW | lib/fluent/source_only_buffer_agent.rb | 1 | # | COMMENT |
| LOW | lib/fluent/label.rb | 1 | # | COMMENT |
| LOW | lib/fluent/input.rb | 1 | # | COMMENT |
| LOW | lib/fluent/agent.rb | 1 | # | COMMENT |
| LOW | lib/fluent/static_config_analysis.rb | 1 | # | COMMENT |
| LOW | lib/fluent/filter.rb | 1 | # | COMMENT |
| LOW | lib/fluent/root_agent.rb | 1 | # | COMMENT |
| LOW | lib/fluent/root_agent.rb | 21 | require 'fluent/label' | COMMENT |
| LOW | lib/fluent/process.rb | 1 | # | COMMENT |
| LOW | lib/fluent/system_config.rb | 1 | # | COMMENT |
| LOW | lib/fluent/plugin.rb | 1 | # | COMMENT |
| LOW | lib/fluent/output_chain.rb | 1 | # | COMMENT |
| LOW | lib/fluent/parser.rb | 1 | # | COMMENT |
| LOW | lib/fluent/tls.rb | 1 | # | COMMENT |
| LOW | lib/fluent/engine.rb | 1 | # | COMMENT |
| LOW | lib/fluent/rpc.rb | 1 | # | COMMENT |
| LOW | lib/fluent/capability.rb | 1 | # | COMMENT |
| LOW | lib/fluent/winsvc.rb | 1 | # | COMMENT |
| LOW | lib/fluent/ext_monitor_require.rb | 1 | # | COMMENT |
| LOW | lib/fluent/daemonizer.rb | 1 | # | COMMENT |
| LOW | lib/fluent/variable_store.rb | 1 | # | COMMENT |
| LOW | lib/fluent/test.rb | 1 | # | COMMENT |
| LOW | lib/fluent/registry.rb | 1 | # | COMMENT |
| LOW | lib/fluent/msgpack_factory.rb | 1 | # | COMMENT |
| LOW | lib/fluent/supervisor.rb | 1 | # | COMMENT |
| LOW | lib/fluent/win32api.rb | 1 | # | COMMENT |
| LOW | lib/fluent/unique_id.rb | 1 | # | COMMENT |
| LOW | lib/fluent/configurable.rb | 1 | # | COMMENT |
| LOW | lib/fluent/clock.rb | 1 | # | COMMENT |
| LOW | lib/fluent/config.rb | 1 | # | COMMENT |
| LOW | lib/fluent/env.rb | 1 | # | COMMENT |
| LOW | lib/fluent/version.rb | 1 | # | COMMENT |
| LOW | lib/fluent/error.rb | 1 | # | COMMENT |
| LOW | lib/fluent/event_router.rb | 1 | # | COMMENT |
| LOW | lib/fluent/event_router.rb | 21 | COMMENT | |
| LOW | lib/fluent/mixin.rb | 1 | # | COMMENT |
| LOW | lib/fluent/log.rb | 1 | # | COMMENT |
| LOW | lib/fluent/log.rb | 101 | # ERROR = 3 | COMMENT |
| LOW | lib/fluent/time.rb | 1 | # | COMMENT |
| LOW | lib/fluent/event.rb | 1 | # | COMMENT |
| LOW | lib/fluent/plugin_helper.rb | 1 | # | COMMENT |
| 217 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tasks/backport.rb | 18 | def append_additional_arguments(commands) | CODE |
| LOW | test/test_formatter.rb | 237 | def test_config_params_with_customized_delimiters(data) | CODE |
| LOW | test/test_formatter.rb | 288 | def test_format_with_empty_fields(data) | CODE |
| LOW | test/test_formatter.rb | 300 | def test_config_params_with_fields(data) | CODE |
| LOW | test/test_supervisor.rb | 490 | def test_fluentsigdump_get_path_with_pid(data) | CODE |
| LOW | test/test_supervisor.rb | 569 | def test_invalid_rpc_endpoint(data) | CODE |
| LOW | test/test_supervisor.rb | 849 | def test_logger_with_rotate_age_and_rotate_size(rotate_age) | CODE |
| LOW | test/test_supervisor.rb | 1141 | def test_zero_downtime_restart((daemonize, wait_success, wait_sleep, restart_canceled)) | CODE |
| LOW | test/test_event.rb | 8 | def assert_duplicated_records(es1, es2) | CODE |
| LOW | test/test_log.rb | 85 | def test_output_with_serverengine_loglevel(data) | CODE |
| LOW | test/test_log.rb | 150 | def test_output_with_block_with_serverengine_loglevel(data) | CODE |
| LOW | test/test_log.rb | 214 | def test_execute_block_with_serverengine_loglevel(data) | CODE |
| LOW | test/test_log.rb | 290 | def test_backtrace_with_serverengine_loglevel(data) | CODE |
| LOW⚡ | test/plugin_helper/test_server.rb | 957 | def create_server_pair_signed_by_self(cert_path, private_key_path, passphrase) | CODE |
| LOW⚡ | test/plugin_helper/test_server.rb | 963 | def create_ca_pair_signed_by_self(cert_path, private_key_path, passphrase) | CODE |
| LOW⚡ | test/plugin_helper/test_server.rb | 968 | def create_server_pair_signed_by_ca(ca_cert_path, ca_key_path, ca_key_passphrase, cert_path, private_key_path, passphr | CODE |
| LOW⚡ | test/plugin_helper/test_server.rb | 974 | def create_server_pair_chained_with_root_ca(ca_cert_path, ca_key_path, ca_key_passphrase, cert_path, private_key_path, | CODE |
| LOW | test/plugin_helper/test_service_discovery.rb | 11 | def service_discovery_create_manager(title, configurations:, load_balancer: nil, custom_build_method: nil, interval: | CODE |
| LOW⚡ | test/plugin_helper/data/cert/generate_cert.rb | 41 | def create_server_pair_signed_by_self(cert_path, private_key_path, passphrase) | CODE |
| LOW⚡ | test/plugin_helper/data/cert/generate_cert.rb | 47 | def create_ca_pair_signed_by_self(cert_path, private_key_path, passphrase) | CODE |
| LOW⚡ | test/plugin_helper/data/cert/generate_cert.rb | 53 | def create_server_pair_signed_by_ca(ca_cert_path, ca_key_path, ca_key_passphrase, cert_path, private_key_path, passphras | CODE |
| LOW | test/plugin_helper/data/cert/generate_cert.rb | 87 | def create_cert_pair_chained_with_root_ca(ca_cert_path, ca_key_path, ca_key_passphrase, cert_path, private_key_path, pas | CODE |
| LOW | test/compat/test_parser.rb | 86 | def test_regexp_parser_config(options) | CODE |
| LOW | test/config/test_yaml_parser.rb | 542 | def test_merge_common_parameter_using_include(include_path) | CODE |
| LOW | test/config/assertions.rb | 17 | def assert_text_parsed_as_json(expected, actual) | CODE |
| LOW | test/config/test_config_parser.rb | 232 | def test_rejects_at_prefix_in_the_parameter_name(data) | CODE |
| LOW | test/config/test_config_parser.rb | 245 | def test_not_reject_at_prefix_in_the_parameter_name(data) | CODE |
| LOW | test/plugin/test_formatter_csv.rb | 42 | def test_config_params_with_customized_delimiters(data) | CODE |
| LOW | test/plugin/test_formatter_csv.rb | 106 | def test_format_with_empty_fields(data) | CODE |
| LOW | test/plugin/test_formatter_csv.rb | 116 | def test_config_params_with_fields(data) | CODE |
| LOW | test/plugin/test_in_syslog.rb | 61 | def test_configure_resolve_hostname(param) | CODE |
| LOW | test/plugin/test_in_syslog.rb | 173 | def test_space_after_input_owned_priority_preserves_input_priority_syntax(parser_engine) | CODE |
| LOW | test/plugin/test_in_syslog.rb | 325 | def test_msg_size_with_severity_key(param_name) | CODE |
| LOW | test/plugin/test_in_syslog.rb | 483 | def compare_unmatched_lines_test_result(events, tests, options = {}) | CODE |
| LOW | test/plugin/test_base.rb | 220 | def assert_system_config_workers_value(data) | CODE |
| LOW | test/plugin/test_buf_file.rb | 473 | def write_with_single_record_overflow(m) | CODE |
| LOW⚡ | test/plugin/test_in_tail.rb | 1773 | def test_rotate_file_with_read_from_head(data) | CODE |
| LOW⚡ | test/plugin/test_in_tail.rb | 1782 | def test_rotate_file_with_open_on_every_update(data) | CODE |
| LOW⚡ | test/plugin/test_in_tail.rb | 1791 | def test_rotate_file_with_write_old(data) | CODE |
| LOW | test/plugin/test_in_tail.rb | 550 | def test_emit_with_read_lines_limit(data) | CODE |
| LOW | test/plugin/test_in_tail.rb | 590 | def test_emit_with_read_bytes_limit_per_second(data) | CODE |
| LOW | test/plugin/test_in_tail.rb | 655 | def test_emit_with_read_bytes_limit_per_second(data) | CODE |
| LOW | test/plugin/test_in_tail.rb | 793 | def test_emit_with_read_from_head(data) | CODE |
| LOW | test/plugin/test_in_tail.rb | 962 | def test_follow_inodes_refresh_preserves_worker_draining_position_entries(immediate_unwatch) | CODE |
| LOW | test/plugin/test_in_tail.rb | 1115 | def test_worker_queue_saturation_reschedules_waiting_files(notification_order) | CODE |
| LOW | test/plugin/test_in_tail.rb | 1178 | def test_worker_queue_saturation_drains_detached_waiting_file(notification_order) | CODE |
| LOW | test/plugin/test_in_tail.rb | 1280 | def test_worker_queue_saturation_drains_rotated_file(notification_order) | CODE |
| LOW | test/plugin/test_in_tail.rb | 1394 | def test_worker_shutdown_handles_results_published_during_join(finish_parse) | CODE |
| LOW | test/plugin/test_in_tail.rb | 1598 | def test_emit_without_watch_timer(data) | CODE |
| LOW | test/plugin/test_in_tail.rb | 1656 | def test_emit_with_disable_stat_watcher(data) | CODE |
| LOW | test/plugin/test_in_tail.rb | 1813 | def test_rotate_file_with_write_old_and_no_new_file(data) | CODE |
| LOW | test/plugin/test_in_tail.rb | 2125 | def test_multiline_with_emit_unmatched_lines_true(data) | CODE |
| LOW | test/plugin/test_in_tail.rb | 2154 | def test_multiline_flush_buffer_with_emit_unmatched_lines_and_path_key(data) | CODE |
| LOW | test/plugin/test_in_tail.rb | 2209 | def test_multiline_with_flush_interval(data) | CODE |
| LOW | test/plugin/test_in_tail.rb | 2243 | def test_multiline_encoding_of_flushed_record(data) | CODE |
| LOW | test/plugin/test_in_tail.rb | 2306 | def test_multiline_with_multiple_formats(data) | CODE |
| LOW | test/plugin/test_in_tail.rb | 2347 | def test_multilinelog_with_multiple_paths(data) | CODE |
| LOW | test/plugin/test_in_tail.rb | 2392 | def test_multiline_without_firstline(data) | CODE |
| LOW | test/plugin/test_in_tail.rb | 3516 | def wait_until_dir_stat_can_change(dir) | CODE |
| LOW | test/plugin/test_in_tail.rb | 4751 | def test_lines_collected_with_no_throttling(data) | CODE |
| 124 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | test/config/test_yaml_parser.rb | 23 | $id: dummy_id | CODE |
| LOW | test/config/test_yaml_parser.rb | 31 | assert_equal('dummy_id', config.elements[0]['@id']) | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1400 | dummy_data = "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1402 | ["test.tag.1", event_time('2016-04-13 14:03:21 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1403 | ["test.tag.2", event_time('2016-04-13 14:03:23 +0900'), {"data" => dummy_data, "name" => "yyy", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1404 | ["test.tag.1", event_time('2016-04-13 14:03:29 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1405 | ["test.tag.1", event_time('2016-04-13 14:03:30 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1406 | ["test.tag.1", event_time('2016-04-13 14:03:33 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1407 | ["test.tag.1", event_time('2016-04-13 14:03:38 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "b" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1408 | ["test.tag.1", event_time('2016-04-13 14:03:43 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1409 | ["test.tag.1", event_time('2016-04-13 14:03:49 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "b" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1410 | ["test.tag.2", event_time('2016-04-13 14:03:51 +0900'), {"data" => dummy_data, "name" => "yyy", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1411 | ["test.tag.1", event_time('2016-04-13 14:04:00 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1412 | ["test.tag.2", event_time('2016-04-13 14:04:01 +0900'), {"data" => dummy_data, "name" => "yyy", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1489 | dummy_data = "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1491 | ["test.tag.1", event_time('2016-04-13 14:03:21 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1492 | ["test.tag.2", event_time('2016-04-13 14:03:23 +0900'), {"data" => dummy_data, "name" => "yyy", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1493 | ["test.tag.1", event_time('2016-04-13 14:03:29 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1494 | ["test.tag.1", event_time('2016-04-13 14:03:30 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1495 | ["test.tag.1", event_time('2016-04-13 14:03:33 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1496 | ["test.tag.1", event_time('2016-04-13 14:03:38 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "b" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1497 | ["test.tag.1", event_time('2016-04-13 14:03:43 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1498 | ["test.tag.1", event_time('2016-04-13 14:03:49 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "b" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1499 | ["test.tag.2", event_time('2016-04-13 14:03:51 +0900'), {"data" => dummy_data, "name" => "yyy", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1500 | ["test.tag.1", event_time('2016-04-13 14:04:00 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1501 | ["test.tag.2", event_time('2016-04-13 14:04:01 +0900'), {"data" => dummy_data, "name" => "yyy", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1646 | dummy_data = "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1648 | ["test.tag.1", event_time('2016-04-13 14:03:21 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1649 | ["test.tag.2", event_time('2016-04-13 14:03:23 +0900'), {"data" => dummy_data, "name" => "yyy", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1650 | ["test.tag.1", event_time('2016-04-13 14:03:29 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1651 | ["test.tag.1", event_time('2016-04-13 14:03:30 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1652 | ["test.tag.1", event_time('2016-04-13 14:03:33 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1653 | ["test.tag.1", event_time('2016-04-13 14:03:38 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "b" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1654 | ["test.tag.1", event_time('2016-04-13 14:03:43 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1655 | ["test.tag.1", event_time('2016-04-13 14:03:49 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "b" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1656 | ["test.tag.2", event_time('2016-04-13 14:03:51 +0900'), {"data" => dummy_data, "name" => "yyy", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1657 | ["test.tag.1", event_time('2016-04-13 14:04:00 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1658 | ["test.tag.2", event_time('2016-04-13 14:04:01 +0900'), {"data" => dummy_data, "name" => "yyy", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1765 | dummy_data = "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1767 | ["test.tag.1", event_time('2016-04-13 14:03:21 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1768 | ["test.tag.2", event_time('2016-04-13 14:03:23 +0900'), {"data" => dummy_data, "name" => "yyy", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1769 | ["test.tag.1", event_time('2016-04-13 14:03:29 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1770 | ["test.tag.1", event_time('2016-04-13 14:03:30 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1771 | ["test.tag.1", event_time('2016-04-13 14:03:33 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1772 | ["test.tag.1", event_time('2016-04-13 14:03:38 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "b" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1773 | ["test.tag.1", event_time('2016-04-13 14:03:43 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1774 | ["test.tag.1", event_time('2016-04-13 14:03:49 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "b" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1775 | ["test.tag.2", event_time('2016-04-13 14:03:51 +0900'), {"data" => dummy_data, "name" => "yyy", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1776 | ["test.tag.1", event_time('2016-04-13 14:04:00 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1777 | ["test.tag.2", event_time('2016-04-13 14:04:01 +0900'), {"data" => dummy_data, "name" => "yyy", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1926 | dummy_data = "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1928 | ["test.tag.1", event_time('2016-04-13 14:03:21 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1929 | ["test.tag.2", event_time('2016-04-13 14:03:23 +0900'), {"data" => dummy_data, "name" => "yyy", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1930 | ["test.tag.1", event_time('2016-04-13 14:03:29 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1931 | ["test.tag.1", event_time('2016-04-13 14:03:30 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1932 | ["test.tag.1", event_time('2016-04-13 14:03:33 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1933 | ["test.tag.1", event_time('2016-04-13 14:03:38 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "b" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1934 | ["test.tag.1", event_time('2016-04-13 14:03:43 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "a" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1935 | ["test.tag.1", event_time('2016-04-13 14:03:49 +0900'), {"data" => dummy_data, "name" => "xxx", "service" => "b" | CODE |
| LOW⚡ | test/plugin/test_output_as_buffered.rb | 1936 | ["test.tag.2", event_time('2016-04-13 14:03:51 +0900'), {"data" => dummy_data, "name" => "yyy", "service" => "a" | CODE |
| 2 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | lib/fluent/timezone.rb | 98 | # Create a formatter for a timezone and optionally a format. | COMMENT |
| MEDIUM | lib/fluent/fluent_log_event_router.rb | 35 | # This class is for handling fluentd's inner log | COMMENT |
| MEDIUM | lib/fluent/supervisor.rb | 1010 | # This method is the only method to set signal handlers in Fluentd worker process. | COMMENT |
| MEDIUM | lib/fluent/log.rb | 72 | # Create a unique path for each process. | COMMENT |
| MEDIUM | lib/fluent/plugin/buf_file_single.rb | 134 | # This method is called only when multi worker is configured | COMMENT |
| MEDIUM | lib/fluent/plugin/buf_file.rb | 113 | # This method is called only when multi worker is configured | COMMENT |
| MEDIUM | lib/fluent/plugin/in_tail/position_file.rb | 94 | # This method is similar to #compact but it tries to get less lock to avoid a lock contention | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | lib/fluent/plugin/in_http.rb | 572 | # ========== | COMMENT |
| MEDIUM | lib/fluent/plugin/in_http.rb | 584 | # ================= | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | lib/fluent/compat/file_util.rb | 35 | # Check file is writable in conjunction with mkdir_p(dirname(path)) | COMMENT |
| LOW | lib/fluent/plugin/in_tail/dir_watcher.rb | 120 | # When file is not created yet, Dir.glob returns an empty array. So just add when path is static. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tasks/benchmark.rb | 36 | # Output the results with markdown format | COMMENT |
| LOW | test/plugin/test_out_http.rb | 196 | # Check if an exception is raised on not JSON format use | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | test/command/test_fluentd.rb | 1580 | sleep 5 # make sure to flush each chunk (1s flush interval for 1chunk) | CODE |
| LOW | lib/fluent/fluent_log_event_router.rb | 130 | # to make sure to emit all log events into router, before shutting down | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | lib/fluent/plugin_helper/socket.rb | 39 | # TODO: implement connection pool for specified host | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | lib/fluent/plugin/buffer.rb | 576 | # NOTE: The following line might cause data race depending on Ruby implementations except CRuby | COMMENT |