Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -226,7 +226,14 @@ async fn main() {
// post retry until one sticks, since a node can briefly refuse a write while it is
// still recovering. A wedged node never delivers it and fails here. Runs
// unconditionally.
let deadline = time::Instant::now() + time::Duration::from_secs(45);
//
// The recovery gate above only proves the metrics endpoint answers. That is a
// separate listener from the source's data path, so the source and sink can still
// be unready while metrics already serve, and a just-restarted node needs time to
// bring them up. The round-trip is therefore the real readiness signal and gets the
// same budget as recovery rather than a tight window that expires before the data
// path is serving.
let deadline = time::Instant::now() + time::Duration::from_secs(180);
let mut probe = None;
let mut progressed = false;
while !progressed && time::Instant::now() < deadline {
Expand Down
7 changes: 1 addition & 6 deletions tests/antithesis/scenarios/vector_e2e/Dockerfile
Original file line number Diff line number Diff line change
Expand Up @@ -76,13 +76,8 @@ FROM debian:stable-slim AS vector
RUN apt-get update && apt-get install -y --no-install-recommends curl ca-certificates \
&& rm -rf /var/lib/apt/lists/*
COPY --from=vector-build /usr/local/bin/vector /usr/bin/vector
# Bake the node config plus its benign alternate, which the reload fault swaps in
# to force a sink rebuild.
# Bake the node config; compose selects it via --config.
COPY tests/antithesis/scenarios/vector_e2e/vector.yaml /etc/vector/vector.yaml
COPY tests/antithesis/scenarios/vector_e2e/vector.b.yaml /etc/vector/vector.b.yaml
# The reload fault is an anytime_ test command that runs IN the node container.
# The node stays running because its entrypoint is Vector, not a test command.
COPY --chmod=755 tests/antithesis/scenarios/vector_e2e/anytime_reload.sh /opt/antithesis/test/v1/ve2e/anytime_reload
RUN mkdir -p /symbols && ln -s /usr/bin/vector /symbols/vector
ENV NO_COLOR=1
EXPOSE 8080 9598
Expand Down
4 changes: 1 addition & 3 deletions tests/antithesis/scenarios/vector_e2e/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -26,9 +26,7 @@ One Vector node and one oracle container.

- **vector** takes an `http_server` source (`:8080`) and delivers over `http` to
the oracle through an in-memory buffer with `when_full: block` and e2e acks. It
also exposes Prometheus metrics (`:9598`) for the health gate, and runs the
reload fault: an `anytime_` command swaps `vector.yaml`/`vector.b.yaml` and sends
`SIGHUP`, forcing the sink to rebuild mid-run.
also exposes Prometheus metrics (`:9598`) for the health gate.
- **oracle** (`:8686`) is one container that injects unique event ids at the node
and runs the HTTP endpoint the node's sink delivers back to.

Expand Down
34 changes: 0 additions & 34 deletions tests/antithesis/scenarios/vector_e2e/anytime_reload.sh

This file was deleted.

4 changes: 0 additions & 4 deletions tests/antithesis/scenarios/vector_e2e/docker-compose.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -21,12 +21,8 @@ services:
build: *vector-build
image: ve2e-vector:${ANTITHESIS_IMAGE_TAG:-dev}
entrypoint: ["/usr/bin/vector", "--config", "/etc/vector/vector.yaml"]
# vector runs the reload fault: VECTOR_CONFIG_ALT lets anytime_reload swap
# configs and SIGHUP, forcing the sink to rebuild. No disk buffer, so no volume.
environment:
NO_COLOR: "1"
VECTOR_CONFIG: "/etc/vector/vector.yaml"
VECTOR_CONFIG_ALT: "/etc/vector/vector.b.yaml"
healthcheck: *node-health

oracle:
Expand Down
36 changes: 0 additions & 36 deletions tests/antithesis/scenarios/vector_e2e/vector.b.yaml

This file was deleted.

Loading