4 people 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 <[email protected]>

* 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 <[email protected]>
Co-authored-by: David Colburn <[email protected]>

2024-04-03 15:25:42 -07:00

..

timeout.go

agent service: new protocol & namespaces (#2545)

2024-04-03 15:25:42 -07:00