12 Commits

Author	SHA1	Message	Date
Daniel García Aubert	36d5dc1719	Queue seeker refactor: ... - Extract from job subcriber everything related to queue dicovering - Job Queue is responsible of queue dicovering and exposes functions to scan user queues. - Batch creates an interval to consume queues - Now Batch.start() does: * Finds existing queues from metadata, adding to queue index the ones that are not indexed yet * Binds callback to process jobs for every queue found. * Inits queue consumer interval * Subscribes to PUB/SUB channel	2017-04-03 19:26:21 +02:00
Daniel García Aubert	8012fe26aa	Avoid scan behaviour to discover active queues of user's jobs, now keeps an index to know which queues are available	2017-03-31 14:30:33 +02:00
Raul Ochoa	1f038ac1f4	Moves from host queues to user queues ... - Existing jobs are moved before start processing them. - Uses a new queue prefix to avoid collisions. - Pub/Sub also changes communication channel. - Job subscriber emits user+host on new jobs. - Batch processor is faulty. See TODO in batch.js.	2016-10-12 21:32:29 +02:00
Raul Ochoa	67566c1d0e	Callback in subscriber unsubscribe errors	2016-10-12 12:29:54 +02:00
Raul Ochoa	c74f9bcce0	More aggressive on seek interval	2016-10-12 12:29:18 +02:00
Raul Ochoa	81393190f7	Add callback to jobseeker result from initial load	2016-10-11 19:59:11 +02:00
Raul Ochoa	8bc52b09cf	Remove console call	2016-10-11 19:46:27 +02:00
Raul Ochoa	dc1a23e886	Add error handler for channel subscriber	2016-10-11 19:45:43 +02:00
Raul Ochoa	2822b68198	onJobHandler receives host with job ... Queue seeker only returns hosts, not mixing responsibilities	2016-10-11 19:45:26 +02:00
Raul Ochoa	611508c654	Hide queue seeker behind job subscriber	2016-10-11 19:01:39 +02:00
Raul Ochoa	e7c4ee32df	Share redis channel config	2016-10-11 18:41:59 +02:00
Raul Ochoa	e4b1711e8e	pub/sub package	2016-10-11 18:28:46 +02:00