Method create_cluster

tests/mock_server.py:370–378

(self)

        self._attempt_shutdown()

    def create_cluster(self):
        self._cluster_id = str(uuid4())
        res = self._round_trip_command({
            'type': 'createcluster',
            'id': self._cluster_id
        })
        if res is not None:
            self._connstr = res['connstr']
            self._mgmt_addrs = res['mgmt_addrs']

    def _read_command(self):
        result = self._recv()