aboutsummaryrefslogtreecommitdiff
path: root/weed/mq
AgeCommit message (Expand)AuthorFilesLines
2025-11-29mount: improve read throughput with parallel chunk fetching (#7569)Chris Lu1-1/+1
2025-11-18S3: Directly read write volume servers (#7481)Chris Lu4-28/+34
2025-10-27go fmtchrislu21-221/+200
2025-10-17Clean up logs and deprecated functions (#7339)Chris Lu8-45/+4
2025-10-17Fixes for kafka gateway (#7329)Chris Lu44-2232/+3731
2025-10-13Added bounds checking after calculating startIdx.chrislu1-6/+13
2025-10-13nil checkingchrislu1-0/+18
2025-10-13Add Kafka Gateway (#7231)Chris Lu146-301/+47692
2025-10-08Migrate from deprecated azure-storage-blob-go to modern Azure SDK (#7310)Chris Lu1-1/+0
2025-09-09Message Queue: Add sql querying (#7185)Chris Lu20-75/+1835
2025-08-30S3 API: Advanced IAM System (#7160)Chris Lu5-17/+21
2025-08-06Context cancellation during reading range reading large files (#7093)Chris Lu1-1/+1
2025-07-16convert error fromating to %w everywhere (#6995)Chris Lu17-49/+49
2025-07-11Admin UI: Add message queue to admin UI (#6958)Chris Lu7-28/+445
2025-06-23chore(deps): bump github.com/parquet-go/parquet-go from 0.24.0 to 0.25.1 (#6851)dependabot[bot]2-18/+41
2025-05-28Add context with request (#6824)Aleksey Kosov3-4/+4
2025-05-22added context to filer_client method calls (#6808)Aleksey Kosov4-9/+13
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 Lu25-718/+257
2025-03-04adjust logschrislu1-3/+3
2025-02-25minorchrislu1-1/+2
2025-02-18Delete broker.gochrislu1-12/+0
2025-01-20Add message queue agent (#6463)Chris Lu31-120/+729
2024-12-19"golang.org/x/exp/slices" => "slices" and go fmtchrislu7-22/+22
2024-11-04merge current message queue code changes (#6201)Chris Lu23-189/+916
2024-10-03add helper functionschrislu2-1/+39
2024-08-12fix buildchrislu1-1/+1
2024-08-12fix testschrislu1-52/+6
2024-08-11adds lockingchrislu3-7/+15
2024-08-10refactorchrislu2-4/+7
2024-08-10Merge branch 'master' into mqchrislu6-2/+17
2024-07-16Added tls for http clients (#5766)vadimartynov6-2/+17
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 FilerClientAccessorchrislu4-70/+8
2024-05-30remove per-message debug logschrislu3-6/+5
2024-05-30fix size calculationchrislu2-1/+15
2024-05-30debugchrislu2-2/+6
2024-05-30fix passing sub follower offsetchrislu1-1/+1
2024-05-30fix cases when buffer wraps aroundchrislu2-5/+31
2024-05-30fixchrislu1-1/+0
2024-05-30stop partitionOffsetChan if closedchrislu1-0/+5
2024-05-29skip control messageschrislu2-2/+8
2024-05-29fix inflight message trackerchrislu3-87/+124
2024-05-29passing along publisher namechrislu1-0/+1
2024-05-29avoid nil stopChanchrislu1-2/+3
2024-05-29less logschrislu1-10/+9
2024-05-27balance subscriberschrislu11-146/+141
2024-05-26add marketchrislu2-0/+449
generated by cgit v1.2.3 (git 2.25.1) at 2025-12-21 01:42:28 +0000