71 Commits (cbcc75bef8cb73f7e45690f1c8f080170ed53eaa)

Author SHA1 Message Date
chrislu 664b704e30 add delay 12 months ago
chrislu 4e3701df77 reset last error 12 months ago
chrislu 7a9b115cc2 rename 1 year ago
chrislu 4a3e8869bb subscriber can unmarshal the record 1 year ago
chrislu 1c5043baf7 rename 1 year ago
chrislu f2f4630029 rename field types 1 year ago
chrislu b8af997e41 consistent with protobuf data types 1 year ago
chrislu 0f35b3a4ea add example to publish a record 1 year ago
chrislu 928a4e8dff rename 1 year ago
yudrywet 8833745fbc
chore: fix some typos in comments (#5497) 1 year ago
chrislu 68ade92d4f publisher send schema 1 year ago
chrislu 5324e4288a rename parameter 1 year ago
chrislu 66a878af39 add control message to data message 1 year ago
chrislu 546ae87c39 send is_close message to broker 1 year ago
chrislu c9df613b6b add publisher name for debugging 1 year ago
chrislu 205d2285f3 setup follower by publisher 1 year ago
chrislu da31e9b939 correctly wait for the publisher to finish 1 year ago
chrislu 7003ce7425 publisher is able to fully send data and receive acks 1 year ago
chrislu 33ab6cfcf7 adjust error 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 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
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 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 841fafd0a8 publish to input buffer 1 year ago
chrislu 91af1f3069 schedule jobs 1 year ago
chrislu 34a78ffad0 remove isForPublish from LookupTopicBrokers 1 year ago
chrislu 7e6497cc1c adjust publisher subscriber 1 year ago
chrislu 026c54a9bb fix publisher 1 year ago
chrislu 3aa3991f0f adjust client side logs 1 year ago
chrislu 6a7a679137 passing partition generation timestamp 1 year ago
chrislu 49428a303b add batch index for each memory buffer 1 year ago
chrislu d0d24f1e40 rename functions 1 year ago
chrislu aa5b6a8187 adjust logs 1 year ago
chrislu 496fc8fbbf refactor 1 year ago
chrislu 531f854af2 rename functions 1 year ago
chrislu f8787a9761 rename functions 1 year ago
chrislu ddd0fde094 rename functions 1 year ago
chrislu ee41dbb7fc rename functions 1 year ago
chrislu 47a4963d7a subscription start from specified timestamp 1 year ago