aboutsummaryrefslogtreecommitdiff
AgeCommit message (Expand)AuthorFilesLines
2024-05-30debugchrislu2-2/+6
2024-05-30fix passing sub follower offsetchrislu1-1/+1
2024-05-30fix cases when buffer wraps aroundchrislu2-5/+31
2024-05-30fixchrislu1-1/+0
2024-05-30stop partitionOffsetChan if closedchrislu1-0/+5
2024-05-29skip control messageschrislu2-2/+8
2024-05-29fix inflight message trackerchrislu3-87/+124
2024-05-29passing along publisher namechrislu3-284/+285
2024-05-29avoid nil stopChanchrislu1-2/+3
2024-05-29less logschrislu1-10/+9
2024-05-27balance subscriberschrislu13-597/+686
2024-05-26add marketchrislu2-0/+449
2024-05-26use type ConsumerGroupInstanceIdchrislu4-13/+13
2024-05-24Merge branch 'master' into mqchrislu4-0/+5
2024-05-24avoid ticker leakchrislu4-0/+5
2024-05-23refactorchrislu2-19/+26
2024-05-23go fmtchrislu5-19/+19
2024-05-23Merge branch 'master' into mqchrislu3-16/+15
2024-05-23go fmtchrislu2-15/+14
2024-05-23coordinator receives unassignment ackchrislu7-491/+615
2024-05-23increase helm chart version to include the emptyDir storage feature (#5613)Tomer Eskenazi1-1/+1
2024-05-22Merge branch 'master' into mqchrislu6-15/+75
2024-05-22Helm: Fix warning when providing resource requests/limits for S3 (#5611)Johnny Cederholm1-1/+1
2024-05-22helm chart - add support for emptyDir storage type (#5610)Tomer Eskenazi5-13/+72
2024-05-21fix wrong prefix exampleChris Lu1-1/+1
2024-05-21chore: add missing concurrency help in fs.meta.load command (#5609)Vlad1-0/+1
2024-05-21renamechrislu10-29/+29
2024-05-21rename filechrislu1-0/+0
2024-05-21rename Coordinator to SubCoordinatorchrislu2-12/+12
2024-05-21rename filechrislu1-0/+0
2024-05-21rename Balancer to PubBalancerchrislu8-21/+21
2024-05-21client side stop partition subscribing if unassignedchrislu2-12/+27
2024-05-21fix compilationchrislu1-7/+2
2024-05-21refactorchrislu5-488/+571
2024-05-20avoid concurrent processing for the same keychrislu2-0/+12
2024-05-20refactorchrislu2-104/+112
2024-05-20remove ProcessorConfigurationchrislu5-22/+17
2024-05-20fixchrislu1-0/+3
2024-05-20unusedchrislu2-500/+400
2024-05-20sending keyed offsetchrislu1-3/+12
2024-05-20minorchrislu1-7/+7
2024-05-20go fmtchrislu15-56/+58
2024-05-20Merge branch 'master' into mqchrislu54-1674/+2319
2024-05-20Merge branch 'master' of https://github.com/seaweedfs/seaweedfschrislu29-1580/+2228
2024-05-20go fmtchrislu26-95/+92
2024-05-20adjust logschrislu1-1/+1
2024-05-20track offsetchrislu9-183/+215
2024-05-20add InflightMessageTrackerchrislu2-0/+205
2024-05-20chore(deps): bump github.com/aws/aws-sdk-go from 1.51.30 to 1.53.5 (#5608)dependabot[bot]2-3/+3
2024-05-20chore(deps): bump cloud.google.com/go/storage from 1.40.0 to 1.41.0 (#5607)dependabot[bot]2-6/+8