aboutsummaryrefslogtreecommitdiff
path: root/weed/mq
AgeCommit message (Collapse)AuthorFilesLines
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
* Added global http client * Added Do func for global http client * Changed the code to use the global http client * Fix http client in volume uploader * Fixed pkg name * Fixed http util funcs * Fixed http client for bench_filer_upload * Fixed http client for stress_filer_upload * Fixed http client for filer_server_handlers_proxy * Fixed http client for command_fs_merge_volumes * Fixed http client for command_fs_merge_volumes and command_volume_fsck * Fixed http client for s3api_server * Added init global client for main funcs * Rename global_client to client * Changed: - fixed NewHttpClient; - added CheckIsHttpsClientEnabled func - updated security.toml in scaffold * Reduce the visibility of some functions in the util/http/client pkg * Added the loadSecurityConfig function * Use util.LoadSecurityConfiguration() in NewHttpClient func
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
* Added context for the MasterClient's methods to avoid endless loops * Returned WithClient function. Added WithClientCustomGetMaster function * Hid unused ctx arguments * Using a common context for the KeepConnectedToMaster and WaitUntilConnected functions * Changed the context termination check in the tryConnectToMaster function * Added a child context to the tryConnectToMaster function * Added a common context for KeepConnectedToMaster and WaitUntilConnected functions in benchmark
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
need to ensure the offsets are persisted
2024-05-26add marketchrislu2-0/+449
2024-05-26use type ConsumerGroupInstanceIdchrislu4-13/+13
2024-05-23refactorchrislu2-19/+26
2024-05-23go fmtchrislu5-19/+19
2024-05-23coordinator receives unassignment ackchrislu5-16/+45
2024-05-21renamechrislu10-29/+29
2024-05-21rename filechrislu1-0/+0
2024-05-21rename Coordinator to SubCoordinatorchrislu2-12/+12
2024-05-21rename filechrislu1-0/+0
2024-05-21rename Balancer to PubBalancerchrislu8-21/+21
2024-05-21client side stop partition subscribing if unassignedchrislu2-12/+27
2024-05-21fix compilationchrislu1-7/+2
2024-05-21refactorchrislu3-50/+52
ToDo 1. handle unassignment on client side 2. get notified of completed unassignment 3. in consumer_group.go, balance and send unassignment
2024-05-20avoid concurrent processing for the same keychrislu2-0/+12
2024-05-20refactorchrislu2-104/+112
2024-05-20remove ProcessorConfigurationchrislu5-22/+17
2024-05-20fixchrislu1-0/+3
2024-05-20sending keyed offsetchrislu1-3/+12
2024-05-20minorchrislu1-7/+7
2024-05-20go fmtchrislu15-56/+58
2024-05-20Merge branch 'master' into mqchrislu19-79/+75
2024-05-20go fmtchrislu20-80/+76
2024-05-20adjust logschrislu1-1/+1
2024-05-20track offsetchrislu7-8/+19
2024-05-20add InflightMessageTrackerchrislu2-0/+205
2024-05-19fixchrislu1-1/+1
2024-05-19ConcurrentPartitionLimitchrislu3-15/+23