| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061 |
- # Copyright 2016 Cloudbase Solutions Srl
- # All Rights Reserved.
- from coriolis.conductor.rpc import client as rpc_conductor_client
- from coriolis.minion_manager.rpc import client as rpc_minion_manager_client
- from coriolis import utils
- class API(object):
- def __init__(self):
- self._rpc_conductor_client = rpc_conductor_client.ConductorClient()
- self._rpc_minion_manager_client = (
- rpc_minion_manager_client.MinionManagerClient())
- def create(self, ctxt, name, endpoint_type, description,
- connection_info, mapped_regions):
- return self._rpc_conductor_client.create_endpoint(
- ctxt, name, endpoint_type, description, connection_info,
- mapped_regions)
- def update(self, ctxt, endpoint_id, properties):
- return self._rpc_conductor_client.update_endpoint(
- ctxt, endpoint_id, properties)
- def delete(self, ctxt, endpoint_id):
- self._rpc_conductor_client.delete_endpoint(ctxt, endpoint_id)
- def get_endpoints(self, ctxt):
- return self._rpc_conductor_client.get_endpoints(ctxt)
- def get_endpoint(self, ctxt, endpoint_id):
- return self._rpc_conductor_client.get_endpoint(ctxt, endpoint_id)
- def validate_connection(self, ctxt, endpoint_id):
- return self._rpc_conductor_client.validate_endpoint_connection(
- ctxt, endpoint_id)
- @utils.bad_request_on_error("Invalid destination environment: %s")
- def validate_target_environment(self, ctxt, endpoint_id, target_env):
- return self._rpc_conductor_client.validate_endpoint_target_environment(
- ctxt, endpoint_id, target_env)
- @utils.bad_request_on_error("Invalid source environment: %s")
- def validate_source_environment(self, ctxt, endpoint_id, source_env):
- return self._rpc_conductor_client.validate_endpoint_source_environment(
- ctxt, endpoint_id, source_env)
- @utils.bad_request_on_error("Invalid source minion pool environment: %s")
- def validate_endpoint_source_minion_pool_options(
- self, ctxt, endpoint_id, pool_environment):
- return (self._rpc_minion_manager_client.
- validate_endpoint_source_minion_pool_options)(
- ctxt, endpoint_id, pool_environment)
- @utils.bad_request_on_error(
- "Invalid destination minion pool environment: %s")
- def validate_endpoint_destination_minion_pool_options(
- self, ctxt, endpoint_id, pool_environment):
- return (self._rpc_minion_manager_client.
- validate_endpoint_destination_minion_pool_options)(
- ctxt, endpoint_id, pool_environment)
|
