aboutsummaryrefslogtreecommitdiff
path: root/weed/mq/client/pub_client/scheduler.go
AgeCommit message (Expand)AuthorFilesLines
2024-05-20go fmtchrislu1-5/+5
2024-05-19persist consumer group offsetchrislu1-1/+1
2024-05-05reset last errorchrislu1-0/+1
2024-04-12publisher send schemachrislu1-0/+1
2024-04-12rename parameterchrislu1-1/+1
2024-03-31add control message to data messagechrislu1-1/+1
2024-03-31send is_close message to brokerchrislu1-1/+4
2024-03-31add publisher name for debuggingchrislu1-2/+3
2024-03-21correctly wait for the publisher to finishchrislu1-7/+16
2024-03-20publisher is able to fully send data and receive ackschrislu1-6/+12
2024-03-07adjust errorchrislu1-1/+1
2024-02-29publish init add followerschrislu1-3/+4
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-28read will block if no itemschrislu1-1/+1
2024-01-28adjust visibilitychrislu1-1/+1
2024-01-28refactorchrislu1-9/+9
2024-01-28refactorchrislu1-20/+11
2024-01-28wait for publishing clientschrislu1-3/+11
2024-01-27publish to input bufferchrislu1-1/+73
2024-01-26schedule jobschrislu1-0/+181