def __init__()

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))