| 67 | } |
| 68 | |
| 69 | func (c *agentClient) Run(jobType livekit.JobType, namespace string) (err error) { |
| 70 | go c.read() |
| 71 | |
| 72 | switch jobType { |
| 73 | case livekit.JobType_JT_ROOM: |
| 74 | err = c.write(&livekit.WorkerMessage{ |
| 75 | Message: &livekit.WorkerMessage_Register{ |
| 76 | Register: &livekit.RegisterWorkerRequest{ |
| 77 | Type: livekit.JobType_JT_ROOM, |
| 78 | Version: "version", |
| 79 | Namespace: &namespace, |
| 80 | }, |
| 81 | }, |
| 82 | }) |
| 83 | |
| 84 | case livekit.JobType_JT_PUBLISHER: |
| 85 | err = c.write(&livekit.WorkerMessage{ |
| 86 | Message: &livekit.WorkerMessage_Register{ |
| 87 | Register: &livekit.RegisterWorkerRequest{ |
| 88 | Type: livekit.JobType_JT_PUBLISHER, |
| 89 | Version: "version", |
| 90 | Namespace: &namespace, |
| 91 | }, |
| 92 | }, |
| 93 | }) |
| 94 | |
| 95 | case livekit.JobType_JT_PARTICIPANT: |
| 96 | err = c.write(&livekit.WorkerMessage{ |
| 97 | Message: &livekit.WorkerMessage_Register{ |
| 98 | Register: &livekit.RegisterWorkerRequest{ |
| 99 | Type: livekit.JobType_JT_PARTICIPANT, |
| 100 | Version: "version", |
| 101 | Namespace: &namespace, |
| 102 | }, |
| 103 | }, |
| 104 | }) |
| 105 | } |
| 106 | |
| 107 | return err |
| 108 | } |
| 109 | |
| 110 | func (c *agentClient) read() { |
| 111 | for { |