| Age | Commit message (Expand) | Author | Files | Lines |
|---|---|---|---|---|
| 2025-06-25 | fix error logging to reduce noise | chrislu | 1 | -4/+48 |
| 2025-03-09 | Accumulated changes for message queue (#6600) | Chris Lu | 1 | -2/+6 |
| 2024-11-04 | merge current message queue code changes (#6201) | Chris Lu | 1 | -0/+1 |
| 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 | 1 | -12/+12 |
| 2024-05-17 | rename | chrislu | 1 | -12/+12 |
| 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-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 | 1 | -3/+4 |
| 2024-03-30 | logs | chrislu | 1 | -0/+1 |
| 2024-03-27 | LocalPartition shutdown | chrislu | 1 | -18/+18 |
| 2024-03-27 | simplify | chrislu | 1 | -15/+1 |
| 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-10 | ask follower to follow | chrislu | 1 | -6/+12 |
| 2024-03-07 | change LogBuffer visibility in LocalPartition | chrislu | 1 | -9/+9 |
| 2024-02-29 | go fmt | chrislu | 1 | -0/+1 |
| 2024-01-16 | release local topic partition if no publisher and subscribers | chrislu | 1 | -0/+8 |
| 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-10 | passing partition generation timestamp | chrislu | 1 | -1/+1 |
| 2024-01-08 | flush to disk | chrislu | 1 | -6/+5 |
| 2024-01-08 | add batch index for each memory buffer | chrislu | 1 | -2/+14 |
| 2023-12-11 | Merge accumulated changes related to message queue (#5098) | Chris Lu | 1 | -23/+36 |
| 2023-09-16 | balancer works | chrislu | 1 | -0/+1 |
| 2023-08-28 | connect and publish | chrislu | 1 | -0/+19 |
| 2023-08-27 | rename to lookup | chrislu | 1 | -7/+3 |
| 2023-08-27 | sub | chrislu | 1 | -0/+9 |
| 2023-08-26 | adjust proto | chrislu | 1 | -1/+1 |
| 2023-08-20 | Squashed commit of the following: | chrislu | 1 | -0/+40 |
 |
index : seaweedfs/.git | |
| Unnamed repository; edit this file 'description' to name the repository. | root |
| aboutsummaryrefslogtreecommitdiff |