ait.core.server.plugins.PacketAccumulator module

class ait.core.server.plugins.PacketAccumulator.PacketAccumulator(inputs=None, outputs=None, zmq_args=None, timer_seconds=1, max_size_octets=1024)

Bases: ait.core.server.plugin.Plugin

__init__(inputs=None, outputs=None, zmq_args=None, timer_seconds=1, max_size_octets=1024)

Constructor

Params:

inputs: names of inbound streams plugin receives data from outputs: names of outbound streams plugin sends its data to zmq_args: dict containing the follow keys:

zmq_context zmq_proxy_xsub_url zmq_proxy_xpub_url

Defaults to empty dict. Default values assigned during instantiation of parent class.

**kwargs: (optional) Dependent on requirements of child class.

emit()

periodic_check()

process(data, topic=None)

Not implemented by base Plugin class. This process method must be implemented by any custom plugin class that inherits from this base Plugin.

Params:

input_data: Message received from any of the plugin’s input streams. topic: Name of stream that message was received from.