aboutsummaryrefslogtreecommitdiff
path: root/weed/mq/client/cmd
AgeCommit message (Expand)AuthorFilesLines
2024-08-10Merge branch 'master' into mqchrislu4-0/+8
2024-07-16Added tls for http clients (#5766)vadimartynov4-0/+8
2024-05-23go fmtchrislu2-8/+8
2024-05-20remove ProcessorConfigurationchrislu2-11/+11
2024-05-20go fmtchrislu2-3/+3
2024-05-20Merge branch 'master' into mqchrislu2-2/+2
2024-05-20go fmtchrislu2-2/+2
2024-05-20track offsetchrislu2-2/+3
2024-05-19ConcurrentPartitionLimitchrislu2-4/+4
2024-05-10clean up unused variableschrislu2-2/+0
2024-05-05add delaychrislu1-2/+5
2024-05-02renamechrislu1-4/+4
2024-05-02subscriber can unmarshal the recordchrislu2-4/+94
2024-05-02renamechrislu1-0/+0
2024-05-02rename field typeschrislu1-1/+1
2024-05-02consistent with protobuf data typeschrislu1-8/+8
2024-05-02add example to publish a recordchrislu1-0/+126
2024-05-02renamechrislu1-0/+1
2024-04-15Merge branch 'master' into mq-subscribechrislu1-1/+1
2024-04-14chore: fix some typos in comments (#5497)yudrywet1-1/+1
2024-04-12rename parameterchrislu1-5/+4
2024-03-31send is_close message to brokerchrislu1-0/+3
2024-03-31add publisher name for debuggingchrislu1-3/+7
2024-02-29go fmtchrislu1-2/+2
2024-02-05subscriber find broker leader firstChris Lu1-3/+3
2024-01-28refactorchrislu1-12/+3
2024-01-28refactorchrislu1-2/+4
2024-01-28wait for publishing clientschrislu1-2/+5
2024-01-27publish to input bufferchrislu1-6/+8
2024-01-15adjust publisher subscriberchrislu2-6/+10
2024-01-15fix publisherchrislu1-1/+4
2024-01-08add batch index for each memory bufferchrislu1-2/+5
2024-01-05rename functionschrislu1-0/+1
2024-01-03subscription start from specified timestampchrislu1-1/+1
2024-01-03subscriber can be notified of the assignment change when topic is just config...chrislu1-2/+2
2023-12-31clean up dead codechrislu1-2/+2
2023-12-28subscriber keep connected to the balancerchrislu1-5/+9
2023-12-11Merge accumulated changes related to message queue (#5098)Chris Lu2-6/+26
2023-10-01refactorchrislu1-5/+1
2023-09-07add publisher shutdownchrislu1-0/+1
2023-09-04api for subchrislu1-9/+23
2023-09-04publish, benchmarkchrislu1-10/+38
2023-09-01can pub and subchrislu1-38/+18
2023-08-28connect and publishchrislu2-0/+79