 chrislu
|
edc87c16f9
balance subscribers
|
5 months ago |
|
chrislu
|
d40b350f54
coordinator receives unassignment ack
|
6 months ago |
|
chrislu
|
fa98ecf71e
client side stop partition subscribing if unassigned
|
6 months ago |
|
chrislu
|
2190d59bc3
refactor
|
6 months ago |
|
chrislu
|
33aecb7bb4
remove ProcessorConfiguration
|
6 months ago |
|
chrislu
|
3622196881
go fmt
|
6 months ago |
|
chrislu
|
d8ab22012a
track offset
|
6 months ago |
|
chrislu
|
279cb2b85e
consumer acks received messages
|
6 months ago |
|
chrislu
|
1f20178ded
subscriber receives partitions and dispatch to processors
|
6 months ago |
|
chrislu
|
458ddbf919
clean up dead code
|
10 months ago |
|
chrislu
|
c950a40aad
subscriber keep connected to the balancer
|
10 months ago |
|
Chris Lu
|
580940bf82
Merge accumulated changes related to message queue (#5098)
|
11 months ago |
|
chrislu
|
bf13f3ced7
add subscriber coordinator
|
1 year ago |
|
chrislu
|
2a578b9033
refactor
|
1 year ago |
|
chrislu
|
ebd6f96d35
adjust mq.proto
|
1 year ago |
|
chrislu
|
ba67e6ca29
api for sub
|
1 year ago |
|
chrislu
|
cb470d44df
can pub and sub
|
1 year ago |
|
chrislu
|
1eb2da46d5
connect and publish
|
1 year ago |
