| Age | Commit message (Expand) | Author | Files | Lines |
|---|---|---|---|---|
| 2025-07-16 | convert error fromating to %w everywhere (#6995) | Chris Lu | 1 | -2/+2 |
| 2025-03-09 | Accumulated changes for message queue (#6600) | Chris Lu | 4 | -28/+61 |
| 2025-01-20 | Add message queue agent (#6463) | Chris Lu | 3 | -55/+68 |
| 2024-11-04 | merge current message queue code changes (#6201) | Chris Lu | 2 | -0/+13 |
| 2024-08-12 | fix build | chrislu | 1 | -1/+1 |
| 2024-05-30 | fix | chrislu | 1 | -1/+0 |
| 2024-05-30 | stop partitionOffsetChan if closed | chrislu | 1 | -0/+5 |
| 2024-05-29 | skip control messages | chrislu | 1 | -0/+4 |
| 2024-05-27 | balance subscribers | chrislu | 3 | -2/+10 |
| 2024-05-23 | go fmt | chrislu | 2 | -8/+8 |
| 2024-05-23 | coordinator receives unassignment ack | chrislu | 3 | -15/+33 |
| 2024-05-21 | client side stop partition subscribing if unassigned | chrislu | 2 | -12/+27 |
| 2024-05-21 | fix compilation | chrislu | 1 | -7/+2 |
| 2024-05-21 | refactor | chrislu | 2 | -32/+37 |
| 2024-05-20 | refactor | chrislu | 2 | -104/+112 |
| 2024-05-20 | remove ProcessorConfiguration | chrislu | 3 | -11/+6 |
| 2024-05-20 | sending keyed offset | chrislu | 1 | -3/+12 |
| 2024-05-20 | minor | chrislu | 1 | -7/+7 |
| 2024-05-20 | go fmt | chrislu | 3 | -19/+18 |
| 2024-05-20 | track offset | chrislu | 3 | -4/+6 |
| 2024-05-19 | fix | chrislu | 1 | -1/+1 |
| 2024-05-19 | ConcurrentPartitionLimit | chrislu | 1 | -11/+19 |
| 2024-05-19 | start consuming ASAP | chrislu | 1 | -1/+1 |
| 2024-05-19 | persist consumer group offset | chrislu | 2 | -5/+1 |
| 2024-05-16 | consumer acks received messages | chrislu | 2 | -13/+32 |
| 2024-05-14 | subscriber receives partitions and dispatch to processors | chrislu | 3 | -36/+94 |
| 2024-05-13 | consumer instance passing MaxPartitionCount to coordinator | chrislu | 2 | -1/+2 |
| 2024-05-10 | clean up unused variables | chrislu | 1 | -3/+0 |
| 2024-03-24 | setup follower by publisher | chrislu | 1 | -10/+11 |
| 2024-02-05 | subscriber find broker leader first | Chris Lu | 2 | -25/+34 |
| 2024-01-11 | adjust client side logs | chrislu | 1 | -10/+7 |
| 2024-01-08 | add batch index for each memory buffer | chrislu | 1 | -1/+2 |
| 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 | 1 | -4/+4 |
| 2024-01-03 | subscriber can be notified of the assignment change when topic is just config... | chrislu | 1 | -2/+2 |
| 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 | 5 | -162/+75 |
| 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 | 4 | -7/+109 |
| 2023-12-11 | Merge accumulated changes related to message queue (#5098) | Chris Lu | 3 | -8/+33 |
| 2023-10-02 | add subscriber coordinator | chrislu | 2 | -5/+12 |
| 2023-10-01 | refactor | chrislu | 3 | -66/+98 |
| 2023-09-30 | adjust mq.proto | chrislu | 1 | -14/+14 |
| 2023-09-04 | api for sub | chrislu | 3 | -27/+45 |
| 2023-09-01 | can pub and sub | chrislu | 3 | -66/+105 |
 |
index : seaweedfs/.git | |
| Unnamed repository; edit this file 'description' to name the repository. | root |
| aboutsummaryrefslogtreecommitdiff |