mirrors/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2026-09-12 02:56:10 +00:00
Code Issues Packages Projects Releases Wiki Activity
Files
e8d8bfccccc666bbef4f1019f880e9aed5aea668
seaweedfs/weed/mq/client/sub_client
T
History
Chris LuandGitHub cc05874d06 Add message queue agent (#6463) 
* scaffold message queue agent

* adjust proto, add mq_agent

* add agent client implementation

* remove unused function

* agent publish server implementation

* adding agent
2025-01-20 22:19:27 -08:00
..
connect_to_sub_coordinator.go
balance subscribers
2024-05-27 17:30:16 -07:00
on_each_partition.go
Add message queue agent (#6463)
2025-01-20 22:19:27 -08:00
subscribe.go
Add message queue agent (#6463)
2025-01-20 22:19:27 -08:00
subscriber.go
Add message queue agent (#6463)
2025-01-20 22:19:27 -08:00