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: 20000].

-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(name=None, **parameters)[source]

Forwards a message to another ligier

configure()[source]

Configure module, like instance variables etc.

process(blob)[source]

Knead the blob and return it

finish()[source]

Clean everything up.

km3pipe.utils.ligiermirror.main()[source]

The main script