X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=juju%2Fcontroller.py;h=b3d2ac103af104b07f35de9bb8b01d6ab44c4f07;hb=07d8f84983e1b97bb01db7c82a8fdbaa90984161;hp=113325e902225b02d807fb09426d088c051e04ad;hpb=efca4234627865400e0d2ab74a0f77bd6988c397;p=osm%2FN2VC.git diff --git a/juju/controller.py b/juju/controller.py index 113325e..b3d2ac1 100644 --- a/juju/controller.py +++ b/juju/controller.py @@ -5,7 +5,6 @@ from . import tag from . import utils from .client import client from .client import connection -from .client import watcher from .model import Model log = logging.getLogger(__name__) @@ -104,8 +103,9 @@ class Controller(object): try: ssh_key = await utils.read_ssh_key(loop=self.loop) await utils.execute_process( - 'juju', 'add-ssh-key', '-m', model_name, ssh_key, log=log) - except Exception as e: + 'juju', 'add-ssh-key', '-m', model_name, ssh_key, log=log, + loop=self.loop) + except Exception: log.exception( "Could not add ssh key to model. You will not be able " "to ssh into machines in this model. " @@ -120,6 +120,7 @@ class Controller(object): self.connection.password, self.connection.cacert, self.connection.macaroons, + loop=self.loop, ) return model @@ -154,7 +155,7 @@ class Controller(object): :param list models: Models to which the user is granted access """ - pass + raise NotImplementedError() def change_user_password(self, username, password): """Change the password for a user in this controller. @@ -163,7 +164,7 @@ class Controller(object): :param str password: New password """ - pass + raise NotImplementedError() def destroy(self, destroy_all_models=False): """Destroy this controller. @@ -172,7 +173,7 @@ class Controller(object): controller. """ - pass + raise NotImplementedError() def disable_user(self, username): """Disable a user. @@ -180,20 +181,20 @@ class Controller(object): :param str username: Username """ - pass + raise NotImplementedError() def enable_user(self): """Re-enable a previously disabled user. """ - pass + raise NotImplementedError() def kill(self): """Forcibly terminate all machines and other associated resources for this controller. """ - pass + raise NotImplementedError() async def get_cloud(self): """ @@ -214,7 +215,7 @@ class Controller(object): :param str username: User for which to list models (admin use only) """ - pass + raise NotImplementedError() def get_payloads(self, *patterns): """Return list of known payloads. @@ -232,7 +233,7 @@ class Controller(object): - payload status """ - pass + raise NotImplementedError() def get_users(self, all_=False): """Return list of users that can connect to this controller. @@ -240,13 +241,13 @@ class Controller(object): :param bool all_: Include disabled users """ - pass + raise NotImplementedError() def login(self): """Log in to this controller. """ - pass + raise NotImplementedError() def logout(self, force=False): """Log out of this controller. @@ -255,7 +256,7 @@ class Controller(object): with a password """ - pass + raise NotImplementedError() def get_model(self, name): """Get a model by name. @@ -263,7 +264,7 @@ class Controller(object): :param str name: Model name """ - pass + raise NotImplementedError() def get_user(self, username): """Get a user by name. @@ -271,4 +272,4 @@ class Controller(object): :param str username: Username """ - pass + raise NotImplementedError()