aboutsummaryrefslogtreecommitdiff
path: root/weed/pb
AgeCommit message (Expand)AuthorFilesLines
2024-03-31add publisher name for debuggingchrislu2-201/+213
2024-03-27simplifychrislu2-17/+18
2024-03-24setup follower by publisherchrislu2-358/+279
2024-03-20publisher is able to fully send data and receive ackschrislu3-274/+573
2024-03-17remove FollowInMemoryMessageschrislu3-793/+222
2024-03-10ask follower to followchrislu3-270/+1050
2024-03-07include key in LogEntrychrislu2-261/+271
2024-02-29latest protoc-gen-gochrislu8-8/+8
2024-02-29publish init add followerschrislu2-166/+178
2024-02-29go fmtchrislu14-21/+21
2024-02-05upgrade protocChris Lu15-23/+23
2024-02-02lock returns host and ownerchrislu2-176/+188
2024-01-16remove isForPublish from LookupTopicBrokerschrislu2-286/+274
2024-01-08add batch index for each memory bufferchrislu2-460/+549
2024-01-05subscribe with partition offsetchrislu2-196/+140
2024-01-05rename functionschrislu3-409/+417
2024-01-05add offsetchrislu2-247/+410
2023-12-28subscriber can get assignmentschrislu2-193/+203
2023-12-28subscriber keep connected to the balancerchrislu2-224/+225
2023-12-11Merge accumulated changes related to message queue (#5098)Chris Lu3-1654/+1450
2023-10-12upgrading grpcchrislu15-96/+148
2023-10-12Revert "rename"chrislu5-497/+539
2023-10-12 fix: disallow file name too long when writing a file (#4881)Konstantin Lebedev3-237/+277
2023-10-11renamechrislu5-539/+497
2023-10-09 fix: skipping checking active volumes with the same number of files at the m...Konstantin Lebedev3-866/+934
2023-10-01RetryForever => RetryUntilchrislu1-1/+1
2023-09-30adjust mq.protochrislu3-355/+279
2023-09-30update proto generated fileschrislu7-7/+7
2023-09-30adjust mq protochrislu2-224/+354
2023-09-26rename functionchrislu11-379/+379
2023-09-25[s3acl] Step1: move s3account.AccountManager into to iam.S3ApiConfiguration (...Konstantin Lebedev3-39/+144
2023-09-24create topic and report topicorigin/subchrislu3-396/+564
2023-09-24do create topicchrislu3-387/+569
2023-09-24add CreateTopic APIchrislu3-380/+577
2023-09-19wipchrislu2-427/+531
2023-09-16balancer workschrislu5-518/+708
2023-09-14receive broker statschrislu3-381/+816
2023-09-13Merge branch 'master' into subchrislu6-138/+350
2023-09-06ack intervalchrislu2-132/+143
2023-09-04api for subchrislu2-99/+120
2023-09-01can pub and subchrislu2-159/+296
2023-08-28protoc versionchrislu8-8/+8
2023-08-27rename to lookupchrislu10-494/+402
2023-08-27pub sub initial testschrislu3-115/+108
2023-08-27subchrislu3-194/+143
2023-08-26adjust protochrislu3-164/+653
2023-08-24Implement SRV lookups for filer (#4767)Nico D'Cotta3-0/+135
2023-08-22add stream assign protochrislu3-138/+215
2023-08-20Squashed commit of the following:chrislu3-181/+1424
2023-06-25adjust filer.protochrislu2-10/+10