| Age | Commit message (Collapse) | Author | Files | Lines | |
|---|---|---|---|---|---|
| 2024-08-12 | fix build | chrislu | 1 | -1/+1 | |
| 2024-08-12 | fix tests | chrislu | 1 | -52/+6 | |
| 2024-08-11 | adds locking | chrislu | 3 | -7/+15 | |
| 2024-08-10 | refactor | chrislu | 2 | -4/+7 | |
| 2024-08-10 | Merge branch 'master' into mq | chrislu | 6 | -2/+17 | |
| 2024-07-16 | Added tls for http clients (#5766) | vadimartynov | 6 | -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-14 | sort imports | chrislu | 1 | -1/+1 | |
| 2024-06-14 | Merge branch 'master' into mq | chrislu | 1 | -2/+3 | |
| 2024-06-14 | Added context for the MasterClient's methods to avoid endless loops (#5628) | vadimartynov | 1 | -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-06 | refactor out FilerClientAccessor | chrislu | 4 | -70/+8 | |
| 2024-05-30 | remove per-message debug logs | chrislu | 3 | -6/+5 | |
| 2024-05-30 | fix size calculation | chrislu | 2 | -1/+15 | |
| 2024-05-30 | debug | chrislu | 2 | -2/+6 | |
| 2024-05-30 | fix passing sub follower offset | chrislu | 1 | -1/+1 | |
| 2024-05-30 | fix cases when buffer wraps around | chrislu | 2 | -5/+31 | |
| 2024-05-30 | fix | chrislu | 1 | -1/+0 | |
| 2024-05-30 | stop partitionOffsetChan if closed | chrislu | 1 | -0/+5 | |
| 2024-05-29 | skip control messages | chrislu | 2 | -2/+8 | |
| 2024-05-29 | fix inflight message tracker | chrislu | 3 | -87/+124 | |
| 2024-05-29 | passing along publisher name | chrislu | 1 | -0/+1 | |
| 2024-05-29 | avoid nil stopChan | chrislu | 1 | -2/+3 | |
| 2024-05-29 | less logs | chrislu | 1 | -10/+9 | |
| 2024-05-27 | balance subscribers | chrislu | 11 | -146/+141 | |
| need to ensure the offsets are persisted | |||||
| 2024-05-26 | add market | chrislu | 2 | -0/+449 | |
| 2024-05-26 | use type ConsumerGroupInstanceId | chrislu | 4 | -13/+13 | |
| 2024-05-23 | refactor | chrislu | 2 | -19/+26 | |
| 2024-05-23 | go fmt | chrislu | 5 | -19/+19 | |
| 2024-05-23 | coordinator receives unassignment ack | chrislu | 5 | -16/+45 | |
| 2024-05-21 | rename | chrislu | 10 | -29/+29 | |
| 2024-05-21 | rename file | chrislu | 1 | -0/+0 | |
| 2024-05-21 | rename Coordinator to SubCoordinator | chrislu | 2 | -12/+12 | |
| 2024-05-21 | rename file | chrislu | 1 | -0/+0 | |
| 2024-05-21 | rename Balancer to PubBalancer | chrislu | 8 | -21/+21 | |
| 2024-05-21 | client side stop partition subscribing if unassigned | chrislu | 2 | -12/+27 | |
| 2024-05-21 | fix compilation | chrislu | 1 | -7/+2 | |
| 2024-05-21 | refactor | chrislu | 3 | -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-20 | avoid concurrent processing for the same key | chrislu | 2 | -0/+12 | |
| 2024-05-20 | refactor | chrislu | 2 | -104/+112 | |
| 2024-05-20 | remove ProcessorConfiguration | chrislu | 5 | -22/+17 | |
| 2024-05-20 | fix | chrislu | 1 | -0/+3 | |
| 2024-05-20 | sending keyed offset | chrislu | 1 | -3/+12 | |
| 2024-05-20 | minor | chrislu | 1 | -7/+7 | |
| 2024-05-20 | go fmt | chrislu | 15 | -56/+58 | |
| 2024-05-20 | Merge branch 'master' into mq | chrislu | 19 | -79/+75 | |
| 2024-05-20 | go fmt | chrislu | 20 | -80/+76 | |
| 2024-05-20 | adjust logs | chrislu | 1 | -1/+1 | |
| 2024-05-20 | track offset | chrislu | 7 | -8/+19 | |
| 2024-05-20 | add InflightMessageTracker | chrislu | 2 | -0/+205 | |
| 2024-05-19 | fix | chrislu | 1 | -1/+1 | |
| 2024-05-19 | ConcurrentPartitionLimit | chrislu | 3 | -15/+23 | |
