| Age | Commit message (Expand) | Author | Files | Lines |
|---|---|---|---|---|
| 2024-03-24 | setup follower by publisher | chrislu | 1 | -10/+11 |
| 2024-03-21 | correctly wait for the publisher to finish | chrislu | 1 | -7/+16 |
| 2024-03-20 | publisher is able to fully send data and receive acks | chrislu | 2 | -6/+14 |
| 2024-03-07 | adjust error | chrislu | 1 | -1/+1 |
| 2024-02-29 | publish init add followers | chrislu | 1 | -3/+4 |
| 2024-02-29 | go fmt | chrislu | 3 | -4/+3 |
| 2024-02-05 | subscriber find broker leader first | Chris Lu | 3 | -28/+37 |
| 2024-02-05 | report EOF error | Chris Lu | 1 | -2/+2 |
| 2024-02-05 | minor | Chris Lu | 1 | -2/+2 |
| 2024-02-05 | proxy requests to lock owner | Chris Lu | 1 | -13/+14 |
| 2024-01-28 | wait 3 seconds before shutting down publish client, to wait for all messages ... | chrislu | 1 | -1/+20 |
| 2024-01-28 | unused code | chrislu | 1 | -71/+0 |
| 2024-01-28 | wait for each publish clients | chrislu | 1 | -2/+4 |
| 2024-01-28 | read will block if no items | chrislu | 1 | -1/+1 |
| 2024-01-28 | adjust visibility | chrislu | 2 | -2/+2 |
| 2024-01-28 | refactor | chrislu | 3 | -22/+28 |
| 2024-01-28 | refactor | chrislu | 4 | -31/+19 |
| 2024-01-28 | wait for publishing clients | chrislu | 2 | -5/+16 |
| 2024-01-28 | clean up | chrislu | 1 | -9/+0 |
| 2024-01-27 | publish to input buffer | chrislu | 5 | -132/+99 |
| 2024-01-26 | schedule jobs | chrislu | 2 | -0/+182 |
| 2024-01-16 | remove isForPublish from LookupTopicBrokers | chrislu | 1 | -2/+0 |
| 2024-01-15 | adjust publisher subscriber | chrislu | 2 | -6/+10 |
| 2024-01-15 | fix publisher | chrislu | 2 | -2/+5 |
| 2024-01-11 | adjust client side logs | chrislu | 1 | -10/+7 |
| 2024-01-10 | passing partition generation timestamp | chrislu | 2 | -0/+5 |
| 2024-01-08 | add batch index for each memory buffer | chrislu | 2 | -3/+7 |
| 2024-01-05 | rename functions | chrislu | 2 | -3/+3 |
| 2024-01-05 | adjust logs | chrislu | 1 | -2/+2 |
| 2024-01-05 | refactor | chrislu | 1 | -7/+8 |
| 2024-01-05 | rename functions | chrislu | 1 | -2/+2 |
| 2024-01-05 | rename functions | chrislu | 1 | -3/+3 |
| 2024-01-05 | rename functions | chrislu | 2 | -4/+5 |
| 2024-01-05 | rename functions | chrislu | 2 | -6/+6 |
| 2024-01-03 | subscription start from specified timestamp | chrislu | 1 | -1/+1 |
| 2024-01-03 | subscriber can be notified of the assignment change when topic is just config... | chrislu | 2 | -4/+4 |
| 2024-01-01 | log errors | chrislu | 1 | -3/+6 |
| 2023-12-31 | adjust wait time | chrislu | 1 | -5/+10 |
| 2023-12-31 | clean up dead code | chrislu | 6 | -164/+77 |
| 2023-12-28 | passing broker into the assignments | chrislu | 1 | -2/+1 |
| 2023-12-28 | subscriber can get assignments | chrislu | 1 | -7/+7 |
| 2023-12-28 | subscriber keep connected to the balancer | chrislu | 5 | -12/+118 |
| 2023-12-11 | Merge accumulated changes related to message queue (#5098) | Chris Lu | 9 | -97/+195 |
| 2023-10-02 | add subscriber coordinator | chrislu | 2 | -5/+12 |
| 2023-10-01 | refactor | chrislu | 4 | -71/+99 |
| 2023-09-30 | adjust mq.proto | chrislu | 1 | -14/+14 |
| 2023-09-19 | fix compilation | chrislu | 2 | -4/+4 |
| 2023-09-07 | add publisher shutdown | chrislu | 3 | -0/+21 |
| 2023-09-06 | ack interval 128 | chrislu | 1 | -0/+1 |
| 2023-09-04 | api for sub | chrislu | 4 | -36/+68 |
 |
index : seaweedfs/.git | |
| Unnamed repository; edit this file 'description' to name the repository. | root |
| aboutsummaryrefslogtreecommitdiff |