zio.mains.flow Namespace Reference

Functions
def	cli (ctx)
def	typeit (v)
def	attrify (attrs)
def	test_ruleset (ruleset, verbosity, attrs)
def	file_server (bind, format, name, port, verbosity, ruleset)
def	send_tens (number, connect, shape, verbosity, attrs)
def	recv_tens (number, connect, verbosity, attrs)
def	recv_server (number, bind, shape, verbosity, attrs)

Variables
	log = logging.getLogger("zio")

Function Documentation

attrify()

def zio.mains.flow.attrify

(

attrs

)

Return dictionary of attribute values parsed from list of "k=v" strings.

Definition at line 29 of file flow.py.

cli()

def zio.mains.flow.cli

(

ctx

)

ZIO FLOW command line interface

Definition at line 12 of file flow.py.

file_server()

def zio.mains.flow.file_server	(		bind,
			format,
			name,
			port,
			verbosity,
			ruleset
	)

Source and sink ZIO flow protocol to file

This brings back-end reader and writer handlers to external
clients via the flow broker.  A ruleset factory dynamically spawns
handlers based on incoming BOT flow messages.  The file format
maps to different flavors of handlers.

Definition at line 113 of file flow.py.

recv_server()

def zio.mains.flow.recv_server	(		number,
			bind,
			shape,
			verbosity,
			attrs
	)

A simple server to catch some TENS messages from flow and dump them.

Definition at line 294 of file flow.py.

recv_tens()

def zio.mains.flow.recv_tens	(		number,
			connect,
			verbosity,
			attrs
	)

Client to recv flow of TENS messages.

Definition at line 235 of file flow.py.

send_tens()

def zio.mains.flow.send_tens	(		number,
			connect,
			shape,
			verbosity,
			attrs
	)

Generate and flow some TENS messages.

Definition at line 179 of file flow.py.

test_ruleset()

def zio.mains.flow.test_ruleset	(		ruleset,
			verbosity,
			attrs
	)

Test a rule set by giving attributes as key=value on command line.

Definition at line 49 of file flow.py.

typeit()

def zio.mains.flow.typeit

(

v

)

Definition at line 18 of file flow.py.

Variable Documentation

log

zio.mains.flow.log = logging.getLogger("zio")

Definition at line 8 of file flow.py.