9dd008f8f1 
								
							
								 
							
						 
						
							
							
								
								add version to filer  
							
							
								
 
							
							
						 
						1 year ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								9dcc576499 
								
							
								 
							
						 
						
							
							
								
								Revert "add collection for buckets"  
							
							
 
							
							
							This reverts commit 96af571219 
							
						 
						1 year ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								96af571219 
								
							
								 
							
						 
						
							
							
								
								add collection for buckets  
							
							
								
 
							
							
						 
						1 year ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								c030cb3ce9 
								
							
								 
							
						 
						
							
							
								
								bootstrap filer from one peer  
							
							
								
 
							
							
						 
						1 year ago  
				
					
						
							
							
								 
						
							
							
								
								
							
							
								
							
								7988ee0805 
								
									
								
							
								 
							
						 
						
							
							
								
								[fs.verify] skip failed files if entry not found on filerStore ( #5693 )  
							
							
								
 
							
							
						 
						1 year ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								464611f614 
								
							
								 
							
						 
						
							
							
								
								optionally skip deleting file chunks  
							
							
								
 
							
							
						 
						1 year ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								7a9b115cc2 
								
							
								 
							
						 
						
							
							
								
								rename  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								f2f4630029 
								
							
								 
							
						 
						
							
							
								
								rename field types  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								111a4e1126 
								
							
								 
							
						 
						
							
							
								
								add field index  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								cc1ce3de87 
								
							
								 
							
						 
						
							
							
								
								all record fields are optional by default  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								0847a17484 
								
							
								 
							
						 
						
							
							
								
								convert to parquet schema and value  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								04fb4c34e3 
								
							
								 
							
						 
						
							
							
								
								add proto for value  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								48fe50df81 
								
							
								 
							
						 
						
							
							
								
								minor  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								0cbf364a3d 
								
							
								 
							
						 
						
							
							
								
								all fields are optional  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								d45a372615 
								
							
								 
							
						 
						
							
							
								
								add schema.proto  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								66a878af39 
								
							
								 
							
						 
						
							
							
								
								add control message to data message  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								546ae87c39 
								
							
								 
							
						 
						
							
							
								
								send is_close message to broker  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								c9df613b6b 
								
							
								 
							
						 
						
							
							
								
								add publisher name for debugging  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								ab9fc0ad70 
								
							
								 
							
						 
						
							
							
								
								simplify  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								205d2285f3 
								
							
								 
							
						 
						
							
							
								
								setup follower by publisher  
							
							
 
							
							
							* 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. 
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								7003ce7425 
								
							
								 
							
						 
						
							
							
								
								publisher is able to fully send data and receive acks  
							
							
 
							
							
							still needs to close the pipes cleanly 
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								516cba7053 
								
							
								 
							
						 
						
							
							
								
								remove FollowInMemoryMessages  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								6f75a0af55 
								
							
								 
							
						 
						
							
							
								
								ask follower to follow  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								28f8f33d6a 
								
							
								 
							
						 
						
							
							
								
								include key in LogEntry  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								7e443ef0a1 
								
							
								 
							
						 
						
							
							
								
								latest protoc-gen-go  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								ead27a4f59 
								
							
								 
							
						 
						
							
							
								
								publish init add followers  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								1b4484bf0a 
								
							
								 
							
						 
						
							
							
								
								go fmt  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								e27deed4bc 
								
							
								 
							
						 
						
							
							
								
								upgrade protoc  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								d41792461c 
								
							
								 
							
						 
						
							
							
								
								lock returns host and owner  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								34a78ffad0 
								
							
								 
							
						 
						
							
							
								
								remove isForPublish from LookupTopicBrokers  
							
							
 
							
							
							also adds a return parameter: whether the topic exists or not 
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								49428a303b 
								
							
								 
							
						 
						
							
							
								
								add batch index for each memory buffer  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								e8611ed85d 
								
							
								 
							
						 
						
							
							
								
								subscribe with partition offset  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								ee41dbb7fc 
								
							
								 
							
						 
						
							
							
								
								rename functions  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								1fed37bed0 
								
							
								 
							
						 
						
							
							
								
								add offset  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								093fdc1621 
								
							
								 
							
						 
						
							
							
								
								subscriber can get assignments  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								c950a40aad 
								
							
								 
							
						 
						
							
							
								
								subscriber keep connected to the balancer  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
								
								
							
							
								
							
								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  
				
					
						
							
							
								 
						
							
							
							
								
							
								deb86ff4a6 
								
							
								 
							
						 
						
							
							
								
								upgrading grpc  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								de0b969b36 
								
							
								 
							
						 
						
							
							
								
								Revert "rename"  
							
							
 
							
							
							This reverts commit 35b5264ab7 
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
								
								
							
							
								
							
								1cac5d983d 
								
									
								
							
								 
							
						 
						
							
							
								
								fix: disallow file name too long when writing a file ( #4881 )  
							
							
 
							
							
							* fix: disallow file name too long when writing a file
* bool LongerName to MaxFilenameLength
---------
Co-authored-by: Konstantin Lebedev <9497591+kmlebedev@users.noreply.github.co> 
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								35b5264ab7 
								
							
								 
							
						 
						
							
							
								
								rename  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
								
								
							
							
								
							
								2b3e39397e 
								
									
								
							
								 
							
						 
						
							
							
								
								fix: skipping checking active volumes with the same number of files at the moment ( #4893 )  
							
							
 
							
							
							* fix: skipping checking active volumes with the same number of files at the moment
 https://github.com/seaweedfs/seaweedfs/issues/4140 
* refactor with comments
https://github.com/seaweedfs/seaweedfs/issues/4140 
* add TestShouldSkipVolume
---------
Co-authored-by: Konstantin Lebedev <9497591+kmlebedev@users.noreply.github.co> 
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								b02fdeabff 
								
							
								 
							
						 
						
							
							
								
								RetryForever => RetryUntil  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								ebd6f96d35 
								
							
								 
							
						 
						
							
							
								
								adjust mq.proto  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								358cba43ef 
								
							
								 
							
						 
						
							
							
								
								update proto generated files  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								d7c211fe8c 
								
							
								 
							
						 
						
							
							
								
								adjust mq proto  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								9d589b48e6 
								
							
								 
							
						 
						
							
							
								
								rename function  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
								
								
							
							
								
							
								f8b94cac0e 
								
									
								
							
								 
							
						 
						
							
							
								
								[s3acl] Step1: move s3account.AccountManager into to iam.S3ApiConfiguration ( #4859 )  
							
							
 
							
							
							* move s3account.AccountManager into to iam.S3ApiConfiguration and switch to Interface
https://github.com/seaweedfs/seaweedfs/issues/4519 
* fix: test bucket acl default and
adjust the variable names
* fix: s3 api config test
---------
Co-authored-by: Konstantin Lebedev <9497591+kmlebedev@users.noreply.github.co>
Co-authored-by: Chris Lu <chrislusf@users.noreply.github.com> 
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								3cf9b8d621 
								
							
								 
							
						 
						
							
							
								
								create topic and report topic  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								b3f94feede 
								
							
								 
							
						 
						
							
							
								
								do create topic  
							
							
								
 
							
							
						 
						2 years ago