from o2dms.domain import dms\r
\r
\r
+class NfDeploymentRepository(abc.ABC):\r
+ def __init__(self):\r
+ self.seen = set() # type: Set[dms.NfDeployment]\r
+\r
+ def add(self, nfdeployment: dms.NfDeployment):\r
+ self._add(nfdeployment)\r
+ self.seen.add(nfdeployment)\r
+\r
+ def get(self, nfdeployment_id) -> dms.NfDeployment:\r
+ nfdeployment = self._get(nfdeployment_id)\r
+ if nfdeployment:\r
+ self.seen.add(nfdeployment)\r
+ return nfdeployment\r
+\r
+ def list(self) -> List[dms.NfDeployment]:\r
+ return self._list()\r
+\r
+ def update(self, id, **kwargs):\r
+ self._update(id, **kwargs)\r
+\r
+ def delete(self, nfdeployment_id):\r
+ self._delete(nfdeployment_id)\r
+\r
+ @abc.abstractmethod\r
+ def _add(self, nfdeployment: dms.NfDeployment):\r
+ raise NotImplementedError\r
+\r
+ @abc.abstractmethod\r
+ def _get(self, nfdeployment_id) -> dms.NfDeployment:\r
+ raise NotImplementedError\r
+\r
+ @abc.abstractmethod\r
+ def _update(self, id, **kwargs):\r
+ raise NotImplementedError\r
+\r
+ @abc.abstractmethod\r
+ def _delete(self, nfdeployment_id):\r
+ raise NotImplementedError\r
+\r
+\r
class NfDeploymentDescRepository(abc.ABC):\r
def __init__(self):\r
self.seen = set() # type: Set[dms.NfDeploymentDesc]\r
def list(self) -> List[dms.NfDeploymentDesc]:\r
return self._list()\r
\r
- def update(self, nfdeployment_descriptor: dms.NfDeploymentDesc):\r
- self._update(nfdeployment_descriptor)\r
+ def update(self, id, **kwargs):\r
+ self._update(id, **kwargs)\r
+\r
+ def delete(self, nfdeployment_descriptor_id):\r
+ self._delete(nfdeployment_descriptor_id)\r
\r
@abc.abstractmethod\r
def _add(self, nfdeployment_descriptor: dms.NfDeploymentDesc):\r
raise NotImplementedError\r
\r
@abc.abstractmethod\r
- def _update(self, nfdeployment_descriptor: dms.NfDeploymentDesc):\r
+ def _update(self, id, **kwargs):\r
+ raise NotImplementedError\r
+\r
+ @abc.abstractmethod\r
+ def _delete(self, nfdeployment_descriptor_id):\r
+ raise NotImplementedError\r
+\r
+\r
+class NfOCloudVResourceRepository(abc.ABC):\r
+ def __init__(self):\r
+ self.seen = set() # type: Set[dms.NfOCloudVResource]\r
+\r
+ def add(self, nfocloudvres: dms.NfOCloudVResource):\r
+ self._add(nfocloudvres)\r
+ self.seen.add(nfocloudvres)\r
+\r
+ def get(self, nfocloudvres_id) -> dms.NfOCloudVResource:\r
+ nfocloudvres = self._get(nfocloudvres_id)\r
+ if nfocloudvres:\r
+ self.seen.add(nfocloudvres)\r
+ return nfocloudvres\r
+\r
+ def list(self) -> List[dms.NfOCloudVResource]:\r
+ return self._list()\r
+\r
+ def update(self, nfocloudvres_id, **kwargs):\r
+ self._update(nfocloudvres_id, **kwargs)\r
+\r
+ def delete(self, nfocloudvres_id):\r
+ self._delete(nfocloudvres_id)\r
+\r
+ @abc.abstractmethod\r
+ def _add(self, nfocloudvres: dms.NfOCloudVResource):\r
+ raise NotImplementedError\r
+\r
+ @abc.abstractmethod\r
+ def _get(self, nfocloudvres_id) -> dms.NfOCloudVResource:\r
+ raise NotImplementedError\r
+\r
+ @abc.abstractmethod\r
+ def _update(self, nfocloudvres_id, **kwargs):\r
+ raise NotImplementedError\r
+\r
+ @abc.abstractmethod\r
+ def _delete(self, nfocloudvres_id):\r
raise NotImplementedError\r