in src/dubbo/registry/zookeeper/zk_registry.py [0:0]
def state_changed(self, state: "StateListener.State") -> None:
if state == StateListener.State.LOST:
_LOGGER.warning("Connection lost")
elif state == StateListener.State.CONNECTED:
_LOGGER.info("Connection established")
elif state == StateListener.State.SUSPENDED:
_LOGGER.info("Connection suspended")