| Age | Commit message (Expand) | Author | Files | Lines |
|---|---|---|---|---|
| 2025-03-09 | Accumulated changes for message queue (#6600) | Chris Lu | 5 | -507/+0 |
| 2025-01-20 | Add message queue agent (#6463) | Chris Lu | 3 | -26/+157 |
| 2024-12-19 | "golang.org/x/exp/slices" => "slices" and go fmt | chrislu | 2 | -2/+2 |
| 2024-11-04 | merge current message queue code changes (#6201) | Chris Lu | 2 | -8/+20 |
| 2024-08-10 | Merge branch 'master' into mq | chrislu | 4 | -0/+8 |
| 2024-07-16 | Added tls for http clients (#5766) | vadimartynov | 4 | -0/+8 |
| 2024-05-23 | go fmt | chrislu | 2 | -8/+8 |
| 2024-05-20 | remove ProcessorConfiguration | chrislu | 2 | -11/+11 |
| 2024-05-20 | go fmt | chrislu | 2 | -3/+3 |
| 2024-05-20 | Merge branch 'master' into mq | chrislu | 2 | -2/+2 |
| 2024-05-20 | go fmt | chrislu | 2 | -2/+2 |
| 2024-05-20 | track offset | chrislu | 2 | -2/+3 |
| 2024-05-19 | ConcurrentPartitionLimit | chrislu | 2 | -4/+4 |
| 2024-05-10 | clean up unused variables | chrislu | 2 | -2/+0 |
| 2024-05-05 | add delay | chrislu | 1 | -2/+5 |
| 2024-05-02 | rename | chrislu | 1 | -4/+4 |
| 2024-05-02 | subscriber can unmarshal the record | chrislu | 2 | -4/+94 |
| 2024-05-02 | rename | chrislu | 1 | -0/+0 |
| 2024-05-02 | rename field types | chrislu | 1 | -1/+1 |
| 2024-05-02 | consistent with protobuf data types | chrislu | 1 | -8/+8 |
| 2024-05-02 | add example to publish a record | chrislu | 1 | -0/+126 |
| 2024-05-02 | rename | chrislu | 1 | -0/+1 |
| 2024-04-15 | Merge branch 'master' into mq-subscribe | chrislu | 1 | -1/+1 |
| 2024-04-14 | chore: fix some typos in comments (#5497) | yudrywet | 1 | -1/+1 |
| 2024-04-12 | rename parameter | chrislu | 1 | -5/+4 |
| 2024-03-31 | send is_close message to broker | chrislu | 1 | -0/+3 |
| 2024-03-31 | add publisher name for debugging | chrislu | 1 | -3/+7 |
| 2024-02-29 | go fmt | chrislu | 1 | -2/+2 |
| 2024-02-05 | subscriber find broker leader first | Chris Lu | 1 | -3/+3 |
| 2024-01-28 | refactor | chrislu | 1 | -12/+3 |
| 2024-01-28 | refactor | chrislu | 1 | -2/+4 |
| 2024-01-28 | wait for publishing clients | chrislu | 1 | -2/+5 |
| 2024-01-27 | publish to input buffer | chrislu | 1 | -6/+8 |
| 2024-01-15 | adjust publisher subscriber | chrislu | 2 | -6/+10 |
| 2024-01-15 | fix publisher | chrislu | 1 | -1/+4 |
| 2024-01-08 | add batch index for each memory buffer | chrislu | 1 | -2/+5 |
| 2024-01-05 | rename functions | chrislu | 1 | -0/+1 |
| 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 | 1 | -2/+2 |
| 2023-12-31 | clean up dead code | chrislu | 1 | -2/+2 |
| 2023-12-28 | subscriber keep connected to the balancer | chrislu | 1 | -5/+9 |
| 2023-12-11 | Merge accumulated changes related to message queue (#5098) | Chris Lu | 2 | -6/+26 |
| 2023-10-01 | refactor | chrislu | 1 | -5/+1 |
| 2023-09-07 | add publisher shutdown | chrislu | 1 | -0/+1 |
| 2023-09-04 | api for sub | chrislu | 1 | -9/+23 |
| 2023-09-04 | publish, benchmark | chrislu | 1 | -10/+38 |
| 2023-09-01 | can pub and sub | chrislu | 1 | -38/+18 |
| 2023-08-28 | connect and publish | chrislu | 2 | -0/+79 |
 |
index : seaweedfs/.git | |
| Unnamed repository; edit this file 'description' to name the repository. | root |
| aboutsummaryrefslogtreecommitdiff |