Functions
def	read_option (section, name, conv=None, default=_dummy)

def	get (section, option)

def	getint (section, option)

def	getboolean (section, option)

def	read_and_format_with_env_name (name)

Variables
	config = ConfigParser.RawConfigParser()

	path = os.path.join(_root, os.pardir, 'topology_engine.ini')

	ENVIRONMENT_NAMING_PREFIX = None

def	KAFKA_BOOTSTRAP_SERVERS = _get_bootstrap_servers()

def	KAFKA_FLOW_TOPIC = read_and_format_with_env_name('flow.topic')

def	KAFKA_CACHE_TOPIC = read_and_format_with_env_name('cache.topic')

def	KAFKA_SPEAKER_TOPIC = read_and_format_with_env_name('speaker.topic')

def	KAFKA_TOPO_ENG_TOPIC = read_and_format_with_env_name('topo.eng.topic')

def	KAFKA_NORTHBOUND_TOPIC = read_and_format_with_env_name('northbound.topic')

def	KAFKA_CONSUMER_GROUP = read_and_format_with_env_name('consumer.group')

def	ZOOKEEPER_HOSTS = config.get('zookeeper', 'hosts')

def	NEO4J_SOCKET_TIMEOUT

def	ISL_COST_WHEN_PORT_DOWN

Function Documentation

◆ get()

def topologylistener.config.get	(	section,
		option
	)

Definition at line 43 of file config.py.

◆ getboolean()

def topologylistener.config.getboolean	(	section,
		option
	)

Definition at line 51 of file config.py.

◆ getint()

def topologylistener.config.getint	(	section,
		option
	)

Definition at line 47 of file config.py.

◆ read_and_format_with_env_name()

def topologylistener.config.read_and_format_with_env_name ( name )

Definition at line 69 of file config.py.

◆ read_option()

def topologylistener.config.read_option	(	section,
		name,
		conv = `None`,
		default = `_dummy`
	)

Definition at line 29 of file config.py.

Variable Documentation

◆ config

topologylistener.config.config = ConfigParser.RawConfigParser()

Definition at line 22 of file config.py.

◆ ENVIRONMENT_NAMING_PREFIX

topologylistener.config.ENVIRONMENT_NAMING_PREFIX = None

Definition at line 66 of file config.py.

◆ ISL_COST_WHEN_PORT_DOWN

def topologylistener.config.ISL_COST_WHEN_PORT_DOWN

Initial value:

1 = read_option(

2 'isl', 'cost_when_port_down', conv=int, default=10000)

topologylistener.config.read_option

def read_option(section, name, conv=None, default=_dummy)

Definition: config.py:29

Definition at line 89 of file config.py.

◆ KAFKA_BOOTSTRAP_SERVERS

def topologylistener.config.KAFKA_BOOTSTRAP_SERVERS = _get_bootstrap_servers()

Definition at line 76 of file config.py.

◆ KAFKA_CACHE_TOPIC

def topologylistener.config.KAFKA_CACHE_TOPIC = read_and_format_with_env_name('cache.topic')

Definition at line 78 of file config.py.

◆ KAFKA_CONSUMER_GROUP

def topologylistener.config.KAFKA_CONSUMER_GROUP = read_and_format_with_env_name('consumer.group')

Definition at line 82 of file config.py.

◆ KAFKA_FLOW_TOPIC

def topologylistener.config.KAFKA_FLOW_TOPIC = read_and_format_with_env_name('flow.topic')

Definition at line 77 of file config.py.

◆ KAFKA_NORTHBOUND_TOPIC

def topologylistener.config.KAFKA_NORTHBOUND_TOPIC = read_and_format_with_env_name('northbound.topic')

Definition at line 81 of file config.py.

◆ KAFKA_SPEAKER_TOPIC

def topologylistener.config.KAFKA_SPEAKER_TOPIC = read_and_format_with_env_name('speaker.topic')

Definition at line 79 of file config.py.

◆ KAFKA_TOPO_ENG_TOPIC

def topologylistener.config.KAFKA_TOPO_ENG_TOPIC = read_and_format_with_env_name('topo.eng.topic')

Definition at line 80 of file config.py.

◆ NEO4J_SOCKET_TIMEOUT

def topologylistener.config.NEO4J_SOCKET_TIMEOUT