aboutsummaryrefslogtreecommitdiff
path: root/weed/mq/broker
AgeCommit message (Expand)AuthorFilesLines
2025-07-16convert error fromating to %w everywhere (#6995)Chris Lu6-11/+11
2025-07-11Admin UI: Add message queue to admin UI (#6958)Chris Lu4-23/+275
2025-05-22added context to filer_client method calls (#6808)Aleksey Kosov1-2/+3
2025-03-31chore(deps): bump gocloud.dev from 0.40.0 to 0.41.0 (#6679)dependabot[bot]2-2/+4
2025-03-09Accumulated changes for message queue (#6600)Chris Lu1-7/+39
2025-02-25minorchrislu1-1/+2
2025-01-20Add message queue agent (#6463)Chris Lu4-9/+8
2024-11-04merge current message queue code changes (#6201)Chris Lu6-150/+11
2024-08-11adds lockingchrislu1-3/+0
2024-08-10Merge branch 'master' into mqchrislu2-2/+9
2024-07-16Added tls for http clients (#5766)vadimartynov2-2/+9
2024-06-14sort importschrislu1-1/+1
2024-06-14Merge branch 'master' into mqchrislu1-2/+3
2024-06-14Added context for the MasterClient's methods to avoid endless loops (#5628)vadimartynov1-2/+3
2024-06-06refactor out FilerClientAccessorchrislu1-2/+3
2024-05-30remove per-message debug logschrislu2-3/+3
2024-05-30debugchrislu2-2/+6
2024-05-30fix passing sub follower offsetchrislu1-1/+1
2024-05-29skip control messageschrislu1-2/+4
2024-05-29fix inflight message trackerchrislu1-13/+18
2024-05-27balance subscriberschrislu3-5/+16
2024-05-23go fmtchrislu1-3/+3
2024-05-23coordinator receives unassignment ackchrislu1-1/+6
2024-05-21renamechrislu8-27/+27
2024-05-21rename Coordinator to SubCoordinatorchrislu1-1/+1
2024-05-21rename Balancer to PubBalancerchrislu1-1/+1
2024-05-20avoid concurrent processing for the same keychrislu1-0/+4
2024-05-20fixchrislu1-0/+3
2024-05-20go fmtchrislu3-8/+6
2024-05-20Merge branch 'master' into mqchrislu4-10/+7
2024-05-20go fmtchrislu4-10/+7
2024-05-20adjust logschrislu1-1/+1
2024-05-20track offsetchrislu1-2/+6
2024-05-19less logschrislu1-1/+1
2024-05-19logschrislu1-1/+1
2024-05-19persist consumer group offsetchrislu5-31/+113
2024-05-17add subscribe followerchrislu2-0/+86
2024-05-16consumer acks received messageschrislu2-8/+25
2024-05-16adjust errorschrislu2-4/+5
2024-05-14move initial assignment to rebalance logicchrislu2-15/+7
2024-05-14move read write topic config into filer client accessorchrislu4-53/+13
2024-05-13refactorchrislu1-2/+2
2024-04-12save schema when configuring topicchrislu1-0/+10
2024-04-02refactorchrislu1-1/+1
2024-04-02comment out printlnchrislu2-7/+4
2024-04-01shutdown follower when leader stopschrislu1-6/+107
2024-04-01send flush message to follower before shutting down logBufferchrislu2-0/+14
2024-04-01renamingchrislu4-7/+7
2024-03-31add control message to data messagechrislu1-0/+3
2024-03-31add publisher name for debuggingchrislu1-4/+4
generated by cgit v1.2.3 (git 2.25.1) at 2025-12-24 22:26:14 +0000