Benjamin Pracht
0fd09d73c1
Instantiate default agent dispatches in rtc for better backward compatibility ( #2886 )
2024-07-22 08:44:13 -07:00
Benjamin Pracht
a877ba2352
Partial support for agent dispatch management ( #2872 )
...
- Store agent dispaches independently of room agents on rtc.Room
- Serialize agent dispatches in rtc.Room
- Support for agent dispatch and job serialization in redis
The agent Job object references denormalized Room and ParticipantInfo object. When storing Jobs, this sets the Room to nil, and only stores the Participant identity field. When read back, these fields need to be set to their current value.
2024-07-18 13:36:43 -07:00
Benjamin Pracht
a9aa65fdc6
Remove unused fields from RegisterWorkerRequest ( #2866 )
2024-07-15 15:22:20 -07:00
Benjamin Pracht
fb7eb3450e
Update agents service to updated protocol ( #2837 )
...
- Deprecate namespace field
- Restore former semantic of starting a job for each registered namespace, for a given Agent Name
- Add agentName field
- Use "dispatcher" naming convention
2024-07-08 17:09:11 -07:00
Paul Wells
e511464d3d
add handler interface to receive agent worker updates ( #2830 )
...
* add handler interface to receive agent worker updates
* cleanup
2024-07-02 13:11:08 -07:00
Benjamin Pracht
32a4d03c9e
Implement Agents protocol addition ( #2786 )
2024-06-27 19:20:52 -07:00
Paul Wells
f1886ece42
update protocol ( #2760 )
...
* update protocol
* deps
2024-06-05 19:46:34 -07:00
David Zhao
f4314686d1
Improve Agent logging ( #2628 )
2024-04-05 20:32:29 -07:00
Théo Monnom
dc67f505a5
agent service: new protocol & namespaces ( #2545 )
...
* initial worker impl
* fix test
* fix build
* TestAgentNamespaces
* log err
* nit cmt
* TestAgentMultiNode
* Update pkg/agent/worker.go
Co-authored-by: David Zhao <dz@livekit.io >
* retry on worker selection & fix review comments
* Update roommanager.go
* license
* use testutils.WIthTimeout
* abstract namespace/enabled logic into agent.Client, incrementally dispatch
* typos and dates
* lock
* timeout is now optional
* pass in topics instead of fixed
* handler handles connections
* onIdle, numConnections
* fix WithGrants
* update protocol
* check agent client
* broadcast after unlock
* fix data race
* remove ReadChan, fix dispatcher
---------
Co-authored-by: David Zhao <dz@livekit.io >
Co-authored-by: David Colburn <xero73@gmail.com >
2024-04-03 15:25:42 -07:00
