in zktraffic/base/util.py [0:0]
def __init__(self, config_string):
"""
:param config_string: str
"""
self.entries = []
empty_matcher = re.compile('^\s*$')
server_matcher = re.compile('server\.(\d+)=(.*)')
version_matcher = re.compile('version=(\d+)')
for line in config_string.splitlines():
if empty_matcher.match(line):
continue
server_m = server_matcher.match(line)
if server_m:
sid = int(server_m.group(1))
address_str = server_m.group(2)
server_ent = QuorumConfig.Server(sid, address_str)
self.entries.append(server_ent)
continue
version_m = version_matcher.match(line)
if version_m:
version = int(version_m.group(1))
version_ent = QuorumConfig.Version(version)
self.entries.append(version_ent)
continue
self.entries.append(QuorumConfig.Unsupported(line))