fix: align Vector component schemas with v0.53.0 spec (#80)

* fix: align Vector component schemas with official spec (112/114 clean)

Bump Vector to 0.53.0 and audit all VectorFlow component schemas against
`vector generate-schema` to fix mismatches:

- Bump Vector from 0.44.0 to 0.53.0 in agent and server Dockerfiles
- Add encoding to required arrays for 25 sinks
- Remove invalid TLS fields from 12 components (implicit via HTTPS/rediss)
- Remove deprecated fields (http headers, elasticsearch suppress_type_name,
  splunk_hec token, databend tls)
- Remove invalid fields (mqtt qos, pulsar dead_letter_queue_topic, etc.)
- Fix required arrays for 8 components (kafka group_id, nats connection_name,
  vector address, opentelemetry grpc/http, throttle window_secs, etc.)
- Fix aws_sns queue_url → topic_arn (Vector docs have copy-paste bug from SQS)
- Add dependsOn for 6 modal components (syslog, socket, fluent, dnstap,
  statsd sources + socket sink) so fields show/hide based on selected mode

* fix: align encoding codecs, compression, enums, and defaults with Vector spec

Deep value-level validation against `vector generate-schema`:

Encoding codecs:
- Remove invalid `ndjson` codec from all sinks and shared.ts default
  (NDJSON in Vector = codec:json + framing:newline_delimited)
- Add missing `otlp` and `syslog` codecs to 20+ sinks
- Standardize all sinks to Vector's canonical 13-codec list

Compression options:
- Add missing algorithms to AWS, GCP, network, and search-db sinks
  (snappy, zlib, zstd where missing)
- Keep Kafka's unique list (lz4 instead of zlib)

Enum value fixes:
- source:http_server method — add DELETE, HEAD, OPTIONS, PATCH
- source:http_client method — add DELETE, OPTIONS, PATCH
- sink:http method — add trace
- sink:clickhouse format — add arrow_stream
- source:host_metrics collectors — add tcp
- source:vector version — remove deprecated v1
- source:docker_logs multiline mode — halt_after → halt_with
- sink:gcp_chronicle region — remove invalid australia-southeast1

Default value fixes:
- source:aws_sqs visibility_timeout_secs — 30 → 300 (10x too low)

* feat: add Vector docs link icon to component config header

Small ExternalLink icon next to the component name in the detail panel
that opens the Vector documentation for that component type. URL is
computed from kind/type: vector.dev/docs/reference/configuration/{kind}s/{type}/

Author: TerrifiedBug

agent/Dockerfile

@@ -9,7 +9,7 @@ RUN CGO_ENABLED=0 go build -ldflags="-s -w -X github.com/TerrifiedBug/vectorflow
 
 # Stage 2: Download Vector
 FROM alpine:3.21 AS vector
-ARG VECTOR_VERSION=0.44.0
+ARG VECTOR_VERSION=0.53.0
 RUN apk add --no-cache curl && \
     curl -sSfL -o /tmp/vector.tar.gz \
       "https://packages.timber.io/vector/${VECTOR_VERSION}/vector-${VECTOR_VERSION}-x86_64-unknown-linux-musl.tar.gz" && \

agent/install.sh

@@ -11,7 +11,7 @@ VECTOR_DATA_DIR="/var/lib/vector"
 CONFIG_DIR="/etc/vectorflow"
 ENV_FILE="${CONFIG_DIR}/agent.env"
 SERVICE_NAME="vf-agent"
-VECTOR_VERSION="0.44.0"
+VECTOR_VERSION="0.53.0"
 
 # Defaults
 VF_URL=""

docker/server/Dockerfile

@@ -12,7 +12,7 @@ RUN --mount=type=cache,target=/root/.local/share/pnpm/store \
 
 # ---- Stage 2: Download Vector binary (cached unless VECTOR_VERSION changes) ----
 FROM alpine:3.21 AS vector
-ARG VECTOR_VERSION=0.44.0
+ARG VECTOR_VERSION=0.53.0
 RUN apk add --no-cache curl && \
     curl -sSfL -o /tmp/vector.tar.gz \
       "https://packages.timber.io/vector/${VECTOR_VERSION}/vector-${VECTOR_VERSION}-x86_64-unknown-linux-musl.tar.gz" && \

src/components/flow/detail-panel.tsx

@@ -1,7 +1,7 @@
 "use client";
 
 import { useCallback, useEffect, useMemo, useState } from "react";
-import { Copy, Trash2, Lock, Info, MousePointerClick } from "lucide-react";
+import { Copy, Trash2, Lock, Info, MousePointerClick, ExternalLink } from "lucide-react";
 import { useFlowStore } from "@/stores/flow-store";
 import { SchemaForm } from "@/components/config-forms/schema-form";
 import { VrlEditor } from "@/components/vrl-editor/vrl-editor";
@@ -255,8 +255,17 @@ export function DetailPanel({ pipelineId, isDeployed }: DetailPanelProps) {
             <Card className="gap-4 py-4">
               <CardHeader className="pb-0">
                 <div className="flex items-center justify-between gap-2">
-                  <CardTitle className="truncate text-base">
+                  <CardTitle className="flex items-center gap-1.5 truncate text-base">
                     {componentDef.displayName}
+                    <a
+                      href={`https://vector.dev/docs/reference/configuration/${componentDef.kind}s/${componentDef.type}/`}
+                      target="_blank"
+                      rel="noopener noreferrer"
+                      className="inline-flex text-muted-foreground hover:text-foreground"
+                      aria-label="Open Vector docs"
+                    >
+                      <ExternalLink className="h-3.5 w-3.5" />
+                    </a>
                   </CardTitle>
                   <div className="flex items-center gap-1.5">
                     <Badge

src/lib/vector/schemas/shared.ts

@@ -175,14 +175,19 @@ export function requestSchema() {
 
 export function encodingSchema(
   codecs: string[] = [
+    "avro",
+    "cef",
+    "csv",
+    "gelf",
     "json",
-    "ndjson",
-    "text",
     "logfmt",
-    "csv",
-    "avro",
-    "raw_message",
+    "native",
     "native_json",
+    "otlp",
+    "protobuf",
+    "raw_message",
+    "syslog",
+    "text",
   ],
 ) {
   return {

src/lib/vector/schemas/sinks/aws.ts

@@ -129,8 +129,8 @@ export const awsSinks: VectorComponentDef[] = [
           type: "string",
           description: "Timezone for date specifiers in templates (default: UTC)",
         },
-        ...encodingSchema(["avro", "cef", "csv", "gelf", "json", "logfmt", "native", "native_json", "protobuf", "raw_message", "text"]),
-        ...compressionSchema(["none", "gzip"], "gzip"),
+        ...encodingSchema(["avro", "cef", "csv", "gelf", "json", "logfmt", "native", "native_json", "otlp", "protobuf", "raw_message", "syslog", "text"]),
+        ...compressionSchema(["gzip", "none", "snappy", "zlib", "zstd"], "gzip"),
         ...authAwsSchema(),
         ...tlsSchema(),
         ...batchSchema({ max_bytes: "10MB", timeout_secs: "300" }),
@@ -197,15 +197,15 @@ export const awsSinks: VectorComponentDef[] = [
           type: "string",
           description: "KMS key ARN for encrypting logs",
         },
-        ...encodingSchema(["avro", "cef", "csv", "gelf", "json", "logfmt", "native", "native_json", "protobuf", "raw_message", "text"]),
-        ...compressionSchema(["none", "gzip"], "none"),
+        ...encodingSchema(["avro", "cef", "csv", "gelf", "json", "logfmt", "native", "native_json", "otlp", "protobuf", "raw_message", "syslog", "text"]),
+        ...compressionSchema(["gzip", "none", "snappy", "zlib", "zstd"], "none"),
         ...authAwsSchema(),
         ...tlsSchema(),
         ...batchSchema({ max_bytes: "1MB", timeout_secs: "1" }),
         ...bufferSchema(),
         ...requestSchema(),
       },
-      required: ["group_name", "stream_name"],
+      required: ["group_name", "stream_name", "encoding"],
     },
   },
   {
@@ -232,7 +232,7 @@ export const awsSinks: VectorComponentDef[] = [
           type: "string",
           description: "Custom endpoint for use with AWS-compatible services",
         },
-        ...compressionSchema(["none", "gzip"], "none"),
+        ...compressionSchema(["gzip", "none", "snappy", "zlib", "zstd"], "none"),
         ...authAwsSchema(),
         ...tlsSchema(),
         ...batchSchema({ timeout_secs: "1" }),
@@ -269,15 +269,15 @@ export const awsSinks: VectorComponentDef[] = [
           type: "string",
           description: "Log field to use as the partition key for Kinesis records",
         },
-        ...encodingSchema(["avro", "cef", "csv", "gelf", "json", "logfmt", "native", "native_json", "protobuf", "raw_message", "text"]),
-        ...compressionSchema(["none", "gzip"], "none"),
+        ...encodingSchema(["avro", "cef", "csv", "gelf", "json", "logfmt", "native", "native_json", "otlp", "protobuf", "raw_message", "syslog", "text"]),
+        ...compressionSchema(["gzip", "none", "snappy", "zlib", "zstd"], "none"),
         ...authAwsSchema(),
         ...tlsSchema(),
         ...batchSchema({ max_bytes: "4MB", timeout_secs: "1" }),
         ...bufferSchema(),
         ...requestSchema(),
       },
-      required: ["stream_name"],
+      required: ["stream_name", "encoding"],
     },
   },
   {
@@ -308,15 +308,15 @@ export const awsSinks: VectorComponentDef[] = [
           type: "string",
           description: "Custom endpoint for use with AWS-compatible services",
         },
-        ...encodingSchema(["avro", "cef", "csv", "gelf", "json", "logfmt", "native", "native_json", "protobuf", "raw_message", "text"]),
-        ...compressionSchema(["none", "gzip"], "none"),
+        ...encodingSchema(["avro", "cef", "csv", "gelf", "json", "logfmt", "native", "native_json", "otlp", "protobuf", "raw_message", "syslog", "text"]),
+        ...compressionSchema(["gzip", "none", "snappy", "zlib", "zstd"], "none"),
         ...authAwsSchema(),
         ...tlsSchema(),
         ...batchSchema({ max_bytes: "5MB", timeout_secs: "1" }),
         ...bufferSchema(),
         ...requestSchema(),
       },
-      required: ["stream_name"],
+      required: ["stream_name", "encoding"],
     },
   },
   {
@@ -351,13 +351,13 @@ export const awsSinks: VectorComponentDef[] = [
           type: "string",
           description: "Deduplication ID for FIFO queues (template-enabled)",
         },
-        ...encodingSchema(["avro", "cef", "csv", "gelf", "json", "logfmt", "native", "native_json", "protobuf", "raw_message", "text"]),
+        ...encodingSchema(["avro", "cef", "csv", "gelf", "json", "logfmt", "native", "native_json", "otlp", "protobuf", "raw_message", "syslog", "text"]),
         ...authAwsSchema(),
         ...tlsSchema(),
         ...bufferSchema(),
         ...requestSchema(),
       },
-      required: ["queue_url"],
+      required: ["queue_url", "encoding"],
     },
   },
   {
@@ -372,9 +372,9 @@ export const awsSinks: VectorComponentDef[] = [
     configSchema: {
       type: "object",
       properties: {
-        queue_url: {
+        topic_arn: {
           type: "string",
-          description: "SQS queue URL for SNS publishing",
+          description: "The ARN of the SNS topic to publish to",
         },
         region: {
           type: "string",
@@ -392,13 +392,13 @@ export const awsSinks: VectorComponentDef[] = [
           type: "string",
           description: "Deduplication ID for FIFO queues (template-enabled)",
         },
-        ...encodingSchema(["avro", "cef", "csv", "gelf", "json", "logfmt", "native", "native_json", "protobuf", "raw_message", "text"]),
+        ...encodingSchema(["avro", "cef", "csv", "gelf", "json", "logfmt", "native", "native_json", "otlp", "protobuf", "raw_message", "syslog", "text"]),
         ...authAwsSchema(),
         ...tlsSchema(),
         ...bufferSchema(),
         ...requestSchema(),
       },
-      required: ["queue_url"],
+      required: ["topic_arn", "encoding"],
     },
   },
 ];

src/lib/vector/schemas/sinks/azure.ts

@@ -56,8 +56,10 @@ export const azureSinks: VectorComponentDef[] = [
           "logfmt",
           "native",
           "native_json",
+          "otlp",
           "protobuf",
           "raw_message",
+          "syslog",
           "text",
         ]),
         ...compressionSchema(
@@ -68,7 +70,7 @@ export const azureSinks: VectorComponentDef[] = [
         ...bufferSchema(),
         ...requestSchema(),
       },
-      required: ["connection_string", "container_name"],
+      required: ["connection_string", "container_name", "encoding"],
     },
   },
   {

src/lib/vector/schemas/sinks/gcp.ts

@@ -108,8 +108,10 @@ export const gcpSinks: VectorComponentDef[] = [
           "logfmt",
           "native",
           "native_json",
+          "otlp",
           "protobuf",
           "raw_message",
+          "syslog",
           "text",
         ]),
         ...compressionSchema(
@@ -121,7 +123,7 @@ export const gcpSinks: VectorComponentDef[] = [
         ...bufferSchema(),
         ...requestSchema(),
       },
-      required: ["bucket"],
+      required: ["bucket", "encoding"],
     },
   },
   {
@@ -225,7 +227,7 @@ export const gcpSinks: VectorComponentDef[] = [
         ...bufferSchema(),
         ...requestSchema(),
       },
-      required: ["log_id"],
+      required: ["log_id", "resource"],
     },
   },
   {
@@ -269,7 +271,7 @@ export const gcpSinks: VectorComponentDef[] = [
         ...bufferSchema(),
         ...requestSchema(),
       },
-      required: ["project_id"],
+      required: ["project_id", "resource"],
     },
   },
   {
@@ -308,16 +310,18 @@ export const gcpSinks: VectorComponentDef[] = [
           "logfmt",
           "native",
           "native_json",
+          "otlp",
           "protobuf",
           "raw_message",
+          "syslog",
           "text",
         ]),
         ...tlsSchema(),
         ...batchSchema({ max_bytes: "10MB", timeout_secs: "1" }),
         ...bufferSchema(),
         ...requestSchema(),
       },
-      required: ["project", "topic"],
+      required: ["project", "topic", "encoding"],
     },
   },
   {
@@ -357,7 +361,6 @@ export const gcpSinks: VectorComponentDef[] = [
             "us",
             "eu",
             "asia",
-            "australia-southeast1",
             "canada",
             "dammam",
             "doha",
@@ -396,17 +399,19 @@ export const gcpSinks: VectorComponentDef[] = [
           "logfmt",
           "native",
           "native_json",
+          "otlp",
           "protobuf",
           "raw_message",
+          "syslog",
           "text",
         ]),
-        ...compressionSchema(["gzip", "none"], "none"),
+        ...compressionSchema(["gzip", "none", "snappy", "zlib", "zstd"], "none"),
         ...tlsSchema(),
         ...batchSchema({ max_bytes: "1MB", timeout_secs: "15" }),
         ...bufferSchema(),
         ...requestSchema(),
       },
-      required: ["customer_id", "log_type"],
+      required: ["customer_id", "log_type", "encoding"],
     },
   },
 ];

src/lib/vector/schemas/sinks/logging.ts

@@ -91,7 +91,7 @@ export const loggingSinks: VectorComponentDef[] = [
         ...bufferSchema(),
         ...requestSchema(),
       },
-      required: ["endpoint"],
+      required: ["endpoint", "encoding"],
     },
   },
   {
@@ -146,7 +146,7 @@ export const loggingSinks: VectorComponentDef[] = [
         ...tlsSchema(),
         ...bufferSchema(),
       },
-      required: ["endpoint"],
+      required: ["endpoint", "encoding"],
     },
   },
   {
@@ -236,7 +236,7 @@ export const loggingSinks: VectorComponentDef[] = [
         ...bufferSchema(),
         ...requestSchema(),
       },
-      required: ["endpoint", "default_token"],
+      required: ["endpoint", "default_token", "encoding"],
     },
   },
   {