def state_changed()

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