Add AgentDispatchQueue service (outbound dispatch queueing)#1660
Add AgentDispatchQueue service (outbound dispatch queueing)#1660erikhortsch wants to merge 2 commits into
Conversation
Adds a new public twirp service, QueuedJob/DispatchQueueConfig messages, and an Agent.DispatchAdmin grant, following the AgentSimulation precedent (dedicated service served by cloud-api-server, not routed through the room-keyed AgentDispatchService). Part of the Agent Dispatch Queueing project.
|
|
|
Summary
AgentDispatchQueue(livekit_agent_dispatch_queue.proto) withAddJobs,RemoveJob,GetJob,ListJobs,RetryJobs,GetDispatchQueueConfig,UpdateDispatchQueueConfig.QueuedJob/QueuedJob.Input/DispatchQueueConfigmessages. Per-job webhooks reuse the existingWebhookConfig(same pattern as Egress per-request webhooks).AgentGrant.DispatchAdminfor authorizing the new RPCs.Follows the
AgentSimulationprecedent: a dedicated service intended to be served directly by cloud-api-server (see stacked PRs in cloud-protocol / agents-private / cloud-api-server), rather than routed through the room-keyedAgentDispatchServiceused for just-in-time dispatch.Part of the Agent Dispatch Queueing project. Design doc: Agent Dispatch Queueing Service — Design Doc (Notion).
Stack
AgentDispatchQueueInternal)SimulationService)Test plan
go build ./...go test ./auth/... ./livekit/...go get github.com/livekit/protocol@erikhortsch/agent-dispatch-queue-api)🤖 Generated with Claude Code