| Age | Commit message (Expand) | Author | Files | Lines |
|---|---|---|---|---|
| 2025-11-18 | S3: Directly read write volume servers (#7481) | Chris Lu | 2 | -5/+24 |
| 2025-10-17 | Fixes for kafka gateway (#7329) | Chris Lu | 2 | -2/+114 |
| 2025-10-13 | Add Kafka Gateway (#7231) | Chris Lu | 6 | -12/+835 |
| 2025-09-09 | Message Queue: Add sql querying (#7185) | Chris Lu | 3 | -4/+71 |
| 2025-07-16 | convert error fromating to %w everywhere (#6995) | Chris Lu | 2 | -6/+6 |
| 2025-07-11 | Admin UI: Add message queue to admin UI (#6958) | Chris Lu | 3 | -5/+170 |
| 2025-03-09 | Accumulated changes for message queue (#6600) | Chris Lu | 1 | -2/+6 |
| 2025-01-20 | Add message queue agent (#6463) | Chris Lu | 3 | -8/+10 |
| 2024-12-19 | "golang.org/x/exp/slices" => "slices" and go fmt | chrislu | 1 | -1/+1 |
| 2024-11-04 | merge current message queue code changes (#6201) | Chris Lu | 5 | -9/+58 |
| 2024-10-03 | add helper functions | chrislu | 1 | -1/+12 |
| 2024-08-11 | adds locking | chrislu | 2 | -4/+15 |
| 2024-08-10 | refactor | chrislu | 2 | -4/+7 |
| 2024-05-20 | Merge branch 'master' into mq | chrislu | 1 | -8/+8 |
| 2024-05-20 | go fmt | chrislu | 1 | -8/+8 |
| 2024-05-19 | persist consumer group offset | chrislu | 2 | -12/+13 |
| 2024-05-17 | rename | chrislu | 1 | -12/+12 |
| 2024-05-14 | subscriber receives partitions and dispatch to processors | chrislu | 1 | -0/+10 |
| 2024-04-02 | refactor | chrislu | 1 | -1/+1 |
| 2024-04-02 | comment out println | chrislu | 1 | -4/+4 |
| 2024-04-01 | send flush message to follower before shutting down logBuffer | chrislu | 1 | -1/+19 |
| 2024-04-01 | renaming | chrislu | 1 | -5/+5 |
| 2024-03-31 | purge old code | chrislu | 1 | -2/+0 |
| 2024-03-31 | shutdown follower if no clients, not only publishers | chrislu | 1 | -3/+1 |
| 2024-03-31 | add publisher name for debugging | chrislu | 1 | -1/+8 |
| 2024-03-30 | simplify | chrislu | 3 | -17/+4 |
| 2024-03-30 | logs | chrislu | 1 | -0/+1 |
| 2024-03-27 | LocalPartition shutdown | chrislu | 1 | -18/+18 |
| 2024-03-27 | simplify | chrislu | 2 | -17/+4 |
| 2024-03-27 | change visibility | chrislu | 1 | -14/+14 |
| 2024-03-27 | publish and send to follower | chrislu | 1 | -4/+21 |
| 2024-03-27 | MaybeShutdownLocalPartition refactor | chrislu | 1 | -19/+19 |
| 2024-03-27 | fix | chrislu | 1 | -1/+1 |
| 2024-03-27 | refactor | chrislu | 1 | -0/+50 |
| 2024-03-27 | refactor | chrislu | 1 | -0/+18 |
| 2024-03-27 | separate goroutine to send ack to publisher | chrislu | 1 | -0/+1 |
| 2024-03-26 | rename | chrislu | 1 | -2/+2 |
| 2024-03-24 | setup follower by publisher | chrislu | 1 | -0/+4 |
| 2024-03-17 | logging | chrislu | 1 | -0/+1 |
| 2024-03-16 | notify | chrislu | 1 | -3/+16 |
| 2024-03-16 | go fmt | chrislu | 1 | -7/+7 |
| 2024-03-15 | add size() | chrislu | 2 | -0/+14 |
| 2024-03-10 | ask follower to follow | chrislu | 2 | -6/+13 |
| 2024-03-07 | change LogBuffer visibility in LocalPartition | chrislu | 1 | -9/+9 |
| 2024-02-29 | go fmt | chrislu | 2 | -2/+3 |
| 2024-01-16 | passing partition info | chrislu | 1 | -10/+2 |
| 2024-01-16 | release local topic partition if no publisher and subscribers | chrislu | 2 | -0/+15 |
| 2024-01-15 | reuse local partition | chrislu | 1 | -2/+2 |
| 2024-01-15 | read from disk if not in memory | chrislu | 1 | -16/+38 |
| 2024-01-11 | lint | chrislu | 1 | -1/+1 |
