272 Commits (b62f7c512267cfe379100fa283bbe4b0682e5dc9)

Author SHA1 Message Date
chrislu 34f2b600ac each log function adds a "done" return parameter 10 months ago
chrislu 62397f2371 adjust error 10 months ago
chrislu 49869eec83 edge cases for broker assignment 10 months ago
chrislu 33ab6cfcf7 adjust error 10 months ago
chrislu fe03b1b522 handle single broker case 10 months ago
chrislu 50c5dd7313 test low active brokers 10 months ago
chrislu 7598922b41 assign followers 10 months ago
chrislu ead27a4f59 publish init add followers 10 months ago
chrislu 1b4484bf0a go fmt 10 months ago
Chris Lu 16b4f9d9ab subscriber find broker leader first 11 months ago
Chris Lu 656b78d1af proxy to broker leader 11 months ago
Chris Lu 90fcde0e26 report EOF error 11 months ago
Chris Lu 07028a4864 minor 11 months ago
Chris Lu 4dc6681833 proxy requests to lock owner 11 months ago
Chris Lu 0d74ac9224 fix divide by zero 11 months ago
Chris Lu f9131de43f fix lock TTL 11 months ago
Chris Lu 0a12301b3d avoid too large expiration time 11 months ago
chrislu d41792461c lock returns host and owner 11 months ago
chrislu d30150dde1 use a short-lived lock 11 months ago
chrislu ac50d8a822 re-lock if the lock owner is not found 11 months ago
chrislu 0b2e5ddc7c wait 3 seconds before shutting down publish client, to wait for all messages to be received 11 months ago
chrislu 545d5fbdf6 unused code 11 months ago
chrislu a507069d19 lock for creating local partition 11 months ago
chrislu 9e6ea80dff read existing topic conf 11 months ago
chrislu a297247137 wait for each publish clients 11 months ago
chrislu b6c5e57c30 read will block if no items 11 months ago
chrislu 0bf5424a2e adjust visibility 11 months ago
chrislu dedfd31dfb refactor 11 months ago
chrislu cbf750a31f refactor 11 months ago
chrislu b51dfe2bff wait for publishing clients 11 months ago
chrislu f8c55f101e clean up 11 months ago
chrislu d40225ecd2 return the lookup results 11 months ago
chrislu 841fafd0a8 publish to input buffer 11 months ago
chrislu 91af1f3069 schedule jobs 11 months ago
chrislu d268fbe18a when configure, cancel existing assignments 11 months ago
chrislu 3ff6b31d94 sub broker wait for partition 11 months ago
chrislu 2beaa2d0b3 pub/sub brokers check filer for assigned partitions 11 months ago
chrislu c3f8530f97 refactor 11 months ago
chrislu 5f35857cd0 no need to assign partitions explicitly 11 months ago
chrislu 428fea45f3 updated and added assignments 11 months ago
chrislu e8b05ecc91 add/remove assigned partitions 11 months ago
chrislu 861ad732ca refactor 11 months ago
chrislu 47924afa1c refactor 11 months ago
chrislu 581cf6644c lookup reads from filer instead of local memory 11 months ago
chrislu 7121ae9617 separate out read topic conf and ensure topic active assignments 11 months ago
chrislu c77d35313e pub/sub broker only check local assigned partitions 11 months ago
chrislu b0a2e9aea3 fix assignments if brokers changed 11 months ago
chrislu 9ce7c482b3 refactor 11 months ago
chrislu a5b906c0dd refactor 11 months ago
chrislu 34839237ab refactor 11 months ago