(req *livekit.JobAssignment)
| 136 | } |
| 137 | |
| 138 | func (c *agentClient) handleAssignment(req *livekit.JobAssignment) { |
| 139 | switch req.Job.Type { |
| 140 | case livekit.JobType_JT_ROOM: |
| 141 | c.roomJobs.Inc() |
| 142 | case livekit.JobType_JT_PUBLISHER: |
| 143 | c.publisherJobs.Inc() |
| 144 | case livekit.JobType_JT_PARTICIPANT: |
| 145 | c.participantJobs.Inc() |
| 146 | } |
| 147 | } |
| 148 | |
| 149 | func (c *agentClient) handleAvailability(req *livekit.AvailabilityRequest) { |
| 150 | switch req.Job.Type { |