182 Commits (2a88da4de757630a7d35779867f24c66c71ae7a9)

Author SHA1 Message Date
chrislu a8b73296d7 fix test3 1 year ago
chrislu ea2601799c fix test 1 year ago
chrislu 529fa8c4c8 go fmt 1 year ago
chrislu 1b5c547cfe logs 1 year ago
chrislu 55714f54ab local partition is generated or not 1 year ago
chrislu 549455c30d streaming mode 1 year ago
chrislu f653838f34 follower receive a hello message before actual data 1 year ago
chrislu 64a32730a2 add size() 1 year ago
chrislu 6f75a0af55 ask follower to follow 1 year ago
chrislu e7823ee967 retry connecting to broker leader 1 year ago
chrislu 3b28433cb1 change LogBuffer visibility in LocalPartition 1 year ago
chrislu 28f8f33d6a include key in LogEntry 1 year ago
chrislu 34f2b600ac each log function adds a "done" return parameter 1 year ago
chrislu 62397f2371 adjust error 1 year ago
chrislu 49869eec83 edge cases for broker assignment 1 year ago
chrislu 33ab6cfcf7 adjust error 1 year ago
chrislu fe03b1b522 handle single broker case 1 year ago
chrislu 50c5dd7313 test low active brokers 1 year ago
chrislu 7598922b41 assign followers 1 year ago
chrislu ead27a4f59 publish init add followers 1 year ago
chrislu 1b4484bf0a go fmt 1 year ago
Chris Lu 16b4f9d9ab subscriber find broker leader first 1 year ago
Chris Lu 656b78d1af proxy to broker leader 1 year ago
Chris Lu 90fcde0e26 report EOF error 1 year ago
Chris Lu 07028a4864 minor 1 year ago
Chris Lu 4dc6681833 proxy requests to lock owner 1 year ago
Chris Lu 0d74ac9224 fix divide by zero 1 year ago
Chris Lu f9131de43f fix lock TTL 1 year ago
Chris Lu 0a12301b3d avoid too large expiration time 1 year ago
chrislu d41792461c lock returns host and owner 1 year ago
chrislu d30150dde1 use a short-lived lock 1 year ago
chrislu ac50d8a822 re-lock if the lock owner is not found 1 year ago
chrislu 0b2e5ddc7c wait 3 seconds before shutting down publish client, to wait for all messages to be received 1 year ago
chrislu 545d5fbdf6 unused code 1 year ago
chrislu a507069d19 lock for creating local partition 1 year ago
chrislu 9e6ea80dff read existing topic conf 1 year ago
chrislu a297247137 wait for each publish clients 1 year ago
chrislu b6c5e57c30 read will block if no items 1 year ago
chrislu 0bf5424a2e adjust visibility 1 year ago
chrislu dedfd31dfb refactor 1 year ago
chrislu cbf750a31f refactor 1 year ago
chrislu b51dfe2bff wait for publishing clients 1 year ago
chrislu f8c55f101e clean up 1 year ago
chrislu d40225ecd2 return the lookup results 1 year ago
chrislu 841fafd0a8 publish to input buffer 1 year ago
chrislu 91af1f3069 schedule jobs 1 year ago
chrislu d268fbe18a when configure, cancel existing assignments 1 year ago
chrislu 3ff6b31d94 sub broker wait for partition 1 year ago
chrislu 2beaa2d0b3 pub/sub brokers check filer for assigned partitions 1 year ago
chrislu c3f8530f97 refactor 1 year ago