Ettore Di Giacinto 70833fbbdf fix(distributed): harden staged resource ownership ...

Bind cleanup to storage namespaces and generation-scoped quantization state. Validate backend outputs, prove inputs reach worker staging, and make failed-start cleanup retryable.

Assisted-by: Codex:GPT-5 [apply_patch] [exec_command]

2026-09-27 03:05:13 +00:00

..

cluster

fix(distributed): harden staged resource ownership

2026-09-27 03:05:13 +00:00

agent_distributed_test.go

feat(cluster): make a peer prove which replica it is

2026-09-27 03:05:13 +00:00

agent_native_executor_test.go

chore(distributed): stop telling an operator to run a NATS cluster

2026-09-27 03:05:13 +00:00

backend_logs_test.go

feat(cluster): reach every worker through its tunnel, never its address

2026-09-27 03:05:12 +00:00

cluster_baseline_test.go

chore(distributed): take the nats-io modules out of the build

2026-09-27 03:05:13 +00:00

cluster_busless_test.go

test(distributed): prove the busless cluster on two frontends and two workers

2026-09-27 03:05:13 +00:00

cluster_control_test.go

chore(distributed): take the nats-io modules out of the build

2026-09-27 03:05:13 +00:00

cluster_failover_test.go

test(distributed): pin cluster health timings

2026-09-27 03:05:13 +00:00

cluster_fanout_test.go

test(distributed): prove the fan-out carrier between two real replicas

2026-09-27 03:05:13 +00:00

cluster_feature_conformance_test.go

fix(distributed): harden staged resource ownership

2026-09-27 03:05:13 +00:00

cluster_peerlink_test.go

feat(cluster): make a peer prove which replica it is

2026-09-27 03:05:13 +00:00

cluster_tunnel_test.go

fix(distributed): read a departed agent tunnel as the routing fact it is

2026-09-27 03:05:13 +00:00

control_workers_test.go

test(distributed): prove phase 3 end to end, under real processes

2026-09-27 03:05:12 +00:00

db_latency_resilience_test.go

test(distributed): migrate before restricting DB

2026-09-27 03:05:13 +00:00

dbname_test.go

test(distributed): correct the claims the e2e comments make

2026-09-27 03:05:12 +00:00

distributed_full_flow_test.go

feat(distributed): stop a backend on one route, whatever the worker is

2026-09-27 03:05:12 +00:00

distributed_store_test.go

test(distributed): name the replica endpoint the router now requires

2026-09-27 03:05:12 +00:00

distributed_suite_test.go

feat: add distributed mode (#9124)

2026-03-30 00:47:27 +02:00

file_staging_test.go

feat(distributed): serve file staging over the worker tunnel

2026-09-27 03:05:12 +00:00

finetune_distributed_test.go

chore(distributed): take the nats-io modules out of the build

2026-09-27 03:05:13 +00:00

foundation_test.go

chore(distributed): take the nats-io modules out of the build

2026-09-27 03:05:13 +00:00

gallery_distributed_test.go

chore(distributed): take the nats-io modules out of the build

2026-09-27 03:05:13 +00:00

job_dispatch_test.go

feat(cluster): make a peer prove which replica it is

2026-09-27 03:05:13 +00:00

job_distribution_test.go

feat(cluster): make a peer prove which replica it is

2026-09-27 03:05:13 +00:00

managers_test.go

feat(distributed): stop a backend on one route, whatever the worker is

2026-09-27 03:05:12 +00:00

mcp_ci_job_helper_test.go

chore(distributed): stop telling an operator to run a NATS cluster

2026-09-27 03:05:13 +00:00

mcp_ci_job_test.go

chore(distributed): stop telling an operator to run a NATS cluster

2026-09-27 03:05:13 +00:00

model_config_revision_test.go

feat(distributed): stop workers listening, and stop them advertising

2026-09-27 03:05:12 +00:00

model_routing_test.go

chore(distributed): take the nats-io modules out of the build

2026-09-27 03:05:13 +00:00

node_lifecycle_test.go

feat(distributed): stop a backend on one route, whatever the worker is

2026-09-27 03:05:12 +00:00

node_registration_test.go

fix(distributed): exclude pinned models from cluster eviction and idle scale-down

2026-09-11 23:08:26 +00:00

object_storage_test.go

feat: add distributed mode (#9124)

2026-03-30 00:47:27 +02:00

phase4_test.go

feat(distributed): give responses.metadata something to re-hydrate from

2026-09-27 03:05:12 +00:00

prefix_cache_routing_test.go

test(distributed): name the replica endpoint the router now requires

2026-09-27 03:05:12 +00:00

registry_extra_test.go

fix(distributed): keep model replicas config-consistent (#11664)

2026-08-22 22:44:03 +02:00

router_tracking_test.go

feat(distributed): stop a backend on one route, whatever the worker is

2026-09-27 03:05:12 +00:00

skills_distributed_test.go

chore(distributed): take the nats-io modules out of the build

2026-09-27 03:05:13 +00:00

sse_routes_test.go

chore(distributed): take the nats-io modules out of the build

2026-09-27 03:05:13 +00:00

syncstate_distributed_test.go

feat(distributed): carry the state.*.delta families on PostgreSQL

2026-09-27 03:05:12 +00:00

testhelpers_test.go

chore(distributed): take the nats-io modules out of the build

2026-09-27 03:05:13 +00:00

vllm_multinode_test.go

feat(vllm, distributed): tensor parallel distributed workers (#9612)

2026-05-06 00:22:50 +02:00