521 Commits (2a4a9c6343ac32e31172f97789715bb1f3ba302a)

Author SHA1 Message Date
chrislu 66a878af39 add control message to data message 12 months ago
chrislu 546ae87c39 send is_close message to broker 12 months ago
chrislu c9df613b6b add publisher name for debugging 12 months ago
chrislu ab9fc0ad70 simplify 1 year ago
chrislu 205d2285f3 setup follower by publisher 1 year ago
chrislu 7003ce7425 publisher is able to fully send data and receive acks 1 year ago
chrislu 516cba7053 remove FollowInMemoryMessages 1 year ago
chrislu 6f75a0af55 ask follower to follow 1 year ago
chrislu 28f8f33d6a include key in LogEntry 1 year ago
chrislu 7e443ef0a1 latest protoc-gen-go 1 year ago
chrislu ead27a4f59 publish init add followers 1 year ago
chrislu 1b4484bf0a go fmt 1 year ago
Chris Lu e27deed4bc upgrade protoc 1 year ago
chrislu d41792461c lock returns host and owner 1 year ago
chrislu 34a78ffad0 remove isForPublish from LookupTopicBrokers 1 year ago
chrislu 49428a303b add batch index for each memory buffer 1 year ago
chrislu e8611ed85d subscribe with partition offset 1 year ago
chrislu ee41dbb7fc rename functions 1 year ago
chrislu 1fed37bed0 add offset 1 year ago
chrislu 093fdc1621 subscriber can get assignments 1 year ago
chrislu c950a40aad subscriber keep connected to the balancer 1 year ago
Chris Lu 580940bf82
Merge accumulated changes related to message queue (#5098) 1 year ago
chrislu deb86ff4a6 upgrading grpc 1 year ago
chrislu de0b969b36 Revert "rename" 1 year ago
Konstantin Lebedev 1cac5d983d
fix: disallow file name too long when writing a file (#4881) 1 year ago
chrislu 35b5264ab7 rename 1 year ago
Konstantin Lebedev 2b3e39397e
fix: skipping checking active volumes with the same number of files at the moment (#4893) 1 year ago
chrislu b02fdeabff RetryForever => RetryUntil 1 year ago
chrislu ebd6f96d35 adjust mq.proto 2 years ago
chrislu 358cba43ef update proto generated files 2 years ago
chrislu d7c211fe8c adjust mq proto 2 years ago
chrislu 9d589b48e6 rename function 2 years ago
Konstantin Lebedev f8b94cac0e
[s3acl] Step1: move s3account.AccountManager into to iam.S3ApiConfiguration (#4859) 2 years ago
chrislu 3cf9b8d621 create topic and report topic 2 years ago
chrislu b3f94feede do create topic 2 years ago
chrislu 0361c321b4 add CreateTopic API 2 years ago
chrislu 6c6655de9d wip 2 years ago
chrislu 340aea9b34 add broker leader 2 years ago
chrislu a65088d739 broker report stats to balancer 2 years ago
chrislu 89a1fd1751 Squashed commit of the following: 2 years ago
chrislu 4827425146 balancer works 2 years ago
chrislu 436d99443b receive broker stats 2 years ago
chrislu 2492a45499 ack interval 2 years ago
chrislu ba67e6ca29 api for sub 2 years ago
chrislu cb470d44df can pub and sub 2 years ago
chrislu 504ae8383a protoc version 2 years ago
chrislu dbcba75271 rename to lookup 2 years ago
chrislu 4d6c18d86f pub sub initial tests 2 years ago
chrislu 1990456670 sub 2 years ago
chrislu 905911853d adjust proto 2 years ago