aboutsummaryrefslogtreecommitdiff
path: root/weed/pb/mq.proto
AgeCommit message (Expand)AuthorFilesLines
2025-01-20Add message queue agent (#6463)Chris Lu1-316/+0
2024-05-29passing along publisher namechrislu1-1/+1
2024-05-27balance subscriberschrislu1-1/+5
2024-05-23coordinator receives unassignment ackchrislu1-0/+4
2024-05-21refactorchrislu1-2/+5
2024-05-20unusedchrislu1-5/+0
2024-05-20track offsetchrislu1-0/+2
2024-05-19start consuming ASAPchrislu1-0/+9
2024-05-19persist consumer group offsetchrislu1-3/+5
2024-05-17add subscribe followerchrislu1-1/+22
2024-05-13consumer instance passing MaxPartitionCount to coordinatorchrislu1-0/+1
2024-04-12add proto for valuechrislu1-0/+4
2024-03-31add control message to data messagechrislu1-3/+6
2024-03-31send is_close message to brokerchrislu1-0/+1
2024-03-31add publisher name for debuggingchrislu1-0/+1
2024-03-27simplifychrislu1-2/+2
2024-03-24setup follower by publisherchrislu1-6/+2
2024-03-20publisher is able to fully send data and receive ackschrislu1-5/+17
2024-03-17remove FollowInMemoryMessageschrislu1-28/+0
2024-03-10ask follower to followchrislu1-0/+39
2024-02-29publish init add followerschrislu1-0/+1
2024-01-16remove isForPublish from LookupTopicBrokerschrislu1-1/+0
2024-01-08add batch index for each memory bufferchrislu1-1/+9
2024-01-05subscribe with partition offsetchrislu1-6/+2
2024-01-05rename functionschrislu1-6/+6
2024-01-05add offsetchrislu1-0/+10
2023-12-28subscriber can get assignmentschrislu1-0/+1
2023-12-28subscriber keep connected to the balancerchrislu1-1/+1
2023-12-11Merge accumulated changes related to message queue (#5098)Chris Lu1-82/+66
2023-10-12Revert "rename"chrislu1-3/+3
2023-10-11renamechrislu1-3/+3
2023-09-30adjust mq.protochrislu1-9/+6
2023-09-30adjust mq protochrislu1-10/+17
2023-09-26rename functionchrislu1-6/+6
2023-09-24create topic and report topicorigin/subchrislu1-0/+7
2023-09-24do create topicchrislu1-0/+8
2023-09-24add CreateTopic APIchrislu1-0/+9
2023-09-19wipchrislu1-3/+10
2023-09-16balancer workschrislu1-4/+2
2023-09-14receive broker statschrislu1-0/+23
2023-09-06ack intervalchrislu1-0/+1
2023-09-04api for subchrislu1-0/+2
2023-09-01can pub and subchrislu1-3/+11
2023-08-27rename to lookupchrislu1-17/+12
2023-08-27pub sub initial testschrislu1-1/+1
2023-08-27subchrislu1-6/+3
2023-08-26adjust protochrislu1-5/+29
2023-08-20Squashed commit of the following:chrislu1-3/+71
2022-07-31scaffoldchrislu1-0/+17
2022-07-29move to https://github.com/seaweedfs/seaweedfschrislu1-1/+1