| Age | Commit message (Expand) | Author | Files | Lines |
|---|---|---|---|---|
| 2024-03-27 | fix | chrislu | 1 | -1/+1 |
| 2024-03-27 | refactor | chrislu | 2 | -45/+54 |
| 2024-03-27 | refactor | chrislu | 2 | -12/+18 |
| 2024-03-27 | separate goroutine to send ack to publisher | chrislu | 2 | -55/+40 |
| 2024-03-27 | separate context | chrislu | 1 | -1/+1 |
| 2024-03-26 | rename | chrislu | 2 | -5/+5 |
| 2024-03-25 | adjust logs | chrislu | 1 | -2/+3 |
| 2024-03-24 | close local partition if no more publishers and subscribers | chrislu | 1 | -29/+28 |
| 2024-03-24 | refactor | chrislu | 2 | -15/+15 |
| 2024-03-24 | refactor | chrislu | 3 | -23/+24 |
| 2024-03-24 | setup follower by publisher | chrislu | 7 | -76/+60 |
| 2024-03-21 | correctly wait for the publisher to finish | chrislu | 1 | -7/+16 |
| 2024-03-20 | publisher is able to fully send data and receive acks | chrislu | 4 | -61/+202 |
| 2024-03-17 | remove FollowInMemoryMessages | chrislu | 2 | -252/+1 |
| 2024-03-17 | logging | chrislu | 1 | -0/+1 |
| 2024-03-17 | Merge branch 'master' into mq-subscribe | chrislu | 2 | -48/+0 |
| 2024-03-16 | fix test3 | chrislu | 1 | -47/+0 |
| 2024-03-16 | fix test | chrislu | 1 | -1/+0 |
| 2024-03-16 | notify | chrislu | 2 | -11/+22 |
| 2024-03-16 | unnecessary | chrislu | 1 | -5/+0 |
| 2024-03-16 | add follower id info | chrislu | 1 | -4/+6 |
| 2024-03-16 | go fmt | chrislu | 6 | -45/+44 |
| 2024-03-15 | logs | chrislu | 1 | -1/+1 |
| 2024-03-15 | local partition is generated or not | chrislu | 3 | -10/+11 |
| 2024-03-15 | streaming mode | chrislu | 1 | -1/+1 |
| 2024-03-15 | follower receive a hello message before actual data | chrislu | 2 | -1/+28 |
| 2024-03-15 | add size() | chrislu | 2 | -0/+14 |
| 2024-03-10 | ask follower to follow | chrislu | 6 | -33/+293 |
| 2024-03-09 | retry connecting to broker leader | chrislu | 2 | -14/+48 |
| 2024-03-07 | change LogBuffer visibility in LocalPartition | chrislu | 1 | -9/+9 |
| 2024-03-07 | include key in LogEntry | chrislu | 1 | -3/+2 |
| 2024-03-07 | each log function adds a "done" return parameter | chrislu | 2 | -5/+5 |
| 2024-03-07 | adjust error | chrislu | 1 | -1/+2 |
| 2024-03-07 | edge cases for broker assignment | chrislu | 2 | -9/+23 |
| 2024-03-07 | adjust error | chrislu | 1 | -1/+1 |
| 2024-03-01 | handle single broker case | chrislu | 2 | -2/+37 |
| 2024-02-29 | test low active brokers | chrislu | 2 | -1/+24 |
| 2024-02-29 | assign followers | chrislu | 3 | -25/+214 |
| 2024-02-29 | publish init add followers | chrislu | 1 | -3/+4 |
| 2024-02-29 | go fmt | chrislu | 12 | -46/+45 |
| 2024-02-05 | subscriber find broker leader first | Chris Lu | 4 | -38/+43 |
| 2024-02-05 | proxy to broker leader | Chris Lu | 5 | -22/+5 |
| 2024-02-05 | report EOF error | Chris Lu | 1 | -2/+2 |
| 2024-02-05 | minor | Chris Lu | 1 | -2/+2 |
| 2024-02-05 | proxy requests to lock owner | Chris Lu | 6 | -71/+63 |
| 2024-02-04 | fix divide by zero | Chris Lu | 1 | -7/+11 |
| 2024-02-04 | fix lock TTL | Chris Lu | 1 | -4/+3 |
| 2024-02-04 | avoid too large expiration time | Chris Lu | 1 | -1/+1 |
| 2024-02-02 | lock returns host and owner | chrislu | 1 | -4/+7 |
| 2024-02-01 | use a short-lived lock | chrislu | 1 | -2/+2 |
