aboutsummaryrefslogtreecommitdiff
path: root/weed/mq/client/cmd
AgeCommit message (Collapse)AuthorFilesLines
2024-08-10Merge branch 'master' into mqchrislu4-0/+8
2024-07-16Added tls for http clients (#5766)vadimartynov4-0/+8
* 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-05-23go fmtchrislu2-8/+8
2024-05-20remove ProcessorConfigurationchrislu2-11/+11
2024-05-20go fmtchrislu2-3/+3
2024-05-20Merge branch 'master' into mqchrislu2-2/+2
2024-05-20go fmtchrislu2-2/+2
2024-05-20track offsetchrislu2-2/+3
2024-05-19ConcurrentPartitionLimitchrislu2-4/+4
2024-05-10clean up unused variableschrislu2-2/+0
2024-05-05add delaychrislu1-2/+5
2024-05-02renamechrislu1-4/+4
2024-05-02subscriber can unmarshal the recordchrislu2-4/+94
2024-05-02renamechrislu1-0/+0
2024-05-02rename field typeschrislu1-1/+1
2024-05-02consistent with protobuf data typeschrislu1-8/+8
2024-05-02add example to publish a recordchrislu1-0/+126
2024-05-02renamechrislu1-0/+1
2024-04-15Merge branch 'master' into mq-subscribechrislu1-1/+1
2024-04-14chore: fix some typos in comments (#5497)yudrywet1-1/+1
2024-04-12rename parameterchrislu1-5/+4
2024-03-31send is_close message to brokerchrislu1-0/+3
2024-03-31add publisher name for debuggingchrislu1-3/+7
2024-02-29go fmtchrislu1-2/+2
2024-02-05subscriber find broker leader firstChris Lu1-3/+3
2024-01-28refactorchrislu1-12/+3
2024-01-28refactorchrislu1-2/+4
2024-01-28wait for publishing clientschrislu1-2/+5
2024-01-27publish to input bufferchrislu1-6/+8
currently, the input buffer may not exist when start to publish
2024-01-15adjust publisher subscriberchrislu2-6/+10
2024-01-15fix publisherchrislu1-1/+4
2024-01-08add batch index for each memory bufferchrislu1-2/+5
2024-01-05rename functionschrislu1-0/+1
2024-01-03subscription start from specified timestampchrislu1-1/+1
2024-01-03subscriber can be notified of the assignment change when topic is just ↵chrislu1-2/+2
configured Next: Subscriber needs to read by the timestamp offset.
2023-12-31clean up dead codechrislu1-2/+2
2023-12-28subscriber keep connected to the balancerchrislu1-5/+9
2023-12-11Merge accumulated changes related to message queue (#5098)Chris Lu2-6/+26
* balance partitions on brokers * prepare topic partition first and then publish, move partition * purge unused APIs * clean up * adjust logs * add BalanceTopics() grpc API * configure topic * configure topic command * refactor * repair missing partitions * sequence of operations to ensure ordering * proto to close publishers and consumers * rename file * topic partition versioned by unixTimeNs * create local topic partition * close publishers * randomize the client name * wait until no publishers * logs * close stop publisher channel * send last ack * comments * comment * comments * support list of brokers * add cli options * Update .gitignore * logs * return io.eof directly * refactor * optionally create topic * refactoring * detect consumer disconnection * sub client wait for more messages * subscribe by time stamp * rename * rename to sub_balancer * rename * adjust comments * rename * fix compilation * rename * rename * SubscriberToSubCoordinator * sticky rebalance * go fmt * add tests * balance partitions on brokers * prepare topic partition first and then publish, move partition * purge unused APIs * clean up * adjust logs * add BalanceTopics() grpc API * configure topic * configure topic command * refactor * repair missing partitions * sequence of operations to ensure ordering * proto to close publishers and consumers * rename file * topic partition versioned by unixTimeNs * create local topic partition * close publishers * randomize the client name * wait until no publishers * logs * close stop publisher channel * send last ack * comments * comment * comments * support list of brokers * add cli options * Update .gitignore * logs * return io.eof directly * refactor * optionally create topic * refactoring * detect consumer disconnection * sub client wait for more messages * subscribe by time stamp * rename * rename to sub_balancer * rename * adjust comments * rename * fix compilation * rename * rename * SubscriberToSubCoordinator * sticky rebalance * go fmt * add tests * tracking topic=>broker * merge * comment
2023-10-01refactorchrislu1-5/+1
2023-09-07add publisher shutdownchrislu1-0/+1
2023-09-04api for subchrislu1-9/+23
2023-09-04publish, benchmarkchrislu1-10/+38
2023-09-01can pub and subchrislu1-38/+18
2023-08-28connect and publishchrislu2-0/+79
generated by cgit v1.2.3 (git 2.25.1) at 2025-12-25 16:43:24 +0000