.
This commit is contained in:
		
							parent
							
								
									9841a665ee
								
							
						
					
					
						commit
						b3b5e2df53
					
				@ -1,17 +0,0 @@
 | 
			
		||||
package observer
 | 
			
		||||
 | 
			
		||||
import "strconv"
 | 
			
		||||
 | 
			
		||||
type KEY int
 | 
			
		||||
func (k KEY) String() string {
 | 
			
		||||
	return strconv.Itoa(int(k))
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
const (
 | 
			
		||||
	ADD_CRAWLER = KEY(iota)
 | 
			
		||||
	REMOVE_CRAWLER
 | 
			
		||||
	DATA_QUEUE
 | 
			
		||||
	EVENT_QUEUE
 | 
			
		||||
)
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
							
								
								
									
										6
									
								
								observer/messages/crawler.go
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										6
									
								
								observer/messages/crawler.go
									
									
									
									
									
										Normal file
									
								
							@ -0,0 +1,6 @@
 | 
			
		||||
package messages
 | 
			
		||||
 | 
			
		||||
const (
 | 
			
		||||
	CRAWLER_ADD = "CRAWLER_ADD"
 | 
			
		||||
	CRAWLER_REMOVE = "CRAWLER_REMOVE"
 | 
			
		||||
)
 | 
			
		||||
							
								
								
									
										7
									
								
								observer/messages/queue.go
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										7
									
								
								observer/messages/queue.go
									
									
									
									
									
										Normal file
									
								
							@ -0,0 +1,7 @@
 | 
			
		||||
package messages
 | 
			
		||||
 | 
			
		||||
const (
 | 
			
		||||
	QUEUE_DATA = "QUEUE_DATA"
 | 
			
		||||
	QUEUE_EVENT = "QUEUE_EVENT"
 | 
			
		||||
)
 | 
			
		||||
 | 
			
		||||
		Loading…
	
	
			
			x
			
			
		
	
		Reference in New Issue
	
	Block a user