Philip O'Toole 9a73d26bfb Implement NodeProcessor ... A NodeProcessor wraps an on-disk queue and the goroutine that attempts to drain that queue and send the data to the associated target node.		2015-10-26 18:59:55 -07:00
..
config.go	Support configurable purge interval	2015-10-26 13:07:25 -07:00
config_test.go	Support configurable purge interval	2015-10-26 13:07:25 -07:00
doc.go	Add hinted handoff queue	2015-06-05 22:16:51 -06:00
limiter.go	Add hinted handoff queue rate limiting	2015-06-09 14:46:13 -06:00
limiter_test.go	Add hinted handoff queue rate limiting	2015-06-09 14:46:13 -06:00
node_processor.go	Implement NodeProcessor	2015-10-26 18:59:55 -07:00
node_processor_test.go	Implement NodeProcessor	2015-10-26 18:59:55 -07:00
queue.go	Implement NodeProcessor	2015-10-26 18:59:55 -07:00
queue_test.go	Fix spelling errors in comments and strings.	2015-06-28 02:54:34 -04:00
service.go	Implement NodeProcessor	2015-10-26 18:59:55 -07:00