aboutsummaryrefslogtreecommitdiff
path: root/weed/pb
AgeCommit message (Expand)AuthorFilesLines
2024-06-19[fs.verify] skip failed files if entry not found on filerStore (#5693)Konstantin Lebedev1-0/+3
2024-06-15optionally skip deleting file chunkschrislu2-209/+221
2024-05-02renamechrislu2-27/+27
2024-05-02rename field typeschrislu2-32/+32
2024-04-27add field indexchrislu2-81/+82
2024-04-18all record fields are optional by defaultchrislu2-70/+81
2024-04-17convert to parquet schema and valuechrislu2-66/+178
2024-04-12add proto for valuechrislu4-507/+841
2024-04-12minorchrislu2-3/+3
2024-04-12all fields are optionalchrislu2-80/+41
2024-04-12add schema.protochrislu3-0/+561
2024-03-31add control message to data messagechrislu2-425/+495
2024-03-31send is_close message to brokerchrislu2-230/+240
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