| Age | Commit message (Expand) | Author | Files | Lines |
|---|---|---|---|---|
| 2025-01-20 | Add message queue agent (#6463) | Chris Lu | 6 | -15/+20 |
| 2024-12-19 | "golang.org/x/exp/slices" => "slices" and go fmt | chrislu | 1 | -12/+12 |
| 2024-11-04 | merge current message queue code changes (#6201) | Chris Lu | 1 | -2/+2 |
| 2024-08-12 | fix tests | chrislu | 1 | -52/+6 |
| 2024-05-27 | balance subscribers | chrislu | 1 | -4/+0 |
| 2024-05-21 | rename | chrislu | 1 | -1/+1 |
| 2024-05-21 | rename file | chrislu | 1 | -0/+0 |
| 2024-05-21 | rename Balancer to PubBalancer | chrislu | 5 | -16/+16 |
| 2024-05-20 | Merge branch 'master' into mq | chrislu | 1 | -3/+3 |
| 2024-05-20 | go fmt | chrislu | 1 | -3/+3 |
| 2024-05-19 | persist consumer group offset | chrislu | 3 | -56/+24 |
| 2024-04-28 | fix test | chrislu | 2 | -3/+0 |
| 2024-03-27 | simplify | chrislu | 3 | -26/+17 |
| 2024-03-16 | fix test | chrislu | 1 | -1/+0 |
| 2024-03-16 | go fmt | chrislu | 2 | -23/+23 |
| 2024-03-07 | edge cases for broker assignment | chrislu | 2 | -9/+23 |
| 2024-03-01 | handle single broker case | chrislu | 2 | -2/+37 |
| 2024-02-29 | test low active brokers | chrislu | 2 | -1/+24 |
| 2024-02-29 | assign followers | chrislu | 2 | -22/+211 |
| 2024-02-29 | go fmt | chrislu | 2 | -9/+9 |
| 2024-02-04 | fix divide by zero | Chris Lu | 1 | -7/+11 |
| 2024-01-22 | updated and added assignments | chrislu | 1 | -6/+11 |
| 2024-01-22 | add/remove assigned partitions | chrislu | 1 | -2/+6 |
| 2024-01-21 | fix assignments if brokers changed | chrislu | 1 | -0/+20 |
| 2024-01-21 | refactor | chrislu | 2 | -3/+12 |
| 2024-01-20 | refactor | chrislu | 1 | -0/+10 |
| 2024-01-20 | refactor | chrislu | 1 | -2/+6 |
| 2024-01-16 | simplify to LookupTopicPartitions(topic) | chrislu | 1 | -25/+1 |
| 2024-01-16 | simplify api | chrislu | 1 | -2/+5 |
| 2024-01-16 | remove isForPublish from LookupTopicBrokers | chrislu | 1 | -3/+3 |
| 2024-01-16 | rename | chrislu | 1 | -1/+1 |
| 2024-01-16 | rename | chrislu | 2 | -2/+2 |
| 2024-01-10 | passing partition generation timestamp | chrislu | 4 | -3/+20 |
| 2024-01-03 | subscriber can be notified of the assignment change when topic is just config... | chrislu | 2 | -2/+5 |
| 2024-01-02 | lookup existing topic partitions | chrislu | 1 | -3/+2 |
| 2023-12-28 | subscriber can get assignments | chrislu | 1 | -4/+5 |
| 2023-12-22 | go fmt | chrislu | 2 | -6/+7 |
| 2023-12-11 | fix test | chrislu | 1 | -3/+9 |
| 2023-12-11 | Merge accumulated changes related to message queue (#5098) | Chris Lu | 13 | -0/+898 |
