flows.py File Reference

Go to the source code of this file.

Classes
class	app.flows.Flow
class	app.flows.Message

Namespaces
	app.flows

Functions
def	app.flows.build_ingress_flow (expandedRelationships, src_switch, src_port, src_vlan, bandwidth, transit_vlan, flow_id, outputAction)
def	app.flows.build_egress_flow (expandedRelationships, dst_switch, dst_port, dst_vlan, transit_vlan, flow_id, outputAction)
def	app.flows.build_intermediate_flows (expandedRelationships, transit_vlan, i, flow_id)
def	app.flows.build_one_switch_flow (switch, src_port, src_vlan, dst_port, dst_vlan, bandwidth, flow_id, outputAction)
def	app.flows.build_delete_flow (switch, flow_id)
def	app.flows.expand_relationships (relationships)
def	app.flows.get_relationships (src_switch, src_port, dst_switch, dst_port)
def	app.flows.assign_transit_vlan ()
def	app.flows.assign_flow_id ()
def	app.flows.assign_meter_id ()
def	app.flows.choose_output_action (input_vlan_id, output_vlan_id)
def	app.flows.api_v1_topology_get_one_switch_flows (src_switch, src_port, src_vlan, dst_switch, dst_port, dst_vlan, bandwidth, flow_id)
def	app.flows.api_v1_topology_get_path (src_switch, src_port, src_vlan, dst_switch, dst_port, dst_vlan, bandwidth, transit_vlan, flow_id)
def	app.flows.api_v1_health_check ()
def	app.flows.api_v1_flow (flowid)
def	app.flows.api_v1_create_flow ()
def	app.flows.api_v1_push_flows ()

Variables
	app.flows.config = ConfigParser.RawConfigParser()
	app.flows.group = config.get('kafka', 'consumer.group')
	app.flows.topic = config.get('kafka', 'kafka.topic.flow')
	app.flows.environment_naming_prefix
	app.flows.bootstrap_servers_property = config.get('kafka', 'bootstrap.servers')
list	app.flows.bootstrap_servers = [x.strip() for x in bootstrap_servers_property.split(',')]
	app.flows.neo4j_connect = neo4j_tools.connect(config)