| Age | Commit message (Collapse) | Author | Files | Lines | |
|---|---|---|---|---|---|
| 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 | |
| 1. use one follower 2. read write consumer group offset | |||||
| 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 | |
| to avoid overhead when a publisher repeatedly send one message and close | |||||
| 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 | |
| * the subscriber would getOrGen a local partition and wait * the publisher would getOrGen a local partition. If localPartition follower is not setup, and init message has follower info, it would create followers based on init.Messages. | |||||
| 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 | |
| 2024-01-10 | passing partition generation timestamp | chrislu | 1 | -1/+1 | |
| 2024-01-08 | flush to disk | chrislu | 1 | -6/+5 | |
| Need to do: read from disk | |||||
| 2024-01-08 | add batch index for each memory buffer | chrislu | 1 | -2/+14 | |
| 2023-12-28 | subscriber can get assignments | chrislu | 1 | -0/+9 | |
| 2023-12-11 | Merge accumulated changes related to message queue (#5098) | Chris Lu | 7 | -70/+242 | |
| * balance partitions on brokers * prepare topic partition first and then publish, move partition * purge unused APIs * clean up * adjust logs * add BalanceTopics() grpc API * configure topic * configure topic command * refactor * repair missing partitions * sequence of operations to ensure ordering * proto to close publishers and consumers * rename file * topic partition versioned by unixTimeNs * create local topic partition * close publishers * randomize the client name * wait until no publishers * logs * close stop publisher channel * send last ack * comments * comment * comments * support list of brokers * add cli options * Update .gitignore * logs * return io.eof directly * refactor * optionally create topic * refactoring * detect consumer disconnection * sub client wait for more messages * subscribe by time stamp * rename * rename to sub_balancer * rename * adjust comments * rename * fix compilation * rename * rename * SubscriberToSubCoordinator * sticky rebalance * go fmt * add tests * balance partitions on brokers * prepare topic partition first and then publish, move partition * purge unused APIs * clean up * adjust logs * add BalanceTopics() grpc API * configure topic * configure topic command * refactor * repair missing partitions * sequence of operations to ensure ordering * proto to close publishers and consumers * rename file * topic partition versioned by unixTimeNs * create local topic partition * close publishers * randomize the client name * wait until no publishers * logs * close stop publisher channel * send last ack * comments * comment * comments * support list of brokers * add cli options * Update .gitignore * logs * return io.eof directly * refactor * optionally create topic * refactoring * detect consumer disconnection * sub client wait for more messages * subscribe by time stamp * rename * rename to sub_balancer * rename * adjust comments * rename * fix compilation * rename * rename * SubscriberToSubCoordinator * sticky rebalance * go fmt * add tests * tracking topic=>broker * merge * comment | |||||
| 2023-10-02 | add subscriber coordinator | chrislu | 1 | -0/+17 | |
| 2023-10-02 | refactor TopicPartition struct | chrislu | 3 | -14/+12 | |
| 2023-09-24 | comment | chrislu | 1 | -1/+1 | |
| 2023-09-24 | ensure latest stats are reported | chrislu | 1 | -7/+12 | |
| 2023-09-24 | fix listing topics | chrislu | 2 | -1/+22 | |
| 2023-09-19 | wip | chrislu | 1 | -3/+15 | |
 |
index : seaweedfs/.git | |
| Unnamed repository; edit this file 'description' to name the repository. | root |
| aboutsummaryrefslogtreecommitdiff |