Add get_data_directory function
This commit is contained in:
parent
26a78c0eae
commit
f2f3d3c8e3
3 changed files with 19 additions and 0 deletions
|
@ -135,6 +135,10 @@ class DockerHost(Host):
|
||||||
timeout=service_attributes.start_timeout,
|
timeout=service_attributes.start_timeout,
|
||||||
)
|
)
|
||||||
|
|
||||||
|
def get_data_directory(self, service_name: str) -> str:
|
||||||
|
service_attributes = self._get_service_attributes(service_name)
|
||||||
|
return service_attributes.data_directory_path
|
||||||
|
|
||||||
def delete_metabase(self, service_name: str) -> None:
|
def delete_metabase(self, service_name: str) -> None:
|
||||||
raise NotImplementedError("Not implemented for docker")
|
raise NotImplementedError("Not implemented for docker")
|
||||||
|
|
||||||
|
|
|
@ -112,6 +112,18 @@ class Host(ABC):
|
||||||
service_name: Name of the service to restart.
|
service_name: Name of the service to restart.
|
||||||
"""
|
"""
|
||||||
|
|
||||||
|
|
||||||
|
@abstractmethod
|
||||||
|
def get_data_directory(self, service_name: str) -> str:
|
||||||
|
"""
|
||||||
|
Getting path to data directory on node for further usage
|
||||||
|
(example: list databases pilorama.db)
|
||||||
|
|
||||||
|
Args:
|
||||||
|
service_name: Name of storage node service.
|
||||||
|
"""
|
||||||
|
|
||||||
|
|
||||||
@abstractmethod
|
@abstractmethod
|
||||||
def wait_success_suspend_process(self, process_name: str) -> None:
|
def wait_success_suspend_process(self, process_name: str) -> None:
|
||||||
"""Search for a service ID by its name and stop the process
|
"""Search for a service ID by its name and stop the process
|
||||||
|
|
|
@ -167,6 +167,9 @@ class StorageNode(NodeBase):
|
||||||
|
|
||||||
def get_un_locode(self):
|
def get_un_locode(self):
|
||||||
return self._get_attribute(ConfigAttributes.UN_LOCODE)
|
return self._get_attribute(ConfigAttributes.UN_LOCODE)
|
||||||
|
|
||||||
|
def get_data_directory(self) -> str:
|
||||||
|
return self.host.get_data_directory(self.name)
|
||||||
|
|
||||||
def delete_blobovnicza(self):
|
def delete_blobovnicza(self):
|
||||||
self.host.delete_blobovnicza(self.name)
|
self.host.delete_blobovnicza(self.name)
|
||||||
|
|
Loading…
Reference in a new issue