aboutsummaryrefslogtreecommitdiff
path: root/weed/mq
AgeCommit message (Expand)AuthorFilesLines
2024-03-27fixchrislu1-1/+1
2024-03-27refactorchrislu2-45/+54
2024-03-27refactorchrislu2-12/+18
2024-03-27separate goroutine to send ack to publisherchrislu2-55/+40
2024-03-27separate contextchrislu1-1/+1
2024-03-26renamechrislu2-5/+5
2024-03-25adjust logschrislu1-2/+3
2024-03-24close local partition if no more publishers and subscriberschrislu1-29/+28
2024-03-24refactorchrislu2-15/+15
2024-03-24refactorchrislu3-23/+24
2024-03-24setup follower by publisherchrislu7-76/+60
2024-03-21correctly wait for the publisher to finishchrislu1-7/+16
2024-03-20publisher is able to fully send data and receive ackschrislu4-61/+202
2024-03-17remove FollowInMemoryMessageschrislu2-252/+1
2024-03-17loggingchrislu1-0/+1
2024-03-17Merge branch 'master' into mq-subscribechrislu2-48/+0
2024-03-16fix test3chrislu1-47/+0
2024-03-16fix testchrislu1-1/+0
2024-03-16notifychrislu2-11/+22
2024-03-16unnecessarychrislu1-5/+0
2024-03-16add follower id infochrislu1-4/+6
2024-03-16go fmtchrislu6-45/+44
2024-03-15logschrislu1-1/+1
2024-03-15local partition is generated or notchrislu3-10/+11
2024-03-15streaming modechrislu1-1/+1
2024-03-15follower receive a hello message before actual datachrislu2-1/+28
2024-03-15add size()chrislu2-0/+14
2024-03-10ask follower to followchrislu6-33/+293
2024-03-09retry connecting to broker leaderchrislu2-14/+48
2024-03-07change LogBuffer visibility in LocalPartitionchrislu1-9/+9
2024-03-07include key in LogEntrychrislu1-3/+2
2024-03-07each log function adds a "done" return parameterchrislu2-5/+5
2024-03-07adjust errorchrislu1-1/+2
2024-03-07edge cases for broker assignmentchrislu2-9/+23
2024-03-07adjust errorchrislu1-1/+1
2024-03-01handle single broker casechrislu2-2/+37
2024-02-29test low active brokerschrislu2-1/+24
2024-02-29assign followerschrislu3-25/+214
2024-02-29publish init add followerschrislu1-3/+4
2024-02-29go fmtchrislu12-46/+45
2024-02-05subscriber find broker leader firstChris Lu4-38/+43
2024-02-05proxy to broker leaderChris Lu5-22/+5
2024-02-05report EOF errorChris Lu1-2/+2
2024-02-05minorChris Lu1-2/+2
2024-02-05proxy requests to lock ownerChris Lu6-71/+63
2024-02-04fix divide by zeroChris Lu1-7/+11
2024-02-04fix lock TTLChris Lu1-4/+3
2024-02-04avoid too large expiration timeChris Lu1-1/+1
2024-02-02lock returns host and ownerchrislu1-4/+7
2024-02-01use a short-lived lockchrislu1-2/+2