 |
Open Kilda Java Documentation
|
|
Open Kilda Java Documentation
|
Classes | |
| class | Flow |
| class | Message |
Functions | |
| def | build_ingress_flow (expandedRelationships, src_switch, src_port, src_vlan, bandwidth, transit_vlan, flow_id, outputAction) |
| def | build_egress_flow (expandedRelationships, dst_switch, dst_port, dst_vlan, transit_vlan, flow_id, outputAction) |
| def | build_intermediate_flows (expandedRelationships, transit_vlan, i, flow_id) |
| def | build_one_switch_flow (switch, src_port, src_vlan, dst_port, dst_vlan, bandwidth, flow_id, outputAction) |
| def | build_delete_flow (switch, flow_id) |
| def | expand_relationships (relationships) |
| def | get_relationships (src_switch, src_port, dst_switch, dst_port) |
| def | assign_transit_vlan () |
| def | assign_flow_id () |
| def | assign_meter_id () |
| def | choose_output_action (input_vlan_id, output_vlan_id) |
| def | api_v1_topology_get_one_switch_flows (src_switch, src_port, src_vlan, dst_switch, dst_port, dst_vlan, bandwidth, flow_id) |
| def | api_v1_topology_get_path (src_switch, src_port, src_vlan, dst_switch, dst_port, dst_vlan, bandwidth, transit_vlan, flow_id) |
| def | api_v1_health_check () |
| def | api_v1_flow (flowid) |
| def | api_v1_create_flow () |
| def | api_v1_push_flows () |
Variables | |
| config = ConfigParser.RawConfigParser() | |
| group = config.get('kafka', 'consumer.group') | |
| topic = config.get('kafka', 'kafka.topic.flow') | |
| environment_naming_prefix | |
| bootstrap_servers_property = config.get('kafka', 'bootstrap.servers') | |
| list | bootstrap_servers = [x.strip() for x in bootstrap_servers_property.split(',')] |
| neo4j_connect = neo4j_tools.connect(config) | |
| 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.build_egress_flow | ( | expandedRelationships, | |
| dst_switch, | |||
| dst_port, | |||
| dst_vlan, | |||
| transit_vlan, | |||
| flow_id, | |||
| outputAction | |||
| ) |
| def app.flows.build_ingress_flow | ( | expandedRelationships, | |
| src_switch, | |||
| src_port, | |||
| src_vlan, | |||
| bandwidth, | |||
| 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.choose_output_action | ( | input_vlan_id, | |
| output_vlan_id | |||
| ) |
| def app.flows.get_relationships | ( | src_switch, | |
| src_port, | |||
| dst_switch, | |||
| dst_port | |||
| ) |
| list app.flows.bootstrap_servers = [x.strip() for x in bootstrap_servers_property.split(',')] |
| app.flows.bootstrap_servers_property = config.get('kafka', 'bootstrap.servers') |
| app.flows.environment_naming_prefix |
| string app.flows.group = config.get('kafka', 'consumer.group') |
| app.flows.neo4j_connect = neo4j_tools.connect(config) |
1.8.14