examples/allwatcher.py

   1 import asyncio
   2 import logging
   3 logging.basicConfig(level=logging.DEBUG)
   4
   5 from juju.client.connection import Connection
   6 from juju.client import watcher
   7
   8
   9 loop = asyncio.get_event_loop()
  10 conn = loop.run_until_complete(Connection.connect_current())
  11
  12
  13 async def watch():
  14     allwatcher = watcher.AllWatcher()
  15     allwatcher.connect(conn)
  16     while True:
  17         change = await allwatcher.Next()
  18         for delta in change.deltas:
  19             print(delta.deltas)
  20
  21 loop.run_until_complete(watch())