noc.core.datastream.client

Module Contents

noc.core.datastream.client.logger
class noc.core.datastream.client.DataStreamClient(name, service=None)

Bases: object

on_change(self, data)

Called on each item received through datastream :param data: :return:

on_delete(self, data)

Called on each deleted item received through datastream :param data: :return:

query(self, change_id=None, filters=None, block=False, limit=None, io_loop=None)

Query datastream :param filters: :return:

resolve(self, host)