aboutsummaryrefslogtreecommitdiff
path: root/weed/mq/client/sub_client/subscribe.go
AgeCommit message (Expand)AuthorFilesLines
2025-05-22WIPorigin/changing-to-zapchrislu1-5/+5
2025-03-09Accumulated changes for message queue (#6600)Chris Lu1-6/+6
2025-01-20Add message queue agent (#6463)Chris Lu1-1/+17
2024-05-27balance subscriberschrislu1-0/+7
2024-05-23coordinator receives unassignment ackchrislu1-0/+7
2024-05-21client side stop partition subscribing if unassignedchrislu1-3/+13
2024-05-21refactorchrislu1-30/+35
2024-05-20remove ProcessorConfigurationchrislu1-1/+1
2024-05-20go fmtchrislu1-1/+0
2024-05-20track offsetchrislu1-1/+1
2024-05-16consumer acks received messageschrislu1-1/+6
2024-05-14subscriber receives partitions and dispatch to processorschrislu1-0/+77
2023-12-31clean up dead codechrislu1-42/+0
2023-12-28subscriber keep connected to the balancerchrislu1-0/+5
2023-12-11Merge accumulated changes related to message queue (#5098)Chris Lu1-1/+16
2023-10-02add subscriber coordinatorchrislu1-0/+5
2023-10-01refactorchrislu1-58/+14
2023-09-30adjust mq.protochrislu1-14/+14
2023-09-04api for subchrislu1-11/+12
2023-09-01can pub and subchrislu1-19/+62
2023-08-28connect and publishchrislu1-0/+28