d218fe54fa 
								
							
								 
							
						 
						
							
							
								
								go fmt  
							
							
								
 
							
							
						 
						1 year ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								664b704e30 
								
							
								 
							
						 
						
							
							
								
								add delay  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								4e3701df77 
								
							
								 
							
						 
						
							
							
								
								reset last error  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								7a9b115cc2 
								
							
								 
							
						 
						
							
							
								
								rename  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								4a3e8869bb 
								
							
								 
							
						 
						
							
							
								
								subscriber can unmarshal the record  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								1c5043baf7 
								
							
								 
							
						 
						
							
							
								
								rename  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								f2f4630029 
								
							
								 
							
						 
						
							
							
								
								rename field types  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								b8af997e41 
								
							
								 
							
						 
						
							
							
								
								consistent with protobuf data types  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								0f35b3a4ea 
								
							
								 
							
						 
						
							
							
								
								add example to publish a record  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								928a4e8dff 
								
							
								 
							
						 
						
							
							
								
								rename  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
								
								
							
							
								
							
								8833745fbc 
								
									
								
							
								 
							
						 
						
							
							
								
								chore: fix some typos in comments ( #5497 )  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								68ade92d4f 
								
							
								 
							
						 
						
							
							
								
								publisher send schema  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								5324e4288a 
								
							
								 
							
						 
						
							
							
								
								rename parameter  
							
							
								
 
							
							
						 
						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  
				
					
						
							
							
								 
						
							
							
							
								
							
								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  
				
					
						
							
							
								 
						
							
							
							
								
							
								da31e9b939 
								
							
								 
							
						 
						
							
							
								
								correctly wait for the publisher to finish  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								7003ce7425 
								
							
								 
							
						 
						
							
							
								
								publisher is able to fully send data and receive acks  
							
							
 
							
							
							still needs to close the pipes cleanly 
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								33ab6cfcf7 
								
							
								 
							
						 
						
							
							
								
								adjust error  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								ead27a4f59 
								
							
								 
							
						 
						
							
							
								
								publish init add followers  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								1b4484bf0a 
								
							
								 
							
						 
						
							
							
								
								go fmt  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								16b4f9d9ab 
								
							
								 
							
						 
						
							
							
								
								subscriber find broker leader first  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								90fcde0e26 
								
							
								 
							
						 
						
							
							
								
								report EOF error  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								07028a4864 
								
							
								 
							
						 
						
							
							
								
								minor  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								4dc6681833 
								
							
								 
							
						 
						
							
							
								
								proxy requests to lock owner  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								0b2e5ddc7c 
								
							
								 
							
						 
						
							
							
								
								wait 3 seconds before shutting down publish client, to wait for all messages to be received  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								545d5fbdf6 
								
							
								 
							
						 
						
							
							
								
								unused code  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								a297247137 
								
							
								 
							
						 
						
							
							
								
								wait for each publish clients  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								b6c5e57c30 
								
							
								 
							
						 
						
							
							
								
								read will block if no items  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								0bf5424a2e 
								
							
								 
							
						 
						
							
							
								
								adjust visibility  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								dedfd31dfb 
								
							
								 
							
						 
						
							
							
								
								refactor  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								cbf750a31f 
								
							
								 
							
						 
						
							
							
								
								refactor  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								b51dfe2bff 
								
							
								 
							
						 
						
							
							
								
								wait for publishing clients  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								f8c55f101e 
								
							
								 
							
						 
						
							
							
								
								clean up  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								841fafd0a8 
								
							
								 
							
						 
						
							
							
								
								publish to input buffer  
							
							
 
							
							
							currently, the input buffer may not exist when start to publish 
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								91af1f3069 
								
							
								 
							
						 
						
							
							
								
								schedule jobs  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								34a78ffad0 
								
							
								 
							
						 
						
							
							
								
								remove isForPublish from LookupTopicBrokers  
							
							
 
							
							
							also adds a return parameter: whether the topic exists or not 
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								7e6497cc1c 
								
							
								 
							
						 
						
							
							
								
								adjust publisher subscriber  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								026c54a9bb 
								
							
								 
							
						 
						
							
							
								
								fix publisher  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								3aa3991f0f 
								
							
								 
							
						 
						
							
							
								
								adjust client side logs  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								6a7a679137 
								
							
								 
							
						 
						
							
							
								
								passing partition generation timestamp  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								49428a303b 
								
							
								 
							
						 
						
							
							
								
								add batch index for each memory buffer  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								d0d24f1e40 
								
							
								 
							
						 
						
							
							
								
								rename functions  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								aa5b6a8187 
								
							
								 
							
						 
						
							
							
								
								adjust logs  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								496fc8fbbf 
								
							
								 
							
						 
						
							
							
								
								refactor  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								531f854af2 
								
							
								 
							
						 
						
							
							
								
								rename functions  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								f8787a9761 
								
							
								 
							
						 
						
							
							
								
								rename functions  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								ddd0fde094 
								
							
								 
							
						 
						
							
							
								
								rename functions  
							
							
								
 
							
							
						 
						2 years ago  
				
					
						
							
							
								 
						
							
							
							
								
							
								ee41dbb7fc 
								
							
								 
							
						 
						
							
							
								
								rename functions  
							
							
								
 
							
							
						 
						2 years ago