km3pipe.utils.ligiermirror

Subscribes to given tag(s) and sends them to another Ligier.

Usage:
ligiermirror [options] SOURCE_IP ligiermirror (-h | –help)
Options:
-t TARGET_IP Target IP [default: 127.0.0.1].
-p PORT Source port [default: 5553].
-q PORT Target port [default: 5553].
-m TAGS Comma separated message tags [default: IO_EVT, IO_SUM].
-s QUEUE Maximum queue size for messages [default: 2000].
-x TIMEOUT Connection timeout in seconds [default: 604800].
-d DEBUG_LEVEL Debug level (DEBUG, INFO, WARNING, …) [default: WARNING].

-h –help Show this screen.

Module Contents

Classes

LigierSender() Forwards a message to another ligier

Functions

main() The main script
class km3pipe.utils.ligiermirror.LigierSender[source]

Bases:km3pipe.Module

Forwards a message to another ligier

configure(self)[source]
process(self, blob)[source]
finish(self)[source]
km3pipe.utils.ligiermirror.main()[source]

The main script