| Age | Commit message (Collapse) | Author | Files | Lines | |
|---|---|---|---|---|---|
| 2024-08-29 | math/rand => math/rand/v2 | chrislu | 1 | -1/+1 | |
| 2024-08-27 | rename | chrislu | 1 | -1/+1 | |
| 2024-08-16 | EC volume supports expiration and displays expiration message when executing ↵ | augustazz | 4 | -1045/+1067 | |
| volume.list (#5895) * ec volume expire * volume.list show DestroyTime * comments * code optimization --------- Co-authored-by: xuwenfeng <xuwenfeng1@zto.com> | |||||
| 2024-08-13 | rename | chrislu | 2 | -491/+491 | |
| 2024-08-13 | add dat file size into vif for EC | chrislu | 2 | -496/+507 | |
| 2024-08-10 | Merge branch 'master' into mq | chrislu | 5 | -657/+957 | |
| 2024-08-01 | conditional delete | chrislu | 2 | -495/+507 | |
| 2024-07-21 | add version to filer | chrislu | 2 | -321/+344 | |
| 2024-07-20 | Revert "add collection for buckets" | chrislu | 2 | -14/+3 | |
| This reverts commit 96af5712195be37b309115795066f17c7cc6126d. | |||||
| 2024-07-17 | add collection for buckets | chrislu | 2 | -3/+14 | |
| 2024-06-28 | bootstrap filer from one peer | chrislu | 4 | -453/+715 | |
| 2024-06-19 | [fs.verify] skip failed files if entry not found on filerStore (#5693) | Konstantin Lebedev | 1 | -0/+3 | |
| 2024-06-15 | Merge branch 'master' into mq | chrislu | 2 | -209/+221 | |
| 2024-06-15 | optionally skip deleting file chunks | chrislu | 2 | -209/+221 | |
| 2024-05-29 | passing along publisher name | chrislu | 2 | -284/+284 | |
| 2024-05-27 | balance subscribers | chrislu | 2 | -451/+545 | |
| need to ensure the offsets are persisted | |||||
| 2024-05-23 | coordinator receives unassignment ack | chrislu | 2 | -475/+570 | |
| 2024-05-21 | refactor | chrislu | 2 | -438/+519 | |
| ToDo 1. handle unassignment on client side 2. get notified of completed unassignment 3. in consumer_group.go, balance and send unassignment | |||||
| 2024-05-20 | unused | chrislu | 2 | -500/+400 | |
| 2024-05-20 | track offset | chrislu | 2 | -175/+196 | |
| 2024-05-19 | start consuming ASAP | chrislu | 2 | -298/+326 | |
| 2024-05-19 | persist consumer group offset | chrislu | 2 | -422/+443 | |
| 1. use one follower 2. read write consumer group offset | |||||
| 2024-05-17 | add subscribe follower | chrislu | 3 | -244/+737 | |
| 2024-05-13 | consumer instance passing MaxPartitionCount to coordinator | chrislu | 2 | -3/+15 | |
| 2024-05-02 | rename | chrislu | 2 | -27/+27 | |
| 2024-05-02 | rename field types | chrislu | 2 | -32/+32 | |
| 2024-04-27 | add field index | chrislu | 2 | -81/+82 | |
| 2024-04-18 | all record fields are optional by default | chrislu | 2 | -70/+81 | |
| 2024-04-17 | convert to parquet schema and value | chrislu | 2 | -66/+178 | |
| 2024-04-12 | add proto for value | chrislu | 4 | -507/+841 | |
| 2024-04-12 | minor | chrislu | 2 | -3/+3 | |
| 2024-04-12 | all fields are optional | chrislu | 2 | -80/+41 | |
| 2024-04-12 | add schema.proto | chrislu | 3 | -0/+561 | |
| 2024-03-31 | add control message to data message | chrislu | 2 | -425/+495 | |
| 2024-03-31 | send is_close message to broker | chrislu | 2 | -230/+240 | |
| 2024-03-31 | add publisher name for debugging | chrislu | 2 | -201/+213 | |
| 2024-03-27 | simplify | chrislu | 2 | -17/+18 | |
| 2024-03-24 | setup follower by publisher | chrislu | 2 | -358/+279 | |
| * 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-20 | publisher is able to fully send data and receive acks | chrislu | 3 | -274/+573 | |
| still needs to close the pipes cleanly | |||||
| 2024-03-17 | remove FollowInMemoryMessages | chrislu | 3 | -793/+222 | |
| 2024-03-10 | ask follower to follow | chrislu | 3 | -270/+1050 | |
| 2024-03-07 | include key in LogEntry | chrislu | 2 | -261/+271 | |
| 2024-02-29 | latest protoc-gen-go | chrislu | 8 | -8/+8 | |
| 2024-02-29 | publish init add followers | chrislu | 2 | -166/+178 | |
| 2024-02-29 | go fmt | chrislu | 14 | -21/+21 | |
| 2024-02-05 | upgrade protoc | Chris Lu | 15 | -23/+23 | |
| 2024-02-02 | lock returns host and owner | chrislu | 2 | -176/+188 | |
| 2024-01-16 | remove isForPublish from LookupTopicBrokers | chrislu | 2 | -286/+274 | |
| also adds a return parameter: whether the topic exists or not | |||||
| 2024-01-08 | add batch index for each memory buffer | chrislu | 2 | -460/+549 | |
| 2024-01-05 | subscribe with partition offset | chrislu | 2 | -196/+140 | |
