 chrislu
|
5038577f7e
Merge branch 'master' into mq
|
4 months ago |
|
chrislu
|
d218fe54fa
go fmt
|
4 months ago |
|
chrislu
|
b1871427c3
persist consumer group offset
|
4 months ago |
|
chrislu
|
8d5bb7420d
rename
|
4 months ago |
|
chrislu
|
ccdd9cd8de
refactor
|
6 months ago |
|
chrislu
|
f37c0d0d7a
comment out println
|
6 months ago |
|
chrislu
|
f07875e8e1
send flush message to follower before shutting down logBuffer
|
6 months ago |
|
chrislu
|
47975e75bf
purge old code
|
6 months ago |
|
chrislu
|
237e68059d
shutdown follower if no clients, not only publishers
|
6 months ago |
|
chrislu
|
c9df613b6b
add publisher name for debugging
|
6 months ago |
|
chrislu
|
ca4f89a6f6
simplify
|
6 months ago |
|
chrislu
|
0d55bddc75
logs
|
6 months ago |
|
chrislu
|
e3c8be7f89
LocalPartition shutdown
|
6 months ago |
|
chrislu
|
ab9fc0ad70
simplify
|
6 months ago |
|
chrislu
|
7463058299
change visibility
|
6 months ago |
|
chrislu
|
dab5454332
publish and send to follower
|
6 months ago |
|
chrislu
|
f249f831b1
MaybeShutdownLocalPartition refactor
|
6 months ago |
|
chrislu
|
2a0ab7e90d
fix
|
6 months ago |
|
chrislu
|
059a120708
refactor
|
6 months ago |
|
chrislu
|
7d87c1d2bb
refactor
|
6 months ago |
|
chrislu
|
5cc94a05b9
separate goroutine to send ack to publisher
|
6 months ago |
|
chrislu
|
f67c8309d8
rename
|
6 months ago |
|
chrislu
|
205d2285f3
setup follower by publisher
|
6 months ago |
|
chrislu
|
6ef3e6bcad
logging
|
6 months ago |
|
chrislu
|
8e5068fd2f
notify
|
6 months ago |
|
chrislu
|
529fa8c4c8
go fmt
|
6 months ago |
|
chrislu
|
6f75a0af55
ask follower to follow
|
6 months ago |
|
chrislu
|
3b28433cb1
change LogBuffer visibility in LocalPartition
|
7 months ago |
|
chrislu
|
1b4484bf0a
go fmt
|
7 months ago |
|
chrislu
|
3795d8dca8
release local topic partition if no publisher and subscribers
|
8 months ago |
|
chrislu
|
ba73199174
reuse local partition
|
8 months ago |
|
chrislu
|
fa59a5d67e
read from disk if not in memory
|
8 months ago |
|
chrislu
|
6a7a679137
passing partition generation timestamp
|
8 months ago |
|
chrislu
|
d51efddf5c
flush to disk
|
9 months ago |
|
chrislu
|
49428a303b
add batch index for each memory buffer
|
9 months ago |
|
Chris Lu
|
580940bf82
Merge accumulated changes related to message queue (#5098)
|
9 months ago |
|
chrislu
|
4827425146
balancer works
|
1 year ago |
|
chrislu
|
1eb2da46d5
connect and publish
|
1 year ago |
|
chrislu
|
dbcba75271
rename to lookup
|
1 year ago |
|
chrislu
|
1990456670
sub
|
1 year ago |
|
chrislu
|
905911853d
adjust proto
|
1 year ago |
|
chrislu
|
01d70c21f3
Squashed commit of the following:
|
1 year ago |
