Repository navigation

feat(rl): control endpoints for gRPC and ZMQ workers - #2667

Open

key4ng wants to merge 24 commits into

rl/ts-1-weight-version-provenancefrom

rl/ts-2-control-endpoint

Commits on Oct 6, 2026

feat(rl): model a worker's control endpoint separately from its data transport
key4ng
committed
74288b7
feat(rl): proxy control calls to the worker's control endpoint regardless of data transport
key4ng
committed
db0db0b
feat(rl): resolve control endpoints for gRPC and ZMQ workers from the rl.control_url label
key4ng
committed
58cc3b9
feat(rl): report control_url in discovery, add the TokenSpeed capability row, expose control_url in the Python client
key4ng
committed
0b625a6
test(mock_worker): advertise custom server_args and stamp a weight version on gRPC generates
key4ng
committed
848bad9
chore(mock_worker): record the prost-types dependency in Cargo.lock
key4ng
committed
071f209
test(rl): drive a TokenSpeed gRPC worker through /v1/rl via its control endpoint
key4ng
committed
a1c76a2
feat(serve): wire the TokenSpeed control app for ZMQ workers and stamp rl.control_url when RL is on
key4ng
committed
3bc1d46
docs(rl): control endpoints, TokenSpeed drift rows, and the TokenSpeed launch guide
key4ng
committed
835121c
fix(rl): treat a blank rl.control_url label as absent; document base_url
key4ng
committed
64a3ccb
fix(serve): stop retrying 4xx when stamping rl.control_url; require zmq
key4ng
committed
3adfb58
docs(rl): HTTP workers ignore rl.control_url; narrow recorder doc
key4ng
committed
54a9943
style(rl): drop redundant serde_json qualifications in the discovery tests
key4ng
committed
5378dbf
fix(rl): TokenSpeed refits are distributed-only; drop disk from the static row and docs
key4ng
committed
a74b03b
fix(rl): fall back to attn_tp_size when an engine reports no tp_size
key4ng
committed
229f15b
docs(rl): list the gateway-side files that carry RL data and name both refused refit routes
key4ng
committed
8a64238
test(mock_worker): set the new mock fields in the context-length test that landed on main
key4ng
committed
17e09d9
style(rl): apply rustfmt to the control-endpoint resolver
key4ng
committed
be7ee23
fix(rl): hold control clients strongly and carry a client build failure into the 422
key4ng
committed
54b96dc
test(rl): register the TokenSpeed mock through POST /workers; a fan-out over endpoints hits each worker once
key4ng
committed
cabc212
fix(serve): wire no RL control endpoint for ZMQ TokenSpeed workers
key4ng
committed
63a506d
docs(rl): launch recipe that works against the merged engine
key4ng
committed
f81491c
test(rl): make the failed-client-build case fail the build for real
key4ng
committed
9ae9aa7
style(rl): build the test's RouterConfig with struct-update syntax
key4ng
committed
5f12276

Navigation Menu

Repository navigation

feat(rl): control endpoints for gRPC and ZMQ workers - #2667

feat(rl): control endpoints for gRPC and ZMQ workers#2667
key4ng wants to merge 24 commits into
rl/ts-1-weight-version-provenancefrom
rl/ts-2-control-endpoint

Commits on Oct 6, 2026

feat(rl): model a worker's control endpoint separately from its data transport

feat(rl): proxy control calls to the worker's control endpoint regardless of data transport

feat(rl): resolve control endpoints for gRPC and ZMQ workers from the rl.control_url label

feat(rl): report control_url in discovery, add the TokenSpeed capability row, expose control_url in the Python client

test(mock_worker): advertise custom server_args and stamp a weight version on gRPC generates

chore(mock_worker): record the prost-types dependency in Cargo.lock

test(rl): drive a TokenSpeed gRPC worker through /v1/rl via its control endpoint

feat(serve): wire the TokenSpeed control app for ZMQ workers and stamp rl.control_url when RL is on

docs(rl): control endpoints, TokenSpeed drift rows, and the TokenSpeed launch guide

fix(rl): treat a blank rl.control_url label as absent; document base_url

fix(serve): stop retrying 4xx when stamping rl.control_url; require zmq

docs(rl): HTTP workers ignore rl.control_url; narrow recorder doc

style(rl): drop redundant serde_json qualifications in the discovery tests

fix(rl): TokenSpeed refits are distributed-only; drop disk from the static row and docs

fix(rl): fall back to attn_tp_size when an engine reports no tp_size

docs(rl): list the gateway-side files that carry RL data and name both refused refit routes

test(mock_worker): set the new mock fields in the context-length test that landed on main

style(rl): apply rustfmt to the control-endpoint resolver

fix(rl): hold control clients strongly and carry a client build failure into the 422

test(rl): register the TokenSpeed mock through POST /workers; a fan-out over endpoints hits each worker once

fix(serve): wire no RL control endpoint for ZMQ TokenSpeed workers

docs(rl): launch recipe that works against the merged engine

test(rl): make the failed-client-build case fail the build for real

style(rl): build the test's RouterConfig with struct-update syntax