aboutsummaryrefslogtreecommitdiff
path: root/weed/mq/client
AgeCommit message (Expand)AuthorFilesLines
2024-05-20go fmtchrislu4-4/+4
2024-05-05add delaychrislu1-2/+5
2024-05-05reset last errorchrislu1-0/+1
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 recordchrislu2-1/+134
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-12publisher send schemachrislu3-0/+15
2024-04-12rename parameterchrislu3-11/+9
2024-03-31add control message to data messagechrislu2-2/+4
2024-03-31send is_close message to brokerchrislu3-1/+20
2024-03-31add publisher name for debuggingchrislu3-5/+11
2024-03-24setup follower by publisherchrislu1-10/+11
2024-03-21correctly wait for the publisher to finishchrislu1-7/+16
2024-03-20publisher is able to fully send data and receive ackschrislu2-6/+14
2024-03-07adjust errorchrislu1-1/+1
2024-02-29publish init add followerschrislu1-3/+4
2024-02-29go fmtchrislu3-4/+3
2024-02-05subscriber find broker leader firstChris Lu3-28/+37
2024-02-05report EOF errorChris Lu1-2/+2
2024-02-05minorChris Lu1-2/+2
2024-02-05proxy requests to lock ownerChris Lu1-13/+14
2024-01-28wait 3 seconds before shutting down publish client, to wait for all messages ...chrislu1-1/+20
2024-01-28unused codechrislu1-71/+0
2024-01-28wait for each publish clientschrislu1-2/+4
2024-01-28read will block if no itemschrislu1-1/+1
2024-01-28adjust visibilitychrislu2-2/+2
2024-01-28refactorchrislu3-22/+28
2024-01-28refactorchrislu4-31/+19
2024-01-28wait for publishing clientschrislu2-5/+16
2024-01-28clean upchrislu1-9/+0
2024-01-27publish to input bufferchrislu5-132/+99
2024-01-26schedule jobschrislu2-0/+182
2024-01-16remove isForPublish from LookupTopicBrokerschrislu1-2/+0
2024-01-15adjust publisher subscriberchrislu2-6/+10
2024-01-15fix publisherchrislu2-2/+5
2024-01-11adjust client side logschrislu1-10/+7
2024-01-10passing partition generation timestampchrislu2-0/+5
2024-01-08add batch index for each memory bufferchrislu2-3/+7
2024-01-05rename functionschrislu2-3/+3
2024-01-05adjust logschrislu1-2/+2
2024-01-05refactorchrislu1-7/+8
2024-01-05rename functionschrislu1-2/+2
2024-01-05rename functionschrislu1-3/+3
2024-01-05rename functionschrislu2-4/+5