|  chrislu | 554ae09f82 | rename | 1 year ago | 
				
					
						|  chrislu | faffb2973c | adjust errors | 1 year ago | 
				
					
						|  Chris Lu | 656b78d1af | proxy to broker leader | 2 years ago | 
				
					
						|  chrislu | 2828ccbb30 | refactor | 2 years ago | 
				
					
						|  chrislu | 49428a303b | add batch index for each memory buffer | 2 years ago | 
				
					
						|  chrislu | 093fdc1621 | subscriber can get assignments | 2 years ago | 
				
					
						|  Chris Lu | 580940bf82 | Merge accumulated changes related to message queue (#5098) * 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 | 2 years ago | 
				
					
						|  chrislu | de0b969b36 | Revert "rename" This reverts commit 35b5264ab7. | 2 years ago | 
				
					
						|  chrislu | 35b5264ab7 | rename | 2 years ago | 
				
					
						|  chrislu | 23f334dd13 | comment | 2 years ago | 
				
					
						|  chrislu | c7e05e4e71 | ensure latest stats are reported | 2 years ago | 
				
					
						|  chrislu | dff2ce5d2f | read existing broker stats | 2 years ago | 
				
					
						|  chrislu | 1492bf7552 | fix listing topics | 2 years ago | 
				
					
						|  chrislu | 3cf9b8d621 | create topic and report topic | 2 years ago | 
				
					
						|  chrislu | 6c6655de9d | wip | 2 years ago | 
				
					
						|  chrislu | a65088d739 | broker report stats to balancer | 2 years ago | 
				
					
						|  chrislu | 89a1fd1751 | Squashed commit of the following: commit 4827425146Author: chrislu <chris.lu@gmail.com>
Date:   Sat Sep 16 15:05:38 2023 -0700
    balancer works
commit3b50139f68Author: chrislu <chris.lu@gmail.com>
Date:   Fri Sep 15 22:22:32 2023 -0700
    comments
commit7f685ce7baAuthor: chrislu <chris.lu@gmail.com>
Date:   Fri Sep 15 22:20:05 2023 -0700
    adjust APIs
commit436d99443bAuthor: chrislu <chris.lu@gmail.com>
Date:   Thu Sep 14 23:49:05 2023 -0700
    receive broker stats
commitb771fefa37Merge:0a851ec00890881037Author: chrislu <chris.lu@gmail.com>
Date:   Wed Sep 13 00:03:47 2023 -0700
    Merge branch 'master' into sub
commit0a851ec00bAuthor: chrislu <chris.lu@gmail.com>
Date:   Sun Sep 10 22:01:25 2023 -0700
    Create balancer.go
commit39941edc0bAuthor: chrislu <chris.lu@gmail.com>
Date:   Thu Sep 7 23:55:19 2023 -0700
    add publisher shutdown
commit875f562779Author: chrislu <chris.lu@gmail.com>
Date:   Wed Sep 6 23:16:41 2023 -0700
    server side send response at least once per second
commit984b6c54cfAuthor: chrislu <chris.lu@gmail.com>
Date:   Wed Sep 6 23:15:29 2023 -0700
    ack interval 128
commit2492a45499Author: chrislu <chris.lu@gmail.com>
Date:   Wed Sep 6 22:39:46 2023 -0700
    ack interval
commitba67e6ca29Author: chrislu <chris.lu@gmail.com>
Date:   Mon Sep 4 21:43:50 2023 -0700
    api for sub
commit9e4f985698Author: chrislu <chris.lu@gmail.com>
Date:   Mon Sep 4 21:43:30 2023 -0700
    publish, benchmark
commitcb470d44dfAuthor: chrislu <chris.lu@gmail.com>
Date:   Fri Sep 1 00:36:51 2023 -0700
    can pub and sub
commit1eb2da46d5Author: chrislu <chris.lu@gmail.com>
Date:   Mon Aug 28 09:02:12 2023 -0700
    connect and publish
commit504ae8383aAuthor: chrislu <chris.lu@gmail.com>
Date:   Mon Aug 28 09:01:25 2023 -0700
    protoc version
commitdbcba75271Author: chrislu <chris.lu@gmail.com>
Date:   Sun Aug 27 18:59:04 2023 -0700
    rename to lookup
commitc9caf33119Author: chrislu <chris.lu@gmail.com>
Date:   Sun Aug 27 18:33:46 2023 -0700
    move functions
commit4d6c18d86fAuthor: chrislu <chris.lu@gmail.com>
Date:   Sun Aug 27 17:50:59 2023 -0700
    pub sub initial tests
commit4eb8e8624dAuthor: chrislu <chris.lu@gmail.com>
Date:   Sun Aug 27 13:14:39 2023 -0700
    rename
commit1990456670Author: chrislu <chris.lu@gmail.com>
Date:   Sun Aug 27 13:13:14 2023 -0700
    sub
commit905911853dAuthor: chrislu <chris.lu@gmail.com>
Date:   Sat Aug 26 13:39:21 2023 -0700
    adjust proto | 2 years ago | 
				
					
						|  chrislu | 4827425146 | balancer works | 2 years ago | 
				
					
						|  chrislu | 436d99443b | receive broker stats | 2 years ago |