X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=ric_robot_suite%2Fric-python-utils%2Fricutils%2FKubernetesEntity.py;fp=ric_robot_suite%2Fric-python-utils%2Fricutils%2FKubernetesEntity.py;h=049d17df2b1eb39a282a509f00de455f3134a0fa;hb=e96ae18fc88ad2c12b00094a623d426c6f14930d;hp=f4583bcafc0b9fc1b60713ffd2cd09f228df95a5;hpb=cc685917b28444e6e9fc70f1a96b14e073d8cec7;p=it%2Ftest.git

diff --git a/ric_robot_suite/ric-python-utils/ricutils/KubernetesEntity.py b/ric_robot_suite/ric-python-utils/ricutils/KubernetesEntity.py
index f4583bc..049d17d 100644
--- a/ric_robot_suite/ric-python-utils/ricutils/KubernetesEntity.py
+++ b/ric_robot_suite/ric-python-utils/ricutils/KubernetesEntity.py
@@ -48,6 +48,12 @@ class KubernetesEntity(object):
   return self._k8sApp.read_namespaced_deployment(namespace=namespace or self._ns,
                                                  name=name)
 
+ def StatefulSet(self, name, namespace=None):
+  # as above, but for statefulsets, and with the assumption
+  # that the typical check here sfst.replicas == sfst.ready_replicas
+  return self._k8sApp.read_namespaced_stateful_set(namespace = namespace or self._ns,
+                                                   name=name)
+ 
  def Service(self, name, namespace=None):
   # as above, we'll rely on this to throw if the svc dne.