 chrislu
|
edc87c16f9
balance subscribers
|
5 months ago |
|
chrislu
|
d40b350f54
coordinator receives unassignment ack
|
6 months ago |
|
chrislu
|
554ae09f82
rename
|
6 months ago |
|
chrislu
|
972e9faaa2
move initial assignment to rebalance logic
|
6 months ago |
|
chrislu
|
2142842f82
refactor
|
6 months ago |
|
chrislu
|
205d2285f3
setup follower by publisher
|
8 months ago |
|
Chris Lu
|
656b78d1af
proxy to broker leader
|
9 months ago |
|
chrislu
|
c8090b1f99
send assignments to newly connected subscribers
|
10 months ago |
|
chrislu
|
61dbdd0ff6
log ctrl messages
|
10 months ago |
|
chrislu
|
c950a40aad
subscriber keep connected to the balancer
|
10 months ago |
|
chrislu
|
e0727071c8
go fmt
|
11 months ago |
|
Chris Lu
|
580940bf82
Merge accumulated changes related to message queue (#5098)
|
11 months ago |
