Repository Analysis

elastic/logstash

Logstash - transport and process your logs, events, or other data

5.9 Low AI signal View on GitHub

Analysis Overview

This report presents the forensic synthetic code analysis of elastic/logstash, a Java project with 14,905 GitHub stars. SynthScan v2.0 examined 222,535 lines of code across 1828 source files, recording 751 pattern matches distributed across 17 syntactic categories. The overall adjusted score of 5.9 places this repository in the Low AI signal band.

The scanner applied 160+ deterministic lexical heuristics, multi-line block detectors, abstract syntax tree depth profilers, and a cross-file Jaccard similarity matrix to construct a statistically normalised synthetic code estimate. All matches are individually weighted by severity coefficient and contextual multiplier before summation, and the resulting headline score is temporally discounted to account for the repository's development history relative to the commercial emergence of large language model coding tooling (November 2022 onward).

5.9
Adjusted Score
5.9
Raw Score
100%
Time Factor
2026-07-14
Last Push
14.9K
Stars
Java
Language
222.5K
Lines of Code
1.8K
Files
751
Pattern Hits
2026-07-14
Scan Date
0.03
HC Hit Rate

What These Metrics Mean

Adjusted Score
Primary synthetic code indicator. Raw score normalised per 1,000 lines of code and multiplied by the temporal discount factor. This is the definitive comparative metric — use it to rank repositories by AI authorship density.
Raw Score
The unmodified sum of all severity-weighted, context-multiplied pattern match scores before temporal discounting. Reflects the absolute signal strength independent of when the repository was last active.
Time Factor
The temporal discount multiplier (0–100%) applied to the raw score. Repositories last updated before ChatGPT's launch (Nov 2022) receive a 5% factor. Full signal is only assigned to repositories active in the post-adoption era (Jan 2024+).
Pattern Hits
Total count of individual pattern matches across all files and categories. A high hit count with a low score may indicate a very large codebase with isolated AI snippets; a low count with a high score indicates dense, concentrated AI signatures.
HC Hit Rate
High+Critical pattern hits per file, averaged across the repository. This orthogonal signal catches repositories where a few files are densely packed with high-severity AI tells — a strong indicator even when the normalised score appears moderate due to codebase size.
Lines of Code / Files
Total lines and files analysed. The scanner examines 94 file extensions. These denominators are used to normalise the score, enabling fair comparison between repositories of vastly different sizes.

Score History

This chart maps the temporal evolution of the adjusted synthetic code score across successive scan runs. An upward trajectory indicates ongoing incorporation of AI-generated code or expanding LLM-assisted scaffolding; a stable or declining trajectory may reflect active human refactoring, code removal, or the adoption of stricter authorship policies. The dashed secondary line (right axis) independently tracks total raw pattern hit count, which can diverge from the normalised score when codebase size changes significantly between scans.

Severity Breakdown

Classifies detected patterns by their diagnostic confidence and structural impact. CRITICAL patterns (coefficient 10) represent definitive synthetic signatures — hallucinated imports, explicit LLM attribution metadata — virtually never produced by human authors. HIGH (5) indicates strong structural tells such as cross-file repetition or cross-linguistic idioms. MEDIUM (2) covers recognisable conversational padding and AI-specific vocabulary. LOW (1) captures subtle indicators like tautological comments and generic boilerplate that require density to carry independent signal.

CRITICAL 44HIGH 7MEDIUM 42LOW 658

Directory Score Breakdown

This horizontal bar chart decomposes the repository's raw synthetic code score by top-level directory, allowing you to pinpoint precisely which modules or components carry the highest AI authorship density. Directories with disproportionately high scores relative to their size warrant targeted manual review: concentrated AI signatures often trace back to mass-generated configuration layers, auto-ported test suites, LLM-scaffolded boilerplate classes, or entire subsystems authored under heavy copilot assistance. Use this view to prioritise your human code-review effort.

Pattern Findings

The scanner identified 751 distinct pattern matches across 17 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a statistically significant AI authorship indicator. 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 diagnostic confidence level (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — comment-context matches receive a ×1.5 weight because LLMs systematically over-annotate. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier as dense clusters constitute far stronger evidence of synthetic authorship than isolated hits.

Over-Commented Block544 hits · 542 pts
SeverityFileLineSnippetContext
LOW.fossa.yml41 # type: pipCOMMENT
LOWversions.yml21# jruby-runtime-override, if specified, will override the jruby version installed in vendor/jrubyCOMMENT
LOWtools/paquet/spec/spec_helper.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOWtools/paquet/spec/paquet/shell_ui_spec.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOWtools/paquet/spec/paquet/dependency_spec.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOWtools/paquet/spec/paquet/utils_spec.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOWtools/paquet/spec/paquet/gem_spec.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOWtools/paquet/spec/integration/paquet_spec.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOWtools/paquet/lib/paquet.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOWtools/paquet/lib/paquet/shell_ui.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOWtools/paquet/lib/paquet/gem.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOWtools/paquet/lib/paquet/dependency.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOWtools/paquet/lib/paquet/utils.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOWtools/paquet/lib/paquet/version.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOWtools/paquet/lib/paquet/rspec/tasks.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOWtools/logstash-docgen/bin/extract_doc.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOWtools/logstash-docgen/spec/spec_helper.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOWtools/logstash-docgen/spec/logstash/docgen/util_spec.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOW…-docgen/spec/logstash/docgen/dependency_lookup_spec.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOW…gstash-docgen/spec/logstash/docgen/task_runner_spec.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOWtools/logstash-docgen/spec/support/helpers.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOWtools/logstash-docgen/lib/logstash/docgen.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOW…stash-docgen/lib/logstash/docgen/logstash_generator.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOW…ogstash-docgen/lib/logstash/docgen/github_generator.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOWtools/logstash-docgen/lib/logstash/docgen/parser.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOW…ols/logstash-docgen/lib/logstash/docgen/task_runner.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOWtools/logstash-docgen/lib/logstash/docgen/util.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOWtools/logstash-docgen/lib/logstash/docgen/plugin_doc.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOW…s/logstash-docgen/lib/logstash/docgen/static_parser.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOWtools/logstash-docgen/lib/logstash/docgen/version.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOW…logstash-docgen/lib/logstash/docgen/asciidoc_format.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOWtools/logstash-docgen/lib/logstash/docgen/index.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOW…gstash-docgen/lib/logstash/docgen/dependency_lookup.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOWtools/logstash-docgen/lib/logstash/docgen/runner.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOW…/logstash-docgen/lib/logstash/docgen/dynamic_parser.rb1# Licensed to Elasticsearch B.V. under one or more contributorCOMMENT
LOWtools/logstash-docgen/templates/plugin-doc.css21 margin-top: 2em;COMMENT
LOWtools/release/generate_release_notes.rb1#!/usr/bin/env rubyCOMMENT
LOWtools/release/bump_plugin_versions.rb1#!/usr/bin/env rubyCOMMENT
LOWtools/release/generate_release_notes_md.rb1#!/usr/bin/env rubyCOMMENT
LOWbin/logstash.lib.sh1# This script is used to initialize a number of env variables and setup theCOMMENT
LOWconfig/pipelines.yml1# List of pipelines to be loaded by LogstashCOMMENT
LOWconfig/pipelines.yml21#COMMENT
LOWconfig/pipelines.yml41# # to over 50,000 events (1000x50=50,000) will be sent to outputs 50 events at a time instead of aCOMMENT
LOWconfig/pipelines.yml61#COMMENT
LOWconfig/pipelines.yml81#COMMENT
LOWconfig/pipelines.yml101COMMENT
LOWconfig/logstash.yml1# Settings file in YAMLCOMMENT
LOWconfig/logstash.yml21# If omitted the node name will default to the machine's host nameCOMMENT
LOWconfig/logstash.yml41# pipeline.workers: 2COMMENT
LOWconfig/logstash.yml61#COMMENT
LOWconfig/logstash.yml81# "false" disables any extra processing necessary for preserving ordering.COMMENT
LOWconfig/logstash.yml101# Where to fetch the pipeline configuration for the main pipelineCOMMENT
LOWconfig/logstash.yml121# Setting the interval this way is not recommended and might change in later versions.COMMENT
LOWconfig/logstash.yml141#COMMENT
LOWconfig/logstash.yml161# host's loopback interface, ensuring that it is not accessible to the rest ofCOMMENT
LOWconfig/logstash.yml181#COMMENT
LOWconfig/logstash.yml201# resolves to the value stored in the keystore's `HTTP_PASS` variable if presentCOMMENT
LOWconfig/logstash.yml221#COMMENT
LOWconfig/logstash.yml241# If you would like more unacked events to be buffered in Logstash, you can increase theCOMMENT
LOWconfig/logstash.yml261#COMMENT
484 more matches not shown…
Hallucination Indicators44 hits · 495 pts
SeverityFileLineSnippetContext
CRITICALlogstash-core/spec/logstash/pipeline_dlq_commit_spec.rb98 dlq_reader = org.logstash.common.io.DeadLetterQueueReader.new(dlq_path)CODE
CRITICALlogstash-core/spec/logstash/java_pipeline_spec.rb455 org.logstash.config.ir.PipelineConfig.new(CODE
CRITICALlogstash-core/spec/logstash/java_pipeline_spec.rb515 dlq_reader = org.logstash.common.io.DeadLetterQueueReader.new(dlq_path)CODE
CRITICALlogstash-core/spec/logstash/java_pipeline_spec.rb529 org.logstash.config.ir.PipelineConfig.new(CODE
CRITICALlogstash-core/spec/logstash/java_pipeline_spec.rb1838 collected_metric = subject.metric.collector.snapshot_metric.metric_store.get_with_path("stats/pipelines")CODE
CRITICALlogstash-core/spec/logstash/java_pipeline_spec.rb1848 collected_metric = subject.metric.collector.snapshot_metric.metric_store.get_with_path("stats/pipelines")CODE
CRITICAL…ash-core/spec/logstash/instrument/metric_store_spec.rb23 let(:counter) { org.logstash.instrument.metrics.counter.LongCounter.new(key.to_s) }CODE
CRITICAL…ash-core/spec/logstash/instrument/metric_store_spec.rb36 let(:new_counter) { org.logstash.instrument.metrics.counter.LongCounter.new(key.to_s) }CODE
CRITICAL…ash-core/spec/logstash/instrument/metric_store_spec.rb66 metric = subject.fetch_or_store(namespaces, metric_key, org.logstash.instrument.metrics.counter.LongCounter.new(CODE
CRITICAL…ash-core/spec/logstash/instrument/metric_store_spec.rb273 metric = subject.fetch_or_store(namespaces, metric_key, org.logstash.instrument.metrics.counter.LongCounter.new(CODE
CRITICAL…gstash-core/spec/logstash/config/source_loader_spec.rb24 org.logstash.config.ir.PipelineConfig.new(source, id.to_sym, [config_part], LogStash::SETTINGS)CODE
CRITICAL…logstash/plugins/builtin/pipeline_input_output_spec.rb112 event_metrics = input.metric.collector.snapshot_metric.metric_store.get_with_path(CODE
CRITICAL…logstash/plugins/builtin/pipeline_input_output_spec.rb118 event_metrics = output.metric.collector.snapshot_metric.metric_store.get_with_path(CODE
CRITICAL…logstash/plugins/builtin/pipeline_input_output_spec.rb195 event_metrics = output.metric.collector.snapshot_metric.metric_store.get_with_path(CODE
CRITICALlogstash-core/spec/support/helpers.rb107 org.logstash.config.ir.PipelineConfig.new(self.class, pipeline_id.to_sym, config_parts, merged_pipeline_settings)CODE
CRITICALlogstash-core/spec/support/helpers.rb136 org.logstash.config.ir.PipelineConfig.new(LogStash::Config::Source::Local, pipeline_id.to_sym, [config_part], settingsCODE
CRITICALlogstash-core/spec/support/pipeline/pipeline_helpers.rb79 org.logstash.config.ir.PipelineConfig.new(CODE
CRITICALlogstash-core/lib/logstash/java_pipeline.rb71 @flushing = java.util.concurrent.atomic.AtomicBoolean.new(false)CODE
CRITICALlogstash-core/lib/logstash/java_pipeline.rb72 @flushRequested = java.util.concurrent.atomic.AtomicBoolean.new(false)CODE
CRITICALlogstash-core/lib/logstash/java_pipeline.rb73 @shutdownRequested = java.util.concurrent.atomic.AtomicBoolean.new(false)CODE
CRITICALlogstash-core/lib/logstash/agent.rb677 org.logstash.instrument.metrics.counter.LongCounter.fromRubyBase(namespace, key)CODE
CRITICALlogstash-core/lib/logstash/agent.rb682 org.logstash.instrument.metrics.timer.TimerMetric.fromRubyBase(namespace, key)CODE
CRITICALlogstash-core/lib/logstash/agent.rb687 org.logstash.instrument.metrics.FlowMetric.create(name, numerator_metric, denominator_metric)CODE
CRITICALlogstash-core/lib/logstash/instrument/metric_type.rb28 when :counter then return org.logstash.instrument.metrics.counter.LongCounter.new(key.to_s)CODE
CRITICALlogstash-core/lib/logstash/instrument/metric_type.rb29 when :gauge then return org.logstash.instrument.metrics.gauge.LazyDelegatingGauge.new(key.to_s)CODE
CRITICALlogstash-core/lib/logstash/instrument/metric_type.rb30 when :uptime then return org.logstash.instrument.metrics.UptimeMetric.new(key.to_s)CODE
CRITICAL…h-core/lib/logstash/instrument/periodic_poller/otel.rb79 @otel_service = org.logstash.instrument.metrics.otel.OtelMetricsService.new(config)CODE
CRITICALlogstash-core/lib/logstash/config/lir_serializer.rb125 edges_with_separators_removed << edge(org.logstash.config.ir.graph.BooleanEdge.new(e.edgeType, e.from, outCODE
CRITICALlogstash-core/lib/logstash/config/lir_serializer.rb127 edges_with_separators_removed << edge(org.logstash.config.ir.graph.PlainEdge.factory.make(e.from, outgoingCODE
CRITICALlogstash-core/lib/logstash/config/source/local.rb215 [org.logstash.config.ir.PipelineConfig.new(self.class, @settings.get("pipeline.id").to_sym, config_parts, @settingCODE
CRITICAL…sh-core/lib/logstash/plugins/builtin/pipeline/input.rb31 @running = java.util.concurrent.atomic.AtomicBoolean.new(false)CODE
CRITICAL…/java/org/logstash/config/ir/CompiledPipelineTest.java544 final RubyObject configNameDouble = org.logstash.config.ir.PluginConfigNameMethodDouble.create(name);CODE
CRITICAL…/java/org/logstash/config/ir/CompiledPipelineTest.java737 final RubyObject configNameDouble = org.logstash.config.ir.PluginConfigNameMethodDouble.create(name);CODE
CRITICAL…java/org/logstash/log/PipelineRoutingAppenderTest.java46 org.apache.logging.log4j.ThreadContext.put("pipeline.id", pipelineId);CODE
CRITICAL…rg/logstash/config/ir/compiler/OutputDelegatorExt.java110 org.apache.logging.log4j.ThreadContext.put("plugin.id", pluginId.toString());CODE
CRITICAL…rg/logstash/config/ir/compiler/OutputDelegatorExt.java115 org.apache.logging.log4j.ThreadContext.remove("plugin.id");CODE
CRITICAL…rg/logstash/config/ir/compiler/FilterDelegatorExt.java131 org.apache.logging.log4j.ThreadContext.put("plugin.id", pluginId.toString());CODE
CRITICAL…rg/logstash/config/ir/compiler/FilterDelegatorExt.java136 org.apache.logging.log4j.ThreadContext.remove("plugin.id");CODE
CRITICAL…logstash/config/ir/compiler/JavaInputDelegatorExt.java84 org.apache.logging.log4j.ThreadContext.put("pipeline.id", pipeline.pipelineId().toString());CODE
CRITICAL…logstash/config/ir/compiler/JavaInputDelegatorExt.java85 org.apache.logging.log4j.ThreadContext.put("plugin.id", this.getId(context).toString());CODE
CRITICAL…in/java/org/logstash/plugins/NamespacedMetricImpl.java98 USER_METRIC userMetric = org.logstash.instrument.metrics.UserMetric.fromRubyBase(metrics, threadContext.runtime.CODE
CRITICAL…gstash/plugins/factory/ExecutionContextFactoryExt.java70 if (org.logstash.common.io.DeadLetterQueueWriter.class.isAssignableFrom(innerWriter.getJavaClass())) {CODE
CRITICALdocs/static/spec/openapi/logstash-api.yaml1648 - "java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)"CODE
CRITICALdocs/static/spec/openapi/logstash-api.yaml1649 - "java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueueCODE
Self-Referential Comments27 hits · 81 pts
SeverityFileLineSnippetContext
MEDIUM…stash-docgen/lib/logstash/docgen/logstash_generator.rb27 # This class is used to generate the documentation inside a working logstashCOMMENT
MEDIUM…stash-docgen/lib/logstash/docgen/logstash_generator.rb31 # This class is invoked inside logstash with a rake task named: `docs:generate-plugins`COMMENT
MEDIUMtools/logstash-docgen/lib/logstash/docgen/parser.rb74 # This class is mostly a data class that represent what will be exposed in the ERB filesCOMMENT
MEDIUMtools/logstash-docgen/lib/logstash/docgen/parser.rb172 # This class is the main point of entry to the parsing of the plugin ruby file,COMMENT
MEDIUM…s/logstash-docgen/lib/logstash/docgen/static_parser.rb19 # This class is parsing static content of the main class andCOMMENT
MEDIUMdocker/data/logstash/config/pipelines.yml1# This file is where you define your pipelines. You can define multiple.COMMENT
MEDIUM…spec/logstash/persisted_queue_config_validator_spec.rb87 # Create a pipeline config double that matches what the class expectsCOMMENT
MEDIUM…core/spec/logstash/settings/writable_directory_spec.rb42 # Create a new WritableDirectorySetting setting with no default value strictCOMMENT
MEDIUM…core/spec/logstash/settings/writable_directory_spec.rb113 # Create a path with at least one subdirectory we can try to fiddle with permissionsCOMMENT
MEDIUMlogstash-core/spec/support/shared_examples.rb18# Define the common operation that both the `NullMetric` class and the Namespaced class should answer.COMMENT
MEDIUMlogstash-core/lib/logstash/agent.rb106 # Create the collectors and configured it with the libraryCOMMENT
MEDIUM…core/lib/logstash/instrument/namespaced_null_metric.rb18# This file is kept for backwards compatibility with plugins that include it directly.COMMENT
MEDIUM…tash-core/lib/logstash/instrument/namespaced_metric.rb18# This file is kept for backwards compatibility with plugins that include it.COMMENT
MEDIUMlogstash-core/lib/logstash/instrument/metric.rb18# This file is kept for backwards compatibility with plugins that include it.COMMENT
MEDIUMlogstash-core/lib/logstash/config/mixin.rb28# This module is meant as a mixin to classes wishing to be configurable fromCOMMENT
MEDIUMlogstash-core/lib/logstash/config/mixin.rb56 # This method is called when someone does 'include LogStash::Config'COMMENT
MEDIUMlogstash-core/lib/logstash/config/mixin.rb192 # Define a new configuration settingCOMMENT
MEDIUMlogstash-core/lib/logstash/config/mixin.rb246 # This method is invoked whenever someone subclasses us, like:COMMENT
MEDIUMlogstash-core/lib/logstash/patches/clamp.rb131 # Create a subclass of Clamp::Command that enforces the use ofCOMMENT
MEDIUMqa/integration/framework/cert_helpers.rb59# Create a PKCS12 truststore containing one or more CA certificates.COMMENT
MEDIUM.buildkite/scripts/common/vm-agent-multi-jdk.sh4# This file contains prerequisite bootstrap invocationsCOMMENT
MEDIUM.buildkite/scripts/common/container-agent.sh4# This file contains prerequisite bootstrap invocationsCOMMENT
MEDIUM.buildkite/scripts/common/vm-agent.sh4# This file contains prerequisite bootstrap invocationsCOMMENT
MEDIUM…ldkite/scripts/dra/build-and-push-observability-sre.sh36# Create the full tag with SHA and architectureCOMMENT
MEDIUMlib/pluginmanager/bundler/logstash_injector.rb67 # This class is pretty similar to what bundler's injector class is doingCOMMENT
MEDIUMx-pack/lib/license_checker/license_manager.rb72 # Create a daemon thread for the license checker to stop this thread from keeping logstash running in theCOMMENT
MEDIUMpkg/pipelines.yml1# This file is where you define your pipelines. You can define multiple.COMMENT
Hyper-Verbose Identifiers79 hits · 80 pts
SeverityFileLineSnippetContext
LOW…s/logstash-docgen/lib/logstash/docgen/static_parser.rb66 def parse_new_class_description(class_definition)CODE
LOWci/test_plugins.rb250def select_by_tiers_and_kinds(tiers, kinds)CODE
LOWlogstash-core/spec/logstash/java_pipeline_spec.rb1803 def build_pipeline_string_config(dummyinput_config)CODE
LOWlogstash-core/spec/logstash/event_dispatcher_spec.rb30 def method_exists_with_arguments(argument1, argument2, argument3)CODE
LOWlogstash-core/spec/logstash/event_dispatcher_spec.rb43 def method_exists_with_arguments(argument1, argument2, argument3)CODE
LOW…gstash-core/spec/logstash/config/source_loader_spec.rb22def temporary_pipeline_config(id, source, reader = "random_reader")CODE
LOWlogstash-core/spec/support/helpers.rb120def mock_java_pipeline_from_string(config_string, settings = LogStash::SETTINGS, metric = nil)CODE
LOWlogstash-core/lib/logstash/java_pipeline.rb719 def wait_input_threads_termination(timeout_seconds, &block)CODE
LOWlogstash-core/lib/logstash/agent.rb399 def resolve_actions_and_converge_state(pipeline_configs)CODE
LOWlogstash-core/lib/logstash/agent.rb411 def converge_state_with_resolved_actions(pipeline_actions)CODE
LOWlogstash-core/lib/logstash/agent.rb696 def initialize_pipeline_metrics(action)CODE
LOWlogstash-core/lib/logstash/agent.rb706 def update_successful_reload_metrics(action, action_result)CODE
LOWlogstash-core/lib/logstash/agent.rb715 def initialize_geoip_database_metrics(metric)CODE
LOWlogstash-core/lib/logstash/instrument/metric_store.rb311 def fetch_or_store_namespaces(namespaces_path)CODE
LOW…h-core/lib/logstash/instrument/periodic_poller/otel.rb331 def register_pipeline_gauges_for(pipeline_id)CODE
LOW…h-core/lib/logstash/instrument/periodic_poller/otel.rb391 def register_pipeline_counters_for(pipeline_id)CODE
LOW…h-core/lib/logstash/instrument/periodic_poller/otel.rb436 def register_observable_counter(name, description, unit, attributes = Attributes.empty, &block)CODE
LOW…h-core/lib/logstash/instrument/periodic_poller/otel.rb461 def get_pipeline_metric_value(pipeline_id, *path)CODE
LOW…h-core/lib/logstash/instrument/periodic_poller/otel.rb475 def create_pipeline_attributes(pipeline_id)CODE
LOW…h-core/lib/logstash/instrument/periodic_poller/otel.rb491 def register_plugin_metrics_for(pipeline_id)CODE
LOW…h-core/lib/logstash/instrument/periodic_poller/otel.rb519 def register_plugin_counters_for(pipeline_id, plugin_type, plugin_id)CODE
LOW…sh-core/lib/logstash/instrument/periodic_poller/jvm.rb186 def aggregate_information_for(collection)CODE
LOWlogstash-core/lib/logstash/config/lir_serializer.rb119 def remove_separators_from_edges(edges)CODE
LOWlogstash-core/lib/logstash/config/mixin.rb269 def validate_check_invalid_parameter_names(params)CODE
LOWlogstash-core/lib/logstash/config/mixin.rb291 def validate_check_required_parameter(config_key, config_opts, k, v)CODE
LOWlogstash-core/lib/logstash/config/mixin.rb299 def validate_check_required_parameter_names(params)CODE
LOWlogstash-core/lib/logstash/config/mixin.rb341 def validate_check_parameter_values(params)CODE
LOWlogstash-core/lib/logstash/config/source/multi_local.rb105 def detect_duplicate_pipelines(pipelines)CODE
LOWlogstash-core/lib/logstash/patches/clamp.rb86 def define_deprecated_accessors_for(option, opts, &block)CODE
LOWlogstash-core/lib/logstash/patches/clamp.rb90 def define_deprecated_writer_for(option, opts, &block)CODE
LOWlogstash-core/lib/logstash/api/commands/node.rb109 def decorate_with_cluster_uuids(vertex)CODE
LOWlogstash-core/lib/logstash/api/commands/stats.rb234 def reshape_histogram_percentiles_for_window(target_field, histogram_metric, window, result)CODE
LOWlogstash-core/lib/logstash/api/modules/root.rb80 def wait_for_status_and_respond(target_status, timeout)CODE
LOW…ec/unit/plugin_manager/offline_plugin_packager_spec.rb27def retrieve_packaged_plugins(path)CODE
LOW…ec/unit/plugin_manager/offline_plugin_packager_spec.rb31def retrieve_dependencies_gems(path)CODE
LOWqa/docker/spec/spec_helper.rb73def license_agreement_for_flavor(flavor)CODE
LOWqa/integration/framework/helpers.rb90 def extract_gem_data_from_file(gem_file)CODE
LOWqa/integration/specs/spec_helper.rb18def es_allow_wildcard_deletes(es_client)CODE
LOWqa/integration/specs/pipeline_log_spec.rb188 def wait_logstash_process_terminate(service)CODE
LOWqa/integration/specs/tls_hot_reload_spec.rb61 def wait_for_pipeline_reloads(logstash_service, *pipeline_ids, retries: 15, &block)CODE
LOWqa/integration/specs/tls_hot_reload_spec.rb86 def wait_for_pipeline_reload_state(logstash_service, *pipeline_ids, successes:, failures:, retries: 15)CODE
LOWqa/integration/specs/tls_hot_reload_spec.rb93 def wait_for_pipeline_reload_failures(logstash_service, *pipeline_ids, failures:, retries: 15)CODE
LOWqa/integration/specs/tls_hot_reload_spec.rb99 def assert_pipeline_reload_state_stable(logstash_service, *pipeline_ids, successes:, failures:, retries: 5)CODE
LOWqa/integration/specs/direct_heap_allocator_flag_spec.rb108 def find_last_mem_dump_log_line(log_file)CODE
LOWqa/integration/services/logstash_service.rb142 def start_background_with_config_settings(config, settings_file)CODE
LOWqa/acceptance/helpers.rb22def logstash_download_metadata(version, arch, artifact_type)CODE
LOWqa/acceptance/helpers.rb27def fetch_latest_logstash_release_version(branch)CODE
LOWqa/acceptance/spec/spec_helper.rb23def with_running_logstash_service(logstash)CODE
LOW…lure_injector/lib/logstash/filters/failure_injector.rb74 def degrade_or_crash_if_required(phase)CODE
LOW…lure_injector/lib/logstash/outputs/failure_injector.rb74 def degrade_or_crash_if_required(phase)CODE
LOWqa/rspec/commands/base.rb153 def jdk_architecture_extension(skip_jdk_infix)CODE
LOW.buildkite/scripts/jdk-matrix-tests/generate-steps.py211 def succeeded_step_annotation(self, step_name_human) -> str:STRING
LOW.buildkite/scripts/jdk-matrix-tests/generate-steps.py279 def pq_integration_test_parts(self, parts) -> list[partial[JobRetValues]]:STRING
LOW.buildkite/scripts/health-report-tests/bootstrap.py45 def __resolve_latest_stack_version_for(self, major_version: str) -> str:STRING
LOW…ildkite/scripts/snyk/artifact-scan/extract_versions.rb297 def infer_version_from_gem_path(jar_path)CODE
LOW.buildkite/scripts/dra/generatesteps.py8def to_bk_key_friendly_string(key):CODE
LOW.buildkite/scripts/dra/generatesteps.py107def ship_observability_sre_image_steps(branch, workflow_type):STRING
LOWlib/bootstrap/bundler.rb84 def restart_with_locked_bundler_if_needed(*)CODE
LOWlib/bootstrap/bundler.rb195 def execute_bundler_with_retry(options)CODE
LOWlib/bootstrap/bundler.rb258 def expand_logstash_mixin_dependencies(plugin_names); require 'set'CODE
19 more matches not shown…
AI Slop Vocabulary13 hits · 26 pts
SeverityFileLineSnippetContext
MEDIUMconfig/logstash.yml401# Determine where to allocate memory buffers, for plugins that leverage them.COMMENT
LOWlogstash-core/spec/logstash/runner_spec.rb567 # The runner should just pass the code from the agent executeCOMMENT
MEDIUMlogstash-core/spec/logstash/java_pipeline_spec.rb264 # test harness for https://github.com/elastic/logstash/issues/6055COMMENT
LOWlogstash-core/lib/logstash/agent.rb590 # In this context I could just call shutdown, but I've decided toCOMMENT
LOWlogstash-core/lib/logstash/util.rb118 # dst doesn't have this key, just set it.COMMENT
LOWlogstash-core/lib/logstash/util.rb155 # dst doesn't have this key, just set it.COMMENT
LOWlogstash-core/lib/logstash/runner.rb300 # Skip any validation and just return the versionCOMMENT
LOWlogstash-core/lib/logstash/api/modules/base.rb51 # So we manually create a new instance of NotFound and just pass it down.COMMENT
MEDIUM…ldkite/scripts/dra/build-and-push-observability-sre.sh4# This allows us to utilize the make file for building the container andCOMMENT
MEDIUMlib/bootstrap/rspec.rb21# Essentially we end up with a load path that favors bundlers gem env over stdlib. This isCOMMENT
LOWlib/pluginmanager/install.rb43 # if we dont detect an pack we will just use the normal `Bundle install` Strategy`COMMENT
LOW…k/qa/integration/management/multiple_pipelines_spec.rb155 # In the case that some part of the path is missing just return nilCOMMENT
LOWx-pack/lib/config_management/hooks.rb30 # If xpack is enabled we can safely remove the local source completely and just useCOMMENT
Excessive Try-Catch Wrapping11 hits · 18 pts
SeverityFileLineSnippetContext
MEDIUM…ldkite/scripts/health-report-tests/config_validator.py56 print(f"Error in YAML file: {exc}")CODE
LOW.buildkite/scripts/health-report-tests/main.py78 except Exception as e:CODE
LOW.buildkite/scripts/snyk/plugins-scan/generate-steps.py54 except Exception as e:CODE
LOW.buildkite/scripts/snyk/artifact-scan/generate-steps.py16 except Exception as e:CODE
MEDIUM.buildkite/scripts/snyk/artifact-scan/generate-steps.py17 print(f"Error: Failed to fetch logstash versions: {e}", file=sys.stderr)CODE
MEDIUM.buildkite/scripts/snyk/artifact-scan/generate-steps.py11def fetch_logstash_versions() -> dict:CODE
MEDIUM…anup-artifact-stale-projects/cleanup-stale-projects.py55 print("Error: SNYK_TOKEN environment variable is required", file=sys.stderr)CODE
LOW…anup-artifact-stale-projects/cleanup-stale-projects.py81 except Exception as e:CODE
MEDIUM…anup-artifact-stale-projects/cleanup-stale-projects.py82 print(f"Error: Failed to fetch logstash versions: {e}", file=sys.stderr)CODE
MEDIUM…anup-artifact-stale-projects/cleanup-stale-projects.py108 print("Error: Could not find logstash org", file=sys.stderr)CODE
MEDIUM…anup-artifact-stale-projects/cleanup-stale-projects.py143 print(f"Error: Could not find target '{ARTIFACT_SCAN_REMOTE_REPO_URL}'", file=sys.stderr)CODE
Magic Placeholder Names3 hits · 15 pts
SeverityFileLineSnippetContext
HIGHdocs/reference/monitoring-with-opentelemetry.md104 api_key: "your-api-key"CODE
HIGHdocs/reference/ea-integration-tutorial.md110 api_key => "your-api-key"CODE
HIGHdocs/reference/ea-integration-tutorial.md118 api_key => "your-api-key"CODE
Cross-File Repetition3 hits · 15 pts
SeverityFileLineSnippetContext
HIGH.buildkite/scripts/jdk-matrix-tests/generate-steps.py0convert and return key to an acceptable format for buildkite's key: field only alphanumerics, dashes and underscores areSTRING
HIGH.buildkite/scripts/dra/generatesteps.py0convert and return key to an acceptable format for buildkite's key: field only alphanumerics, dashes and underscores areSTRING
HIGH.buildkite/scripts/exhaustive-tests/generate-steps.py0convert and return key to an acceptable format for buildkite's key: field only alphanumerics, dashes and underscores areSTRING
Redundant / Tautological Comments8 hits · 12 pts
SeverityFileLineSnippetContext
LOWlogstash-core/lib/logstash/config/mixin.rb567 if !File.exist?(value.first) # Check if the file existsCODE
LOWlogstash-core/lib/logstash/config/source/local.rb188 # Check if configuration auto-reload is used that -f is specifiedCOMMENT
LOWlogstash-core/lib/logstash/config/source/local.rb192 # Check if both -f and -e are presentCOMMENT
LOWlogstash-core/lib/logstash/inputs/threadable.rb24 # Set this to the number of threads you want this input to spawn.COMMENT
LOW…ildkite/scripts/snyk/artifact-scan/extract_versions.rb225 # Check if the pom.properties artifact matches the JAR nameCOMMENT
LOW…te/scripts/dra/multi-architecture-observability-sre.sh10# Set INCLUDE_COMMIT_ID to include git SHA in versionCOMMENT
LOWlib/pluginmanager/install.rb126 # Check if the specified gems containsCOMMENT
LOW…k/lib/monitoring/inputs/metrics/stats_event_factory.rb119 # Check if pipeline is nil to avoid race condition where metrics system refers pipeline that has been stopped alCOMMENT
Decorative Section Separators3 hits · 9 pts
SeverityFileLineSnippetContext
MEDIUMlogstash-core/lib/logstash/plugin.rb49 # ---------------------------------------------------------------------------------------------------COMMENT
MEDIUMlogstash-core/lib/logstash/plugin.rb55 # ---------------------------------------------------------------------------------------------------COMMENT
MEDIUMlogstash-core/lib/logstash/plugin_metadata.rb32 # ------------------COMMENT
Fake / Example Data6 hits · 6 pts
SeverityFileLineSnippetContext
LOWlogstash-core/spec/logstash/pipeline_pq_file_spec.rb59 let(:dummy_id) { "my-dummyid" }CODE
LOWlogstash-core/spec/logstash/pipeline_pq_file_spec.rb72 id => "#{dummy_id}"CODE
LOWlogstash-core/spec/logstash/java_pipeline_spec.rb1588 let(:dummy_id) { "my-multiline" }CODE
LOWlogstash-core/spec/logstash/java_pipeline_spec.rb1602 id => "#{dummy_id}"CODE
LOWlogstash-core/spec/logstash/java_pipeline_spec.rb1664 [dummy_id, dummy_id_other].map(&:to_sym).each do |id|CODE
LOWlogstash-core/spec/logstash/java_pipeline_spec.rb1686 [dummy_id, dummy_id_other].map(&:to_sym).each do |id|CODE
Cross-Language Confusion1 hit · 5 pts
SeverityFileLineSnippetContext
HIGH.buildkite/scripts/snyk/plugins-scan/generate-steps.py133cd logstash && ./gradlew clean bootstrap installDefaultGems && cd ..CODE
Modern AI Meta-Vocabulary1 hit · 3 pts
SeverityFileLineSnippetContext
MEDIUM…ogstash-docgen/lib/logstash/docgen/github_generator.rb135 # This class orchestrate all the operation between the `logstash-plugins` organization and theCOMMENT
Example Usage Blocks2 hits · 3 pts
SeverityFileLineSnippetContext
LOWci/test_plugins.rb8# Usage example:COMMENT
LOW.buildkite/scripts/benchmark/marathon.sh7# Usage:COMMENT
Deep Nesting3 hits · 3 pts
SeverityFileLineSnippetContext
LOW…ldkite/scripts/health-report-tests/config_validator.py21CODE
LOW.buildkite/scripts/health-report-tests/main.py39CODE
LOW.buildkite/scripts/snyk/artifact-scan/generate-steps.py37CODE
Unused Imports2 hits · 2 pts
SeverityFileLineSnippetContext
LOW…ldkite/scripts/health-report-tests/config_validator.py2CODE
LOW.buildkite/scripts/dra/generatesteps.py2CODE
Slop Phrases1 hit · 2 pts
SeverityFileLineSnippetContext
LOWlogstash-core/lib/logstash/config/config_ast.rb421 # so we must make sure to return the current event.COMMENT