Source code for bspump.abc.sink

from .processor import ProcessorBase



[docs]
class Sink(ProcessorBase):
    """
    Sink is basically a processor. It takes an event sends it to a database where it is stored.

    |

    """


[docs]
    def handle_error(self, context, event, exception, timestamp):
        raise exception