]> git.apps.os.sepia.ceph.com Git - ceph-ci.git/commitdiff
mgr/cephadm: Add an event when creating a service
authorSebastian Wagner <sebastian.wagner@suse.com>
Sat, 6 Jun 2020 22:53:34 +0000 (00:53 +0200)
committerSebastian Wagner <sebastian.wagner@suse.com>
Thu, 16 Jul 2020 08:09:08 +0000 (10:09 +0200)
Signed-off-by: Sebastian Wagner <sebastian.wagner@suse.com>
src/pybind/mgr/cephadm/inventory.py
src/pybind/mgr/cephadm/module.py
src/pybind/mgr/cephadm/tests/test_cephadm.py

index 616a303e5f662783392e07893d8da77ba7a4fe90..1f059186b32ba0e8b46a87ed3fac4f8fc0544405 100644 (file)
@@ -136,6 +136,7 @@ class SpecStore():
                 'created': self.spec_created[spec.service_name()].strftime(DATEFMT),
             }, sort_keys=True),
         )
+        self.mgr.events.for_service(spec, OrchestratorEvent.INFO, 'service was created')
 
     def rm(self, service_name):
         # type: (str) -> bool
index 3d96eede9fbf2c75fe01641631272ae78147b86e..e679947d1bb7ad29bb74cff59529591f663035ab 100644 (file)
@@ -1384,6 +1384,7 @@ you may want to run:
                         container_image_id=dd.container_image_id,
                         container_image_name=dd.container_image_name,
                         spec=spec,
+                        events=self.events.get_for_service(spec.service_name()),
                     )
                 if n in self.spec_store.specs:
                     if dd.daemon_type == 'osd':
@@ -1422,6 +1423,7 @@ you may want to run:
                 spec=spec,
                 size=spec.placement.get_host_selection_size(self.inventory.all_specs()),
                 running=0,
+                events=self.events.get_for_service(spec.service_name()),
             )
             if service_type == 'nfs':
                 spec = cast(NFSServiceSpec, spec)
index 1d746fcd4a4066f1619b60e5053bb6f900e462a5..aaa2a86fedf27f1fc381ca7440912c8dfb2c133c 100644 (file)
@@ -133,9 +133,12 @@ class TestCephadm(object):
                     'service_id': 'r.z',
                     'service_name': 'rgw.r.z',
                     'service_type': 'rgw',
-                    'status': {'running': 0, 'size': 1}
+                    'status': {'running': 0, 'size': 1},
                 }
             ]
+            for o in out:
+                if 'events' in o:
+                    del o['events']  # delete it, as it contains a timestamp
             assert out == expected
             assert [ServiceDescription.from_json(o).to_json() for o in expected] == expected