A high-performance observability data pipeline.
This report presents the forensic synthetic code analysis of vectordotdev/vector, a Rust project with 22,177 GitHub stars. SynthScan v2.0 examined 500,448 lines of code across 6858 source files, recording 1222 pattern matches distributed across 17 syntactic categories. The overall adjusted score of 3.6 places this repository in the Likely human-written 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).
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.
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.
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.
The scanner identified 1222 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.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | Cargo.toml | 541 | # | COMMENT |
| LOW | config/vector.yaml | 1 | # __ __ __ | COMMENT |
| LOW | config/vector.yaml | 41 | json: | COMMENT |
| LOW | config/examples/environment_variables.yaml | 1 | # Environment Variables Example | COMMENT |
| LOW | website/content/en/docs/reference/vrl/_index.md | 61 | COMMENT | |
| LOW | tests/antithesis/harness/src/bin/oracle.rs | 1 | //! oracle: the conservation judge. Mints unique ids, records which ids the | COMMENT |
| LOW | …/antithesis/harness/src/bin/eventually_conservation.rs | 221 | &json!({ "delivered": report.delivered, "delivered_total": report.delivered_total }) | COMMENT |
| LOW | tests/antithesis/scenarios/launch.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | tests/antithesis/scenarios/launch.sh | 21 | # ANTITHESIS_API_KEY api key (or ANTITHESIS_USERNAME + ANTITHESIS_PASSWORD) | COMMENT |
| LOW | tests/antithesis/scenarios/launch.sh | 61 | WEBHOOK="${WEBHOOK:-${SCENARIO_WEBHOOK:-persistent_storage}}" | COMMENT |
| LOW | tests/e2e/datadog/metrics/series.rs | 221 | fn compare_intakes(agent_intake: &SeriesIntake, vector_intake: &SeriesIntake) { | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 181 | # TYPE go_memstats_buck_hash_sys_bytes gauge | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 201 | # HELP go_memstats_heap_objects Number of allocated objects. | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 221 | go_memstats_mcache_inuse_bytes 13888 | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 261 | # HELP mongodb_connections_metrics_created_total totalCreated provides a count of all incoming connections created to th | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 281 | mongodb_extra_info_heap_usage_bytes 0 | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 381 | mongodb_mongod_metrics_get_last_error_wtime_total_milliseconds 0 | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 401 | # TYPE mongodb_mongod_metrics_repl_apply_batches_total_milliseconds counter | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 421 | mongodb_mongod_metrics_repl_executor_queue{type="sleepers"} 0 | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 441 | # TYPE mongodb_mongod_metrics_repl_oplog_insert_bytes_total counter | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 541 | # HELP mongodb_mongod_wiredtiger_log_records_total The total number of compressed/uncompressed records written to the Wi | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 621 | # TYPE go_goroutines gauge | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 641 | # HELP go_memstats_gc_sys_bytes Number of bytes used for garbage collection system metadata. | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 661 | go_memstats_heap_sys_bytes 6.63552e+07 | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 681 | # TYPE go_memstats_mspan_sys_bytes gauge | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 701 | # HELP mongodb_active_reads Telegraf collected metric | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 721 | mongodb_assert_rollovers{host="mba.local",hostname="127.0.0.1:27017",version="4.4.0"} 0 | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 741 | # TYPE mongodb_connections_available untyped | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 761 | # HELP mongodb_cursor_pinned Telegraf collected metric | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 781 | mongodb_delete_command_failed{host="mba.local",hostname="127.0.0.1:27017",version="4.4.0"} 0 | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 801 | # TYPE mongodb_document_inserted untyped | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 821 | # HELP mongodb_flushes Telegraf collected metric | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 841 | mongodb_getmores_per_sec{host="mba.local",hostname="127.0.0.1:27017",version="4.4.0"} 0 | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 861 | # TYPE mongodb_latency_commands_count untyped | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 881 | # HELP mongodb_net_out_bytes Telegraf collected metric | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 901 | mongodb_percent_cache_dirty{host="mba.local",hostname="127.0.0.1:27017",version="4.4.0"} 0 | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 921 | # TYPE mongodb_storage_freelist_search_bucket_exhausted untyped | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 941 | # HELP mongodb_tcmalloc_max_total_thread_cache_bytes Telegraf collected metric | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 961 | mongodb_tcmalloc_pageheap_scavenge_count{host="mba.local",hostname="127.0.0.1:27017",version="4.4.0"} 0 | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 981 | # TYPE mongodb_tcmalloc_total_free_bytes untyped | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 1001 | # HELP mongodb_total_refreshing Telegraf collected metric | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 1021 | mongodb_ttl_passes_per_sec{host="mba.local",hostname="127.0.0.1:27017",version="4.4.0"} 0 | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 1041 | # TYPE mongodb_wtcache_app_threads_page_read_count untyped | COMMENT |
| LOW | rfcs/2020-08-31-3641-mongo-metrics.md | 1061 | # HELP mongodb_wtcache_max_bytes_configured Telegraf collected metric | COMMENT |
| LOW | …s/2021-06-29-7709-helm-update-vector-config-pattern.md | 81 | {{- end }} | COMMENT |
| LOW | …s/2021-06-29-7709-helm-update-vector-config-pattern.md | 101 | # type: host_metrics | COMMENT |
| LOW | scripts/check-style.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | scripts/test-behavior.sh | 1 | #!/bin/bash | COMMENT |
| LOW | scripts/deploy-chart-test.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | scripts/upload-test-results.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | scripts/test-e2e-kubernetes.sh | 61 | # Hint #1: you can use `scripts/start-docker-registry.sh`, but it requires | COMMENT |
| LOW | scripts/package-deb.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | scripts/package-deb.sh | 61 | COMMENT | |
| LOW | scripts/build.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | scripts/upload-benchmarks-s3.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | scripts/sync-install.sh | 1 | #!/bin/bash | COMMENT |
| LOW | scripts/package-archive.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | scripts/package-rpm.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | scripts/run-integration-test.sh | 121 | # Remove stale combined coverage from a previous (possibly failed) attempt so | COMMENT |
| LOW | scripts/environment/prepare.sh | 141 | fi | COMMENT |
| 1012 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 245 | {"log":"\u0009at org.springframework.security.web.context.SecurityContextPersistenceFilter.doFilter(Security | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 247 | {"log":"\u0009at org.springframework.security.web.context.request.async.WebAsyncManagerIntegrationFilter.doF | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 248 | {"log":"\u0009at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 250 | {"log":"\u0009at org.springframework.security.web.FilterChainProxy.doFilterInternal(FilterChainProxy.java:21 | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 251 | {"log":"\u0009at org.springframework.security.web.FilterChainProxy.doFilter(FilterChainProxy.java:178)\n","s | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 252 | {"log":"\u0009at org.springframework.web.filter.DelegatingFilterProxy.invokeDelegate(DelegatingFilterProxy.j | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 253 | {"log":"\u0009at org.springframework.web.filter.DelegatingFilterProxy.doFilter(DelegatingFilterProxy.java:27 | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 254 | {"log":"\u0009at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.jav | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 255 | {"log":"\u0009at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)\n | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 256 | {"log":"\u0009at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.j | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 257 | {"log":"\u0009at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 258 | {"log":"\u0009at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.jav | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 259 | {"log":"\u0009at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)\n | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 260 | {"log":"\u0009at org.springframework.web.filter.HttpPutFormContentFilter.doFilterInternal(HttpPutFormContent | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 261 | {"log":"\u0009at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 262 | {"log":"\u0009at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.jav | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 263 | {"log":"\u0009at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)\n | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 264 | {"log":"\u0009at org.springframework.web.filter.HiddenHttpMethodFilter.doFilterInternal(HiddenHttpMethodFilt | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 265 | {"log":"\u0009at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 266 | {"log":"\u0009at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.jav | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 267 | {"log":"\u0009at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)\n | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 268 | {"log":"\u0009at org.springframework.boot.actuate.metrics.web.servlet.WebMvcMetricsFilter.filterAndRecordMet | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 269 | {"log":"\u0009at org.springframework.boot.actuate.metrics.web.servlet.WebMvcMetricsFilter.doFilterInternal(W | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 270 | {"log":"\u0009at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 271 | {"log":"\u0009at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.jav | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 272 | {"log":"\u0009at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)\n | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 273 | {"log":"\u0009at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFi | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 274 | {"log":"\u0009at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 275 | {"log":"\u0009at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.jav | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 276 | {"log":"\u0009at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)\n | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 277 | {"log":"\u0009at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:198)\n","str | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 278 | {"log":"\u0009at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:96)\n","stre | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 279 | {"log":"\u0009at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:493)\n"," | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 280 | {"log":"\u0009at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:140)\n","stream":" | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 281 | {"log":"\u0009at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:81)\n","stream":"s | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 282 | {"log":"\u0009at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:87)\n","stream | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 283 | {"log":"\u0009at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:342)\n","stream":"st | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 284 | {"log":"\u0009at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:800)\n","stream":"std | CODE |
| CRITICAL⚡ | lib/codecs/src/decoding/framing/character_delimited.rs | 288 | {"log":"\u0009at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49)\n","stream" | CODE |
| CRITICAL | lib/vector-vrl/web-playground/public/index.js | 362 | this.monaco.languages.json.jsonDefaults.setDiagnosticsOptions({ validate: false }); | CODE |
| CRITICAL | lib/vector-vrl/web-playground/public/index.js | 366 | this.monaco.languages.json.jsonDefaults.setDiagnosticsOptions({ validate: true }); | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | config/vector.yaml | 9 | # ------------------------------------------------------------------------------ | COMMENT |
| MEDIUM | config/vector.yaml | 13 | # ------------------------------------------------------------------------------ | COMMENT |
| MEDIUM | config/examples/environment_variables.yaml | 2 | # ------------------------------------------------------------------------------ | COMMENT |
| MEDIUM | config/examples/file_to_cloudwatch_metrics.yaml | 2 | # ------------------------------------------------------------------------------ | COMMENT |
| MEDIUM | config/examples/wrapped_json.yaml | 2 | # ------------------------------------------------------------------------------ | COMMENT |
| MEDIUM | config/examples/es_s3_hybrid.yaml | 2 | # ------------------------------------------------------------------------------ | COMMENT |
| MEDIUM | config/examples/file_to_prometheus.yaml | 2 | # ---------------------------------------------------- | COMMENT |
| MEDIUM | config/examples/stdio.yaml | 2 | # ------------------------------------------------------------------------------ | COMMENT |
| MEDIUM | config/examples/prometheus_to_console.yaml | 2 | # ------------------------------------------------------------------------------ | COMMENT |
| MEDIUM | config/examples/http_sink_custom_retry.yaml | 2 | # ---------------------------------------------------- | COMMENT |
| MEDIUM | distribution/install.sh | 247 | # ------------------------------------------------------------------------------ | COMMENT |
| MEDIUM | distribution/install.sh | 250 | # ------------------------------------------------------------------------------ | COMMENT |
| MEDIUM | lib/codecs/src/encoding/format/parquet.rs | 589 | // ── AutoInfer mode ─────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | lib/codecs/src/encoding/format/parquet.rs | 750 | // ── Schema file mode ───────────────────────────────────────────────────── | COMMENT |
| MEDIUM | lib/codecs/src/encoding/format/parquet.rs | 831 | // ── Schema mode: strict / relaxed ──────────────────────────────────────── | COMMENT |
| MEDIUM | src/cpu_time.rs | 74 | // ── Linux / macOS: CLOCK_THREAD_CPUTIME_ID ──────────────────────────────── | COMMENT |
| MEDIUM | src/cpu_time.rs | 105 | // ── Windows: GetThreadTimes ─────────────────────────────────────────────── | COMMENT |
| MEDIUM | src/cpu_time.rs | 170 | // ── Other platforms: no-op (metric is not emitted on these platforms) ───── | COMMENT |
| MEDIUM | src/cpu_time.rs | 188 | // ── CpuTimedFuture: per-poll CPU time accumulator ───────────────────────── | COMMENT |
| MEDIUM⚡ | src/sinks/webhdfs/mod.rs | 10 | //! ┌───────────────┐ | COMMENT |
| MEDIUM⚡ | src/sinks/webhdfs/mod.rs | 12 | //! └───────────────┘ | COMMENT |
| MEDIUM⚡ | src/sinks/webhdfs/mod.rs | 14 | //! ┌───────────────┐ │ ┌───────────────┐ | COMMENT |
| MEDIUM⚡ | src/sinks/webhdfs/mod.rs | 15 | //! │ Data Node 1 │◄──────────┼───────────►│ Data Node 3 │ | COMMENT |
| MEDIUM⚡ | src/sinks/webhdfs/mod.rs | 16 | //! └───────────────┘ │ └───────────────┘ | COMMENT |
| MEDIUM⚡ | src/sinks/webhdfs/mod.rs | 17 | //! ┌───────┴───────┐ | COMMENT |
| MEDIUM⚡ | src/sinks/webhdfs/mod.rs | 19 | //! └───────────────┘ | COMMENT |
| MEDIUM⚡ | src/sinks/webhdfs/mod.rs | 22 | //! ┌──────┴─────┐ | COMMENT |
| MEDIUM⚡ | src/sinks/webhdfs/mod.rs | 24 | //! └────────────┘ | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | tests/antithesis/harness/Cargo.toml | 9 | # so each scenario builds them with `-p antithesis-harness` and points them at its own | COMMENT |
| MEDIUM | lib/vector-config-macros/src/configurable.rs | 963 | // each variant until it finds one that can deserialize the data correctly. Essentially, | COMMENT |
| MEDIUM | lib/vector-core/src/fanout.rs | 157 | // Essentially, we should only land here if the control channel is closed but we | COMMENT |
| MEDIUM | lib/vector-stream/src/driver.rs | 114 | // Essentially, we bounce back and forth between "grab the new batch from the input | COMMENT |
| MEDIUM | lib/vector-config/tests/integration/named.rs | 6 | // Essentially, this just derives an impl of `vector_config::NamedComponent` where the component | COMMENT |
| MEDIUM | lib/vector-config/src/schema/helpers.rs | 39 | // too generic and muddles the output. Essentially, if the callsite decides to provide an | COMMENT |
| MEDIUM | lib/vector-buffers/src/variants/disk_v2/writer.rs | 1000 | // Essentially, we defer the actual skipping to avoid deadlocking here trying to open a | COMMENT |
| MEDIUM | lib/vector-buffers/src/variants/disk_v2/reader.rs | 1025 | // Essentially: is the writer still writing to this data file or not, and are we | COMMENT |
| MEDIUM | lib/vector-buffers/src/variants/disk_v2/reader.rs | 1086 | // Fundamentally, when `try_read_record` returns `None`, there's three possible | COMMENT |
| MEDIUM | …ector-buffers/src/variants/disk_v2/tests/invariants.rs | 258 | // happening there. Essentially, the process of doing a read or write could contain a | COMMENT |
| MEDIUM | src/config/cmd.rs | 174 | // Start by serializing to a `ConfigBuilder`. This will leverage validation in config | COMMENT |
| MEDIUM | src/sinks/splunk_hec/common/util.rs | 56 | // This sink should undergo a refactor to utilize the `HttpService` | COMMENT |
| MEDIUM | src/sinks/appsignal/service.rs | 27 | // This sink should undergo a refactor to utilize the `HttpService` | COMMENT |
| MEDIUM | src/sinks/datadog/logs/config.rs | 95 | // utilize it, since it all follows the same pattern. | COMMENT |
| MEDIUM | src/sinks/datadog/events/service.rs | 50 | // This sink should undergo a refactor to utilize the `HttpService` | COMMENT |
| MEDIUM | src/sinks/elasticsearch/service.rs | 74 | // This sink should undergo a refactor to utilize the `HttpService` | COMMENT |
| MEDIUM | src/internal_telemetry/allocations/mod.rs | 187 | /// a [`tracing::Span`] to achieve this" we utilize the logical invariants provided by spans -- | COMMENT |
| MEDIUM | src/sources/util/http_client.rs | 65 | /// Builds the context, allowing the source-specific implementation to leverage data from the | COMMENT |
| MEDIUM | src/sources/windows_event_log/checkpoint.rs | 23 | /// Uses Windows Event Log bookmarks for robust position tracking that survives | COMMENT |
| MEDIUM | src/sources/windows_event_log/checkpoint.rs | 57 | /// each channel. Bookmarks are more robust than record IDs as they survive | COMMENT |
| MEDIUM | src/sources/windows_event_log/checkpoint.rs | 99 | /// Bookmarks provide robust position tracking that survives channel clears, | COMMENT |
| MEDIUM | src/sources/windows_event_log/bookmark.rs | 21 | /// Bookmarks provide robust, Windows-managed position tracking in event logs. | COMMENT |
| MEDIUM | src/sources/aws_s3/sqs.rs | 795 | // so we explicitly drop it so that we can again utilize `read_error` below. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | website/content/en/guides/developer/debugging.md | 825 | ##### Step 1: Update the Vector config | COMMENT |
| LOW | website/content/en/guides/developer/debugging.md | 836 | ##### Step 2: Navigate to the Datadog metrics explorer | COMMENT |
| LOW | website/content/en/guides/developer/debugging.md | 853 | ##### Step 1: Update your Vector config | COMMENT |
| LOW | website/content/en/guides/developer/debugging.md | 938 | ##### Step 2: Prometheus configuration | COMMENT |
| LOW | website/content/en/guides/developer/debugging.md | 951 | ##### Step 3: Docker Compose configuration | COMMENT |
| LOW | website/content/en/guides/developer/debugging.md | 995 | ##### Step 4: Setup Grafana | COMMENT |
| LOW | …e/content/en/guides/aws/aws-secrets-manager-example.md | 26 | ## Step 1: Create secrets in AWS Secrets Manager | COMMENT |
| LOW | …e/content/en/guides/aws/aws-secrets-manager-example.md | 44 | ## Step 2: Configure IAM permissions | COMMENT |
| LOW | …e/content/en/guides/aws/aws-secrets-manager-example.md | 85 | ## Step 3: Vector configuration | COMMENT |
| LOW | …e/content/en/guides/aws/aws-secrets-manager-example.md | 209 | ## Step 4: Deploy Vector | COMMENT |
| LOW | …e/content/en/guides/aws/aws-secrets-manager-example.md | 221 | ## Step 5: Monitor and validate | COMMENT |
| LOW⚡ | vdev/src/commands/release/prepare.rs | 138 | // Step 1: Sync with remote and start from master. | COMMENT |
| LOW⚡ | vdev/src/commands/release/prepare.rs | 148 | // Step 2: Create a new release preparation branch | COMMENT |
| LOW | vdev/src/commands/release/prepare.rs | 270 | /// Step 9: Add new version to `versions.cue` | COMMENT |
| LOW | vdev/src/commands/release/prepare.rs | 301 | /// Step 10: Create a new release md file | COMMENT |
| LOW | vdev/src/commands/release/prepare.rs | 483 | // Step 1: get the latest tag | COMMENT |
| LOW | vdev/src/commands/release/prepare.rs | 497 | // Step 2: fetch CHANGELOG.md for that tag | COMMENT |
| LOW | src/sinks/datadog/metrics/encoder.rs | 2032 | // Step 1: measure a single metric's encoded size. | COMMENT |
| LOW | src/sinks/datadog/metrics/encoder.rs | 2048 | // Step 2: encode metrics until buffered_bound decreases (= flush detected). | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tests/integration/gcp/config/invalidauth.json | 6 | "client_email": "test@test.com", | CODE |
| LOW | tests/integration/gcp/config/auth.json | 6 | "client_email": "test@test.com", | CODE |
| LOW | lib/fakedata/src/logs.rs | 36 | "placeholder", | CODE |
| LOW | src/sinks/loki/tests.rs | 95 | labels = {test_name = "placeholder"} | CODE |
| LOW | src/sinks/loki/tests.rs | 140 | labels = {test_name = "placeholder"} | CODE |
| LOW | src/sinks/loki/integration_tests.rs | 42 | labels = {{test_name = "placeholder"}} | CODE |
| LOW | src/sinks/loki/integration_tests.rs | 56 | assert_eq!(test_name.get_ref(), &Bytes::from("placeholder")); | CODE |
| LOW | src/sinks/loki/integration_tests.rs | 71 | labels = {{test_name = "placeholder"}} | CODE |
| LOW | src/sinks/loki/integration_tests.rs | 88 | assert_eq!(test_name.get_ref(), &Bytes::from("placeholder")); | CODE |
| LOW | src/sinks/loki/integration_tests.rs | 393 | labels = {"{{ stream_key }}" = "placeholder"} | CODE |
| LOW | src/sinks/loki/integration_tests.rs | 442 | labels = {test_name = "placeholder"} | CODE |
| LOW | src/sinks/loki/integration_tests.rs | 452 | assert_eq!(test_name.get_ref(), &Bytes::from("placeholder")); | CODE |
| LOW | src/sinks/loki/integration_tests.rs | 633 | labels = {test_name = "placeholder"} | CODE |
| LOW | src/sinks/util/uri.rs | 230 | test_parse("user@example.com", "example.com", Some(("user", ""))); | CODE |
| LOW | src/sinks/gcp_chronicle/chronicle_unstructured.rs | 699 | "client_email": "test@test.com", | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | vdev/src/commands/release/prepare.rs | 138 | // Step 1: Sync with remote and start from master. | COMMENT |
| LOW⚡ | vdev/src/commands/release/prepare.rs | 148 | // Step 2: Create a new release preparation branch | COMMENT |
| LOW | vdev/src/commands/release/prepare.rs | 270 | /// Step 9: Add new version to `versions.cue` | COMMENT |
| LOW | vdev/src/commands/release/prepare.rs | 301 | /// Step 10: Create a new release md file | COMMENT |
| LOW | vdev/src/commands/release/prepare.rs | 483 | // Step 1: get the latest tag | COMMENT |
| LOW | vdev/src/commands/release/prepare.rs | 497 | // Step 2: fetch CHANGELOG.md for that tag | COMMENT |
| LOW | src/sinks/datadog/metrics/encoder.rs | 2032 | // Step 1: measure a single metric's encoded size. | COMMENT |
| LOW | src/sinks/datadog/metrics/encoder.rs | 2048 | // Step 2: encode metrics until buffered_bound decreases (= flush detected). | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | distribution/install.sh | 695 | # Check if curl supports the --retry flag | COMMENT |
| LOW | scripts/check-docs.sh | 31 | # Check if any files were modified | COMMENT |
| LOW | .github/workflows/changes.yml | 428 | # Check if at least one integration test has changes | COMMENT |
| LOW | .github/workflows/changes.yml | 490 | # Check if at least one e2e test has changes | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | scripts/package-deb.sh | 62 | # Create the license file for binary distributions (LICENSE + NOTICE) | COMMENT |
| MEDIUM | scripts/package-archive.sh | 87 | # Create the license file for binary distributions (LICENSE + NOTICE) | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | website/content/en/guides/aws/aws-secrets-manager.md | 30 | "api_key": "your-api-key-here", | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | Cargo.toml | 476 | # make sure to update the external docs when the Lua version changes | COMMENT |
| MEDIUM | scripts/test-e2e-kubernetes.sh | 61 | # Hint #1: you can use `scripts/start-docker-registry.sh`, but it requires | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | .github/workflows/master_merge_queue.yml | 3 | # This workflow orchestrates a collection of workflows that are required for the merge queue check. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | website/content/en/guides/developer/debugging.md | 132 | class DebuggingHTTPRequestHandler(http.server.BaseHTTPRequestHandler): | CODE |
| LOW | docs/tutorials/sinks/2_http_sink.md | 467 | class RequestHandler(http.server.BaseHTTPRequestHandler): | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …tor-buffers/src/variants/disk_v2/tests/known_errors.rs | 237 | // TODO: Add test that emulates "reader throws error when" such that we write three records, each to | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tests/behavior/secrets/mock_secrets_exec.py | 60 | def handle_request(req: Request) -> Response: | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tests/behavior/secrets/mock_secrets_exec.py | 99 | except Exception as e: | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tests/e2e/datadog-metrics/dogstatsd_client/client.py | 4 | CODE |