337 Commits (be338b37b48c491f555d51a2ba8f68b4d0645f30)

Author SHA1 Message Date
chrislu d88c1872ac works with single level of list 12 months ago
chrislu d7e5f6b2a5 fix ordering 12 months ago
chrislu 9ef238b610 has a bug 1 year ago
chrislu cc1ce3de87 all record fields are optional by default 1 year ago
chrislu 384ed7a381 add test 1 year ago
chrislu 57949f9959 support list type 1 year ago
chrislu 05d18130b6 add schema builder 1 year ago
chrislu 0847a17484 convert to parquet schema and value 1 year ago
yudrywet 8833745fbc
chore: fix some typos in comments (#5497) 1 year ago
chrislu 68ade92d4f publisher send schema 1 year ago
chrislu 8415476c2d fix test 1 year ago
chrislu 5324e4288a rename parameter 1 year ago
chrislu 6f80dbdfe5 Create schema.go 1 year ago
chrislu 53d1d2b78a save schema when configuring topic 1 year ago
chrislu d45a372615 add schema.proto 1 year ago
chrislu ccdd9cd8de refactor 1 year ago
chrislu f37c0d0d7a comment out println 1 year ago
chrislu d935f70e3c shutdown follower when leader stops 1 year ago
chrislu f07875e8e1 send flush message to follower before shutting down logBuffer 1 year ago
chrislu e568e742c9 renaming 1 year ago
chrislu 47975e75bf purge old code 1 year ago
chrislu 237e68059d shutdown follower if no clients, not only publishers 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 ca4f89a6f6 simplify 1 year ago
chrislu 0d55bddc75 logs 1 year ago
chrislu e3c8be7f89 LocalPartition shutdown 1 year ago
chrislu ab9fc0ad70 simplify 1 year ago
chrislu 7463058299 change visibility 1 year ago
chrislu dab5454332 publish and send to follower 1 year ago
chrislu f249f831b1 MaybeShutdownLocalPartition refactor 1 year ago
chrislu 2a0ab7e90d fix 1 year ago
chrislu 059a120708 refactor 1 year ago
chrislu 7d87c1d2bb refactor 1 year ago
chrislu 5cc94a05b9 separate goroutine to send ack to publisher 1 year ago
chrislu 17806cde2a separate context 1 year ago
chrislu f67c8309d8 rename 1 year ago
chrislu d6a066495b adjust logs 1 year ago
chrislu 1b1b96ea1e close local partition if no more publishers and subscribers 1 year ago
chrislu 4f5c4c3388 refactor 1 year ago
chrislu d558a58946 refactor 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 516cba7053 remove FollowInMemoryMessages 1 year ago
chrislu 6ef3e6bcad logging 1 year ago
chrislu a8b73296d7 fix test3 1 year ago
chrislu ea2601799c fix test 1 year ago
chrislu 8e5068fd2f notify 1 year ago