| Age | Commit message (Expand) | Author | Files | Lines |
|---|---|---|---|---|
| 2024-08-11 | adds locking | chrislu | 1 | -3/+0 |
| 2024-08-10 | Merge branch 'master' into mq | chrislu | 2 | -2/+9 |
| 2024-07-16 | Added tls for http clients (#5766) | vadimartynov | 2 | -2/+9 |
| 2024-06-14 | sort imports | chrislu | 1 | -1/+1 |
| 2024-06-14 | Merge branch 'master' into mq | chrislu | 1 | -2/+3 |
| 2024-06-14 | Added context for the MasterClient's methods to avoid endless loops (#5628) | vadimartynov | 1 | -2/+3 |
| 2024-06-06 | refactor out FilerClientAccessor | chrislu | 1 | -2/+3 |
| 2024-05-30 | remove per-message debug logs | chrislu | 2 | -3/+3 |
| 2024-05-30 | debug | chrislu | 2 | -2/+6 |
| 2024-05-30 | fix passing sub follower offset | chrislu | 1 | -1/+1 |
| 2024-05-29 | skip control messages | chrislu | 1 | -2/+4 |
| 2024-05-29 | fix inflight message tracker | chrislu | 1 | -13/+18 |
| 2024-05-27 | balance subscribers | chrislu | 3 | -5/+16 |
| 2024-05-23 | go fmt | chrislu | 1 | -3/+3 |
| 2024-05-23 | coordinator receives unassignment ack | chrislu | 1 | -1/+6 |
| 2024-05-21 | rename | chrislu | 8 | -27/+27 |
| 2024-05-21 | rename Coordinator to SubCoordinator | chrislu | 1 | -1/+1 |
| 2024-05-21 | rename Balancer to PubBalancer | chrislu | 1 | -1/+1 |
| 2024-05-20 | avoid concurrent processing for the same key | chrislu | 1 | -0/+4 |
| 2024-05-20 | fix | chrislu | 1 | -0/+3 |
| 2024-05-20 | go fmt | chrislu | 3 | -8/+6 |
| 2024-05-20 | Merge branch 'master' into mq | chrislu | 4 | -10/+7 |
| 2024-05-20 | go fmt | chrislu | 4 | -10/+7 |
| 2024-05-20 | adjust logs | chrislu | 1 | -1/+1 |
| 2024-05-20 | track offset | chrislu | 1 | -2/+6 |
| 2024-05-19 | less logs | chrislu | 1 | -1/+1 |
| 2024-05-19 | logs | chrislu | 1 | -1/+1 |
| 2024-05-19 | persist consumer group offset | chrislu | 5 | -31/+113 |
| 2024-05-17 | add subscribe follower | chrislu | 2 | -0/+86 |
| 2024-05-16 | consumer acks received messages | chrislu | 2 | -8/+25 |
| 2024-05-16 | adjust errors | chrislu | 2 | -4/+5 |
| 2024-05-14 | move initial assignment to rebalance logic | chrislu | 2 | -15/+7 |
| 2024-05-14 | move read write topic config into filer client accessor | chrislu | 4 | -53/+13 |
| 2024-05-13 | refactor | chrislu | 1 | -2/+2 |
| 2024-04-12 | save schema when configuring topic | chrislu | 1 | -0/+10 |
| 2024-04-02 | refactor | chrislu | 1 | -1/+1 |
| 2024-04-02 | comment out println | chrislu | 2 | -7/+4 |
| 2024-04-01 | shutdown follower when leader stops | chrislu | 1 | -6/+107 |
| 2024-04-01 | send flush message to follower before shutting down logBuffer | chrislu | 2 | -0/+14 |
| 2024-04-01 | renaming | chrislu | 4 | -7/+7 |
| 2024-03-31 | add control message to data message | chrislu | 1 | -0/+3 |
| 2024-03-31 | add publisher name for debugging | chrislu | 1 | -4/+4 |
| 2024-03-30 | logs | chrislu | 1 | -2/+0 |
| 2024-03-27 | simplify | chrislu | 2 | -3/+2 |
| 2024-03-27 | publish and send to follower | chrislu | 1 | -15/+2 |
| 2024-03-27 | refactor | chrislu | 1 | -45/+4 |
| 2024-03-27 | refactor | chrislu | 1 | -12/+0 |
| 2024-03-27 | separate goroutine to send ack to publisher | chrislu | 1 | -55/+39 |
| 2024-03-27 | separate context | chrislu | 1 | -1/+1 |
| 2024-03-26 | rename | chrislu | 1 | -3/+3 |
