aboutsummaryrefslogtreecommitdiff
path: root/weed/mq
AgeCommit message (Expand)AuthorFilesLines
2024-01-29re-lock if the lock owner is not foundchrislu1-4/+6
2024-01-28wait 3 seconds before shutting down publish client, to wait for all messages ...chrislu2-12/+29
2024-01-28unused codechrislu1-71/+0
2024-01-28lock for creating local partitionchrislu3-14/+24
2024-01-28read existing topic confchrislu1-4/+5
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-28return the lookup resultschrislu1-0/+1
2024-01-27publish to input bufferchrislu7-134/+103
2024-01-26schedule jobschrislu2-0/+182
2024-01-22when configure, cancel existing assignmentschrislu1-0/+5
2024-01-22sub broker wait for partitionchrislu1-1/+6
2024-01-22pub/sub brokers check filer for assigned partitionschrislu3-33/+31
2024-01-22refactorchrislu2-46/+48
2024-01-22no need to assign partitions explicitlychrislu1-4/+3
2024-01-22updated and added assignmentschrislu2-9/+14
2024-01-22add/remove assigned partitionschrislu4-71/+103
2024-01-22refactorchrislu1-10/+17
2024-01-22refactorchrislu2-157/+165
2024-01-22lookup reads from filer instead of local memorychrislu1-1/+5
2024-01-22separate out read topic conf and ensure topic active assignmentschrislu2-14/+25
2024-01-22pub/sub broker only check local assigned partitionschrislu2-34/+16
2024-01-21fix assignments if brokers changedchrislu2-0/+31
2024-01-21refactorchrislu2-3/+12
2024-01-21refactorchrislu3-33/+52
2024-01-20refactorchrislu3-4/+16
2024-01-20refactorchrislu5-13/+31
2024-01-19renamechrislu1-0/+0
2024-01-17send assignments to newly connected subscriberschrislu2-6/+28
2024-01-17refactorchrislu1-14/+24
2024-01-17create local topic partition from config on filerchrislu4-29/+81
2024-01-16passing partition infochrislu1-10/+2
2024-01-16simplify to LookupTopicPartitions(topic)chrislu3-37/+26
2024-01-16simplify apichrislu3-4/+7
2024-01-16remove isForPublish from LookupTopicBrokerschrislu4-7/+5
2024-01-16release local topic partition if no publisher and subscriberschrislu4-1/+24
2024-01-16renamechrislu1-1/+1
2024-01-16renamechrislu2-2/+2
2024-01-15reuse local partitionchrislu3-10/+14
2024-01-15adjust publisher subscriberchrislu2-6/+10
2024-01-15fix publisherchrislu2-2/+5
2024-01-15read from disk if not in memorychrislu3-33/+175
2024-01-11adjust client side logschrislu1-10/+7
2024-01-11wait on local topic partition creationchrislu1-5/+24
2024-01-11log ctrl messageschrislu1-0/+1
generated by cgit v1.2.3 (git 2.25.1) at 2025-12-27 01:40:42 +0000