agent-dispatch-queue: public queued-job RPCs and messages

.changeset/agent-dispatch-queue-api.md

@@ -0,0 +1,6 @@
+---
+"github.com/livekit/protocol": patch
+"@livekit/protocol": patch
+---
+
+Add the `AgentDispatchQueue` service with `QueuedJob` / `QueuedJobInput` / `QueuedJobStatus`, job group messages, `DispatchQueueConfig` / `DispatchLimit` / `DispatchLimitScope`, and an `AgentGrant.DispatchAdmin` grant

auth/grants.go

@@ -583,6 +583,8 @@ type AgentGrant struct {
 	SimulationAdmin bool `json:"simulationAdmin,omitempty"`
 	// DatabaseAdmin grants access to a project's agent databases (AgentDB).
 	DatabaseAdmin bool `json:"databaseAdmin,omitempty"`
+	// DispatchAdmin grants access to manage the project's outbound agent dispatch queue.
+	DispatchAdmin bool `json:"dispatchAdmin,omitempty"`
 }
 
 func (s *AgentGrant) Clone() *AgentGrant {
@@ -603,6 +605,7 @@ func (s *AgentGrant) MarshalLogObject(e zapcore.ObjectEncoder) error {
 	e.AddBool("Admin", s.Admin)
 	e.AddBool("SimulationAdmin", s.SimulationAdmin)
 	e.AddBool("DatabaseAdmin", s.DatabaseAdmin)
+	e.AddBool("DispatchAdmin", s.DispatchAdmin)
 	return nil
 }
 

auth/grants_test.go

@@ -120,7 +120,8 @@ func TestGrants(t *testing.T) {
 
 	t.Run("clone with Agent", func(t *testing.T) {
 		agent := &AgentGrant{
-			Admin: true,
+			Admin:         true,
+			DispatchAdmin: true,
 		}
 		grants := &ClaimGrants{
 			Identity: "identity",