import sys
DEFAULT_HANDLERS = [
- 'londiste.handlers.bulk',
'londiste.handlers.qtable',
- 'londiste.handlers.dispatch',
'londiste.handlers.applyfn',
'londiste.handlers.part',
'londiste.handlers.multimaster',
+ 'londiste.handlers.vtable',
+
+ 'londiste.handlers.bulk',
+ 'londiste.handlers.dispatch',
]
def handler_args(name, cls):
import pgq
-__all__ = ['QueueTableHandler', 'FakeLocalHandler', 'QueueSplitterHandler']
+__all__ = ['QueueTableHandler', 'QueueSplitterHandler']
class QueueTableHandler(BaseHandler):
def needs_table(self):
return False
-class FakeLocalHandler(BaseHandler):
- handler_name = 'fake_local'
-
- def add(self, trigger_arg_list):
- trigger_arg_list.append('virtual_table')
-
- def needs_table(self):
- return False
-
-
-
class QueueSplitterHandler(BaseHandler):
handler_name = 'qsplitter'
return False
-__londiste_handlers__ = [QueueTableHandler, FakeLocalHandler,
- QueueSplitterHandler]
+__londiste_handlers__ = [QueueTableHandler, QueueSplitterHandler]
--- /dev/null
+"""Virtual Table.
+"""
+
+from londiste.handler import BaseHandler
+
+__all__ = ['VirtualTableHandler', 'FakeLocalHandler']
+
+class VirtualTableHandler(BaseHandler):
+ """Virtual Table.
+
+ """
+ handler_name = 'vtable'
+
+ def add(self, trigger_arg_list):
+ trigger_arg_list.append('virtual_table')
+
+ def needs_table(self):
+ return False
+
+class FakeLocalHandler(VirtualTableHandler):
+ """Deprecated compat name for vtable."""
+ handler_name = 'fake_local'
+
+__londiste_handlers__ = [VirtualTableHandler, FakeLocalHandler]
+