Home / elastic / logstash
Repository Analysis

elastic/logstash

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

5.9 Low AI signal View on GitHub
5.9
Adjusted Score
5.9
Raw Score
100%
Time Factor
2026-05-29
Last Push
14,860
Stars
Java
Language
222,307
Lines of Code
1826
Files
744
Pattern Hits
2026-05-31
Scan Date

Score History

Severity Breakdown

CRITICAL 44HIGH 7MEDIUM 41LOW 652

Pattern Findings

744 matches across 15 categories. Click a row to expand file-level details.

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