# Endpoint to get operation status
apiUrlStatus = '{}{}{}'.format(self._apiName, self._apiVersion, '/nsi_lcm_op_occs')
# Wait for status for NSI instance creation/update/deletion
# Endpoint to get operation status
apiUrlStatus = '{}{}{}'.format(self._apiName, self._apiVersion, '/nsi_lcm_op_occs')
# Wait for status for NSI instance creation/update/deletion
break
resp = self._http.get_cmd('{}/{}'.format(self._apiBase, nsi_id))
#resp = self._http.get_cmd('{}/{}/nsd_content'.format(self._apiBase, nsi_id))
break
resp = self._http.get_cmd('{}/{}'.format(self._apiBase, nsi_id))
#resp = self._http.get_cmd('{}/{}/nsd_content'.format(self._apiBase, nsi_id))
querystring = '?FORCE=True'
http_code, resp = self._http.delete_cmd('{}/{}{}'.format(self._apiBase,
nsi['_id'], querystring))
querystring = '?FORCE=True'
http_code, resp = self._http.delete_cmd('{}/{}{}'.format(self._apiBase,
nsi['_id'], querystring))
ssh_keys=None, description='default description',
admin_status='ENABLED', wait=False):
ssh_keys=None, description='default description',
admin_status='ENABLED', wait=False):
with open(pubkeyfile, 'r') as f:
nsi['ssh_keys'].append(f.read())
if config:
with open(pubkeyfile, 'r') as f:
nsi['ssh_keys'].append(f.read())
if config:
if "netslice-vld" in nsi_config:
for vld in nsi_config["netslice-vld"]:
if vld.get("vim-network-name"):
if "netslice-vld" in nsi_config:
for vld in nsi_config["netslice-vld"]:
if vld.get("vim-network-name"):
raise ValueError("Error at --config 'additionalParamsForSubnet' items must contain "
"'additionalParamsForNs' and/or 'additionalParamsForVnf'")
raise ValueError("Error at --config 'additionalParamsForSubnet' items must contain "
"'additionalParamsForNs' and/or 'additionalParamsForVnf'")
try:
self._apiResource = '/netslice_instances_content'
self._apiBase = '{}{}{}'.format(self._apiName,
try:
self._apiResource = '/netslice_instances_content'
self._apiBase = '{}{}{}'.format(self._apiName,
self._http.set_http_header(http_header)
http_code, resp = self._http.post_cmd(endpoint=self._apiBase,
postfields_dict=nsi)
self._http.set_http_header(http_header)
http_code, resp = self._http.post_cmd(endpoint=self._apiBase,
postfields_dict=nsi)
if http_code in (200, 201, 202, 204):
if resp:
resp = json.loads(resp)
if http_code in (200, 201, 202, 204):
if resp:
resp = json.loads(resp)
raise ClientException(message)
def list_op(self, name, filter=None):
raise ClientException(message)
def list_op(self, name, filter=None):
raise ClientException(message)
def get_op(self, operationId):
"""Returns the status of an operation
"""
raise ClientException(message)
def get_op(self, operationId):
"""Returns the status of an operation
"""
try:
self._apiResource = '/nsi_lcm_op_occs'
self._apiBase = '{}{}{}'.format(self._apiName,
self._apiVersion, self._apiResource)
http_code, resp = self._http.get2_cmd('{}/{}'.format(self._apiBase, operationId))
try:
self._apiResource = '/nsi_lcm_op_occs'
self._apiBase = '{}{}{}'.format(self._apiName,
self._apiVersion, self._apiResource)
http_code, resp = self._http.get2_cmd('{}/{}'.format(self._apiBase, operationId))
raise ClientException(message)
def exec_op(self, name, op_name, op_data=None):
raise ClientException(message)
def exec_op(self, name, op_name, op_data=None):
self._apiBase = '{}{}{}'.format(self._apiName,
self._apiVersion, self._apiResource)
endpoint = '{}/{}/{}'.format(self._apiBase, nsi['_id'], op_name)
self._apiBase = '{}{}{}'.format(self._apiName,
self._apiVersion, self._apiResource)
endpoint = '{}/{}/{}'.format(self._apiBase, nsi['_id'], op_name)
if http_code in (200, 201, 202, 204):
if resp:
resp = json.loads(resp)
if http_code in (200, 201, 202, 204):
if resp:
resp = json.loads(resp)