| 147 | } |
| 148 | |
| 149 | func (c *agentClient) handleAvailability(req *livekit.AvailabilityRequest) { |
| 150 | switch req.Job.Type { |
| 151 | case livekit.JobType_JT_ROOM: |
| 152 | c.roomAvailability.Inc() |
| 153 | case livekit.JobType_JT_PUBLISHER: |
| 154 | c.publisherAvailability.Inc() |
| 155 | case livekit.JobType_JT_PARTICIPANT: |
| 156 | c.participantAvailability.Inc() |
| 157 | } |
| 158 | |
| 159 | c.requestedJobs <- req.Job |
| 160 | |
| 161 | c.write(&livekit.WorkerMessage{ |
| 162 | Message: &livekit.WorkerMessage_Availability{ |
| 163 | Availability: &livekit.AvailabilityResponse{ |
| 164 | JobId: req.Job.Id, |
| 165 | Available: true, |
| 166 | }, |
| 167 | }, |
| 168 | }) |
| 169 | } |
| 170 | |
| 171 | func (c *agentClient) handleRegister(req *livekit.RegisterWorkerResponse) { |
| 172 | c.registered.Inc() |