| Age | Commit message (Collapse) | Author | Files | Lines | |
|---|---|---|---|---|---|
| 2024-08-12 | fix build | chrislu | 1 | -1/+1 | |
| 2024-08-10 | Merge branch 'master' into mq | chrislu | 4 | -0/+8 | |
| 2024-07-16 | Added tls for http clients (#5766) | vadimartynov | 4 | -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-30 | fix | chrislu | 1 | -1/+0 | |
| 2024-05-30 | stop partitionOffsetChan if closed | chrislu | 1 | -0/+5 | |
| 2024-05-29 | skip control messages | chrislu | 1 | -0/+4 | |
| 2024-05-29 | passing along publisher name | chrislu | 1 | -0/+1 | |
| 2024-05-27 | balance subscribers | chrislu | 3 | -2/+10 | |
| need to ensure the offsets are persisted | |||||
| 2024-05-23 | go fmt | chrislu | 4 | -16/+16 | |
| 2024-05-23 | coordinator receives unassignment ack | chrislu | 3 | -15/+33 | |
| 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 | 2 | -32/+37 | |
| 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 | refactor | chrislu | 2 | -104/+112 | |
| 2024-05-20 | remove ProcessorConfiguration | chrislu | 5 | -22/+17 | |
| 2024-05-20 | sending keyed offset | chrislu | 1 | -3/+12 | |
| 2024-05-20 | minor | chrislu | 1 | -7/+7 | |
| 2024-05-20 | go fmt | chrislu | 6 | -27/+26 | |
| 2024-05-20 | Merge branch 'master' into mq | chrislu | 3 | -3/+3 | |
| 2024-05-20 | go fmt | chrislu | 4 | -4/+4 | |
| 2024-05-20 | track offset | chrislu | 5 | -6/+9 | |
| 2024-05-19 | fix | chrislu | 1 | -1/+1 | |
| 2024-05-19 | ConcurrentPartitionLimit | chrislu | 3 | -15/+23 | |
| 2024-05-19 | start consuming ASAP | chrislu | 1 | -1/+1 | |
| 2024-05-19 | persist consumer group offset | chrislu | 3 | -6/+2 | |
| 1. use one follower 2. read write consumer group offset | |||||
| 2024-05-16 | consumer acks received messages | chrislu | 2 | -13/+32 | |
| 2024-05-14 | subscriber receives partitions and dispatch to processors | chrislu | 3 | -36/+94 | |
| 2024-05-13 | consumer instance passing MaxPartitionCount to coordinator | chrislu | 2 | -1/+2 | |
| 2024-05-10 | clean up unused variables | chrislu | 3 | -5/+0 | |
| 2024-05-05 | add delay | chrislu | 1 | -2/+5 | |
| 2024-05-05 | reset last error | chrislu | 1 | -0/+1 | |
| 2024-05-02 | rename | chrislu | 1 | -4/+4 | |
| 2024-05-02 | subscriber can unmarshal the record | chrislu | 2 | -4/+94 | |
| 2024-05-02 | rename | chrislu | 1 | -0/+0 | |
| 2024-05-02 | rename field types | chrislu | 1 | -1/+1 | |
| 2024-05-02 | consistent with protobuf data types | chrislu | 1 | -8/+8 | |
| 2024-05-02 | add example to publish a record | chrislu | 2 | -1/+134 | |
| 2024-05-02 | rename | chrislu | 1 | -0/+1 | |
| 2024-04-15 | Merge branch 'master' into mq-subscribe | chrislu | 1 | -1/+1 | |
| 2024-04-14 | chore: fix some typos in comments (#5497) | yudrywet | 1 | -1/+1 | |
| 2024-04-12 | publisher send schema | chrislu | 3 | -0/+15 | |
| 2024-04-12 | rename parameter | chrislu | 3 | -11/+9 | |
| 2024-03-31 | add control message to data message | chrislu | 2 | -2/+4 | |
| 2024-03-31 | send is_close message to broker | chrislu | 3 | -1/+20 | |
| 2024-03-31 | add publisher name for debugging | chrislu | 3 | -5/+11 | |
| 2024-03-24 | setup follower by publisher | chrislu | 1 | -10/+11 | |
| * the subscriber would getOrGen a local partition and wait * the publisher would getOrGen a local partition. If localPartition follower is not setup, and init message has follower info, it would create followers based on init.Messages. | |||||
| 2024-03-21 | correctly wait for the publisher to finish | chrislu | 1 | -7/+16 | |
| 2024-03-20 | publisher is able to fully send data and receive acks | chrislu | 2 | -6/+14 | |
| still needs to close the pipes cleanly | |||||
| 2024-03-07 | adjust error | chrislu | 1 | -1/+1 | |
| 2024-02-29 | publish init add followers | chrislu | 1 | -3/+4 | |
 |
index : seaweedfs/.git | |
| Unnamed repository; edit this file 'description' to name the repository. | root |
| aboutsummaryrefslogtreecommitdiff |