topologylistener.messageclasses Namespace Reference

Classes
class	MessageItem

Functions
def	update_config ()
def	read_config ()

Variables
	logger = logging.getLogger(__name__)
	graph = flow_utils.graph
dictionary	switch_states
string	MT_SWITCH = "org.openkilda.messaging.info.event.SwitchInfoData"
string	MT_SWITCH_EXTENDED = "org.openkilda.messaging.info.event.SwitchInfoExtendedData"
string	MT_ISL = "org.openkilda.messaging.info.event.IslInfoData"
string	MT_PORT = "org.openkilda.messaging.info.event.PortInfoData"
string	MT_FLOW_INFODATA = "org.openkilda.messaging.info.flow.FlowInfoData"
string	MT_FLOW_RESPONSE = "org.openkilda.messaging.info.flow.FlowResponse"
string	MT_VALID_REQUEST = "org.openkilda.messaging.command.switches.SwitchRulesValidateRequest"
string	MT_SYNC_REQUEST = "org.openkilda.messaging.command.switches.SwitchRulesSyncRequest"
string	MT_NETWORK = "org.openkilda.messaging.info.discovery.NetworkInfoData"
string	MT_SWITCH_RULES = "org.openkilda.messaging.info.rule.SwitchFlowEntries"
string	MT_STATE_TOGGLE = "org.openkilda.messaging.command.system.FeatureToggleStateRequest"
string	MT_TOGGLE = "org.openkilda.messaging.command.system.FeatureToggleRequest"
tuple	MT_NETWORK_TOPOLOGY_CHANGE
string	CD_NETWORK = "org.openkilda.messaging.command.discovery.NetworkCommandData"
string	CD_FLOWS_SYNC_REQUEST = 'org.openkilda.messaging.command.FlowsSyncRequest'
string	CD_LINK_PROPS_PUT = 'org.openkilda.messaging.te.request.LinkPropsPut'
string	CD_LINK_PROPS_DROP = 'org.openkilda.messaging.te.request.LinkPropsDrop'
string	FEATURE_SYNC_OFRULES = 'sync_rules_on_activation'
string	FEATURE_REROUTE_ON_ISL_DISCOVERY = 'flows_reroute_on_isl_discovery'
string	FEATURE_CREATE_FLOW = 'create_flow'
string	FEATURE_UPDATE_FLOW = 'update_flow'
string	FEATURE_DELETE_FLOW = 'delete_flow'
string	FEATURE_PUSH_FLOW = 'push_flow'
string	FEATURE_UNPUSH_FLOW = 'unpush_flow'
dictionary	features_status
dictionary	features_status_app_to_transport_map
dictionary	features_status_transport_to_app_map
	neo4j_update_lock = threading.RLock()

Function Documentation

read_config()

def topologylistener.messageclasses.read_config

(

)

Definition at line 111 of file messageclasses.py.

update_config()

def topologylistener.messageclasses.update_config

(

)

Definition at line 97 of file messageclasses.py.

Variable Documentation

CD_FLOWS_SYNC_REQUEST

string topologylistener.messageclasses.CD_FLOWS_SYNC_REQUEST = 'org.openkilda.messaging.command.FlowsSyncRequest'

Definition at line 55 of file messageclasses.py.

CD_LINK_PROPS_DROP

string topologylistener.messageclasses.CD_LINK_PROPS_DROP = 'org.openkilda.messaging.te.request.LinkPropsDrop'

Definition at line 57 of file messageclasses.py.

CD_LINK_PROPS_PUT

string topologylistener.messageclasses.CD_LINK_PROPS_PUT = 'org.openkilda.messaging.te.request.LinkPropsPut'

Definition at line 56 of file messageclasses.py.

CD_NETWORK

string topologylistener.messageclasses.CD_NETWORK = "org.openkilda.messaging.command.discovery.NetworkCommandData"

Definition at line 54 of file messageclasses.py.

FEATURE_CREATE_FLOW

string topologylistener.messageclasses.FEATURE_CREATE_FLOW = 'create_flow'

Definition at line 61 of file messageclasses.py.

FEATURE_DELETE_FLOW

string topologylistener.messageclasses.FEATURE_DELETE_FLOW = 'delete_flow'

Definition at line 63 of file messageclasses.py.

FEATURE_PUSH_FLOW

string topologylistener.messageclasses.FEATURE_PUSH_FLOW = 'push_flow'

Definition at line 64 of file messageclasses.py.

FEATURE_REROUTE_ON_ISL_DISCOVERY

string topologylistener.messageclasses.FEATURE_REROUTE_ON_ISL_DISCOVERY = 'flows_reroute_on_isl_discovery'

Definition at line 60 of file messageclasses.py.

FEATURE_SYNC_OFRULES

string topologylistener.messageclasses.FEATURE_SYNC_OFRULES = 'sync_rules_on_activation'

Definition at line 59 of file messageclasses.py.

FEATURE_UNPUSH_FLOW

string topologylistener.messageclasses.FEATURE_UNPUSH_FLOW = 'unpush_flow'

Definition at line 65 of file messageclasses.py.

FEATURE_UPDATE_FLOW

string topologylistener.messageclasses.FEATURE_UPDATE_FLOW = 'update_flow'

Definition at line 62 of file messageclasses.py.

features_status

dictionary topologylistener.messageclasses.features_status

Initial value:

=  {
    FEATURE_SYNC_OFRULES: False,
    FEATURE_REROUTE_ON_ISL_DISCOVERY: True,
    FEATURE_CREATE_FLOW: False,
    FEATURE_UPDATE_FLOW: False,
    FEATURE_DELETE_FLOW: False,
    FEATURE_PUSH_FLOW:   False,
    FEATURE_UNPUSH_FLOW: False,
}

Definition at line 67 of file messageclasses.py.

features_status_app_to_transport_map

dictionary topologylistener.messageclasses.features_status_app_to_transport_map

Initial value:

=  {
    FEATURE_SYNC_OFRULES: 'sync_rules',
    FEATURE_REROUTE_ON_ISL_DISCOVERY: 'reflow_on_switch_activation',
    FEATURE_CREATE_FLOW: 'create_flow',
    FEATURE_UPDATE_FLOW: 'update_flow',
    FEATURE_DELETE_FLOW: 'delete_flow',
    FEATURE_PUSH_FLOW: 'push_flow',
    FEATURE_UNPUSH_FLOW: 'unpush_flow'
}

Definition at line 77 of file messageclasses.py.

features_status_transport_to_app_map

dictionary topologylistener.messageclasses.features_status_transport_to_app_map

Initial value:

=  {
    transport: app
    for app, transport in features_status_app_to_transport_map.items()}

Definition at line 87 of file messageclasses.py.

graph

topologylistener.messageclasses.graph = flow_utils.graph

Definition at line 32 of file messageclasses.py.

logger

topologylistener.messageclasses.logger = logging.getLogger(__name__)

Definition at line 31 of file messageclasses.py.

MT_FLOW_INFODATA

string topologylistener.messageclasses.MT_FLOW_INFODATA = "org.openkilda.messaging.info.flow.FlowInfoData"

Definition at line 43 of file messageclasses.py.

MT_FLOW_RESPONSE

string topologylistener.messageclasses.MT_FLOW_RESPONSE = "org.openkilda.messaging.info.flow.FlowResponse"

Definition at line 44 of file messageclasses.py.

MT_ISL

string topologylistener.messageclasses.MT_ISL = "org.openkilda.messaging.info.event.IslInfoData"

Definition at line 41 of file messageclasses.py.

MT_NETWORK

string topologylistener.messageclasses.MT_NETWORK = "org.openkilda.messaging.info.discovery.NetworkInfoData"

Definition at line 47 of file messageclasses.py.

MT_NETWORK_TOPOLOGY_CHANGE

tuple topologylistener.messageclasses.MT_NETWORK_TOPOLOGY_CHANGE

Initial value:

=  (
    "org.openkilda.messaging.info.event.NetworkTopologyChange")

Definition at line 52 of file messageclasses.py.

MT_PORT

string topologylistener.messageclasses.MT_PORT = "org.openkilda.messaging.info.event.PortInfoData"

Definition at line 42 of file messageclasses.py.

MT_STATE_TOGGLE

string topologylistener.messageclasses.MT_STATE_TOGGLE = "org.openkilda.messaging.command.system.FeatureToggleStateRequest"

Definition at line 50 of file messageclasses.py.

MT_SWITCH

string topologylistener.messageclasses.MT_SWITCH = "org.openkilda.messaging.info.event.SwitchInfoData"

Definition at line 39 of file messageclasses.py.

MT_SWITCH_EXTENDED

string topologylistener.messageclasses.MT_SWITCH_EXTENDED = "org.openkilda.messaging.info.event.SwitchInfoExtendedData"

Definition at line 40 of file messageclasses.py.

MT_SWITCH_RULES

string topologylistener.messageclasses.MT_SWITCH_RULES = "org.openkilda.messaging.info.rule.SwitchFlowEntries"

Definition at line 48 of file messageclasses.py.

MT_SYNC_REQUEST

string topologylistener.messageclasses.MT_SYNC_REQUEST = "org.openkilda.messaging.command.switches.SwitchRulesSyncRequest"

Definition at line 46 of file messageclasses.py.

MT_TOGGLE

string topologylistener.messageclasses.MT_TOGGLE = "org.openkilda.messaging.command.system.FeatureToggleRequest"

Definition at line 51 of file messageclasses.py.

MT_VALID_REQUEST

string topologylistener.messageclasses.MT_VALID_REQUEST = "org.openkilda.messaging.command.switches.SwitchRulesValidateRequest"

Definition at line 45 of file messageclasses.py.

neo4j_update_lock

topologylistener.messageclasses.neo4j_update_lock = threading.RLock()

Definition at line 94 of file messageclasses.py.

switch_states

dictionary topologylistener.messageclasses.switch_states

Initial value:

=  {
    'active': 'ACTIVATED',
    'inactive': 'DEACTIVATED',
    'removed': 'REMOVED'
}

Definition at line 33 of file messageclasses.py.