| Age | Commit message (Expand) | Author | Files | Lines |
|---|---|---|---|---|
| 2024-05-29 | passing along publisher name | chrislu | 1 | -283/+283 |
| 2024-05-27 | balance subscribers | chrislu | 1 | -450/+540 |
| 2024-05-23 | coordinator receives unassignment ack | chrislu | 1 | -475/+566 |
| 2024-05-21 | refactor | chrislu | 1 | -436/+514 |
| 2024-05-20 | unused | chrislu | 1 | -495/+400 |
| 2024-05-20 | track offset | chrislu | 1 | -175/+194 |
| 2024-05-19 | start consuming ASAP | chrislu | 1 | -298/+317 |
| 2024-05-19 | persist consumer group offset | chrislu | 1 | -419/+438 |
| 2024-05-17 | add subscribe follower | chrislu | 2 | -243/+715 |
| 2024-05-13 | consumer instance passing MaxPartitionCount to coordinator | chrislu | 1 | -3/+14 |
| 2024-04-12 | add proto for value | chrislu | 1 | -481/+509 |
| 2024-03-31 | add control message to data message | chrislu | 1 | -422/+489 |
| 2024-03-31 | send is_close message to broker | chrislu | 1 | -230/+239 |
| 2024-03-31 | add publisher name for debugging | chrislu | 1 | -201/+212 |
| 2024-03-27 | simplify | chrislu | 1 | -15/+16 |
| 2024-03-24 | setup follower by publisher | chrislu | 1 | -352/+277 |
| 2024-03-20 | publisher is able to fully send data and receive acks | chrislu | 2 | -269/+556 |
| 2024-03-17 | remove FollowInMemoryMessages | chrislu | 2 | -765/+222 |
| 2024-03-10 | ask follower to follow | chrislu | 2 | -270/+1011 |
| 2024-02-29 | latest protoc-gen-go | chrislu | 1 | -1/+1 |
| 2024-02-29 | publish init add followers | chrislu | 1 | -166/+177 |
| 2024-02-29 | go fmt | chrislu | 1 | -1/+1 |
| 2024-02-05 | upgrade protoc | Chris Lu | 2 | -3/+3 |
| 2024-01-16 | remove isForPublish from LookupTopicBrokers | chrislu | 1 | -285/+274 |
| 2024-01-08 | add batch index for each memory buffer | chrislu | 1 | -459/+540 |
| 2024-01-05 | subscribe with partition offset | chrislu | 1 | -190/+138 |
| 2024-01-05 | rename functions | chrislu | 2 | -403/+411 |
| 2024-01-05 | add offset | chrislu | 1 | -247/+400 |
| 2023-12-28 | subscriber can get assignments | chrislu | 1 | -193/+202 |
| 2023-12-28 | subscriber keep connected to the balancer | chrislu | 1 | -223/+224 |
| 2023-12-11 | Merge accumulated changes related to message queue (#5098) | Chris Lu | 2 | -1572/+1384 |
| 2023-10-12 | upgrading grpc | chrislu | 2 | -29/+46 |
| 2023-10-12 | Revert "rename" | chrislu | 2 | -416/+413 |
| 2023-10-11 | rename | chrislu | 2 | -413/+416 |
| 2023-09-30 | adjust mq.proto | chrislu | 2 | -346/+273 |
| 2023-09-30 | adjust mq proto | chrislu | 1 | -214/+337 |
| 2023-09-26 | rename function | chrislu | 2 | -361/+363 |
| 2023-09-24 | create topic and report topicorigin/sub | chrislu | 2 | -396/+557 |
| 2023-09-24 | do create topic | chrislu | 2 | -387/+561 |
| 2023-09-24 | add CreateTopic API | chrislu | 2 | -380/+568 |
| 2023-09-19 | wip | chrislu | 1 | -424/+521 |
| 2023-09-16 | balancer works | chrislu | 1 | -279/+259 |
| 2023-09-14 | receive broker stats | chrislu | 2 | -381/+793 |
| 2023-09-06 | ack interval | chrislu | 1 | -132/+142 |
| 2023-09-04 | api for sub | chrislu | 1 | -99/+118 |
| 2023-09-01 | can pub and sub | chrislu | 1 | -156/+285 |
| 2023-08-28 | protoc version | chrislu | 1 | -1/+1 |
| 2023-08-27 | rename to lookup | chrislu | 2 | -470/+383 |
| 2023-08-27 | pub sub initial tests | chrislu | 1 | -106/+107 |
| 2023-08-27 | sub | chrislu | 2 | -188/+140 |
 |
index : seaweedfs/.git | |
| Unnamed repository; edit this file 'description' to name the repository. | root |
| aboutsummaryrefslogtreecommitdiff |