| Age | Commit message (Expand) | Author | Files | Lines |
|---|---|---|---|---|
| 2025-01-20 | Add message queue agent (#6463) | Chris Lu | 1 | -316/+0 |
| 2024-05-29 | passing along publisher name | chrislu | 1 | -1/+1 |
| 2024-05-27 | balance subscribers | chrislu | 1 | -1/+5 |
| 2024-05-23 | coordinator receives unassignment ack | chrislu | 1 | -0/+4 |
| 2024-05-21 | refactor | chrislu | 1 | -2/+5 |
| 2024-05-20 | unused | chrislu | 1 | -5/+0 |
| 2024-05-20 | track offset | chrislu | 1 | -0/+2 |
| 2024-05-19 | start consuming ASAP | chrislu | 1 | -0/+9 |
| 2024-05-19 | persist consumer group offset | chrislu | 1 | -3/+5 |
| 2024-05-17 | add subscribe follower | chrislu | 1 | -1/+22 |
| 2024-05-13 | consumer instance passing MaxPartitionCount to coordinator | chrislu | 1 | -0/+1 |
| 2024-04-12 | add proto for value | chrislu | 1 | -0/+4 |
| 2024-03-31 | add control message to data message | chrislu | 1 | -3/+6 |
| 2024-03-31 | send is_close message to broker | chrislu | 1 | -0/+1 |
| 2024-03-31 | add publisher name for debugging | chrislu | 1 | -0/+1 |
| 2024-03-27 | simplify | chrislu | 1 | -2/+2 |
| 2024-03-24 | setup follower by publisher | chrislu | 1 | -6/+2 |
| 2024-03-20 | publisher is able to fully send data and receive acks | chrislu | 1 | -5/+17 |
| 2024-03-17 | remove FollowInMemoryMessages | chrislu | 1 | -28/+0 |
| 2024-03-10 | ask follower to follow | chrislu | 1 | -0/+39 |
| 2024-02-29 | publish init add followers | chrislu | 1 | -0/+1 |
| 2024-01-16 | remove isForPublish from LookupTopicBrokers | chrislu | 1 | -1/+0 |
| 2024-01-08 | add batch index for each memory buffer | chrislu | 1 | -1/+9 |
| 2024-01-05 | subscribe with partition offset | chrislu | 1 | -6/+2 |
| 2024-01-05 | rename functions | chrislu | 1 | -6/+6 |
| 2024-01-05 | add offset | chrislu | 1 | -0/+10 |
| 2023-12-28 | subscriber can get assignments | chrislu | 1 | -0/+1 |
| 2023-12-28 | subscriber keep connected to the balancer | chrislu | 1 | -1/+1 |
| 2023-12-11 | Merge accumulated changes related to message queue (#5098) | Chris Lu | 1 | -82/+66 |
| 2023-10-12 | Revert "rename" | chrislu | 1 | -3/+3 |
| 2023-10-11 | rename | chrislu | 1 | -3/+3 |
| 2023-09-30 | adjust mq.proto | chrislu | 1 | -9/+6 |
| 2023-09-30 | adjust mq proto | chrislu | 1 | -10/+17 |
| 2023-09-26 | rename function | chrislu | 1 | -6/+6 |
| 2023-09-24 | create topic and report topicorigin/sub | chrislu | 1 | -0/+7 |
| 2023-09-24 | do create topic | chrislu | 1 | -0/+8 |
| 2023-09-24 | add CreateTopic API | chrislu | 1 | -0/+9 |
| 2023-09-19 | wip | chrislu | 1 | -3/+10 |
| 2023-09-16 | balancer works | chrislu | 1 | -4/+2 |
| 2023-09-14 | receive broker stats | chrislu | 1 | -0/+23 |
| 2023-09-06 | ack interval | chrislu | 1 | -0/+1 |
| 2023-09-04 | api for sub | chrislu | 1 | -0/+2 |
| 2023-09-01 | can pub and sub | chrislu | 1 | -3/+11 |
| 2023-08-27 | rename to lookup | chrislu | 1 | -17/+12 |
| 2023-08-27 | pub sub initial tests | chrislu | 1 | -1/+1 |
| 2023-08-27 | sub | chrislu | 1 | -6/+3 |
| 2023-08-26 | adjust proto | chrislu | 1 | -5/+29 |
| 2023-08-20 | Squashed commit of the following: | chrislu | 1 | -3/+71 |
| 2022-07-31 | scaffold | chrislu | 1 | -0/+17 |
| 2022-07-29 | move to https://github.com/seaweedfs/seaweedfs | chrislu | 1 | -1/+1 |
