Enable/disable services/endpoints (bug 1048662)
Change-Id: I664b7f7dfa281a4481bfc37eab0948a901f1c0c5
This commit is contained in:
@@ -29,6 +29,7 @@ class Endpoint(base.Resource):
|
|||||||
* region: geographic location of the endpoint
|
* region: geographic location of the endpoint
|
||||||
* service_id: service to which the endpoint belongs
|
* service_id: service to which the endpoint belongs
|
||||||
* url: fully qualified service endpoint
|
* url: fully qualified service endpoint
|
||||||
|
* enabled: determines whether the endpoint appears in the catalog
|
||||||
|
|
||||||
"""
|
"""
|
||||||
pass
|
pass
|
||||||
@@ -46,34 +47,39 @@ class EndpointManager(base.CrudManager):
|
|||||||
msg = msg % ', '.join(VALID_INTERFACES)
|
msg = msg % ', '.join(VALID_INTERFACES)
|
||||||
raise Exception(msg)
|
raise Exception(msg)
|
||||||
|
|
||||||
def create(self, service, url, name=None, interface=None, region=None):
|
def create(self, service, url, name=None, interface=None, region=None,
|
||||||
|
enabled=True):
|
||||||
self._validate_interface(interface)
|
self._validate_interface(interface)
|
||||||
return super(EndpointManager, self).create(
|
return super(EndpointManager, self).create(
|
||||||
service_id=base.getid(service),
|
service_id=base.getid(service),
|
||||||
interface=interface,
|
interface=interface,
|
||||||
url=url,
|
url=url,
|
||||||
region=region)
|
region=region,
|
||||||
|
enabled=enabled)
|
||||||
|
|
||||||
def get(self, endpoint):
|
def get(self, endpoint):
|
||||||
return super(EndpointManager, self).get(
|
return super(EndpointManager, self).get(
|
||||||
endpoint_id=base.getid(endpoint))
|
endpoint_id=base.getid(endpoint))
|
||||||
|
|
||||||
def list(self, service=None, name=None, interface=None, region=None):
|
def list(self, service=None, name=None, interface=None, region=None,
|
||||||
|
enabled=None):
|
||||||
self._validate_interface(interface)
|
self._validate_interface(interface)
|
||||||
return super(EndpointManager, self).list(
|
return super(EndpointManager, self).list(
|
||||||
service_id=base.getid(service),
|
service_id=base.getid(service),
|
||||||
interface=interface,
|
interface=interface,
|
||||||
region=region)
|
region=region,
|
||||||
|
enabled=enabled)
|
||||||
|
|
||||||
def update(self, endpoint, service=None, url=None, name=None,
|
def update(self, endpoint, service=None, url=None, name=None,
|
||||||
interface=None, region=None):
|
interface=None, region=None, enabled=None):
|
||||||
self._validate_interface(interface)
|
self._validate_interface(interface)
|
||||||
return super(EndpointManager, self).update(
|
return super(EndpointManager, self).update(
|
||||||
endpoint_id=base.getid(endpoint),
|
endpoint_id=base.getid(endpoint),
|
||||||
service_id=base.getid(service),
|
service_id=base.getid(service),
|
||||||
interface=interface,
|
interface=interface,
|
||||||
url=url,
|
url=url,
|
||||||
region=region)
|
region=region,
|
||||||
|
enabled=enabled)
|
||||||
|
|
||||||
def delete(self, endpoint):
|
def delete(self, endpoint):
|
||||||
return super(EndpointManager, self).delete(
|
return super(EndpointManager, self).delete(
|
||||||
|
@@ -24,6 +24,7 @@ class Service(base.Resource):
|
|||||||
* id: a uuid that identifies the service
|
* id: a uuid that identifies the service
|
||||||
* name: user-facing name of the service (e.g. Keystone)
|
* name: user-facing name of the service (e.g. Keystone)
|
||||||
* type: 'compute', 'identity', etc
|
* type: 'compute', 'identity', etc
|
||||||
|
* enabled: determines whether the service appears in the catalog
|
||||||
|
|
||||||
"""
|
"""
|
||||||
pass
|
pass
|
||||||
@@ -35,21 +36,23 @@ class ServiceManager(base.CrudManager):
|
|||||||
collection_key = 'services'
|
collection_key = 'services'
|
||||||
key = 'service'
|
key = 'service'
|
||||||
|
|
||||||
def create(self, name, type, **kwargs):
|
def create(self, name, type, enabled=True, **kwargs):
|
||||||
return super(ServiceManager, self).create(
|
return super(ServiceManager, self).create(
|
||||||
name=name,
|
name=name,
|
||||||
type=type,
|
type=type,
|
||||||
|
enabled=enabled,
|
||||||
**kwargs)
|
**kwargs)
|
||||||
|
|
||||||
def get(self, service):
|
def get(self, service):
|
||||||
return super(ServiceManager, self).get(
|
return super(ServiceManager, self).get(
|
||||||
service_id=base.getid(service))
|
service_id=base.getid(service))
|
||||||
|
|
||||||
def update(self, service, name=None, type=None, **kwargs):
|
def update(self, service, name=None, type=None, enabled=None, **kwargs):
|
||||||
return super(ServiceManager, self).update(
|
return super(ServiceManager, self).update(
|
||||||
service_id=base.getid(service),
|
service_id=base.getid(service),
|
||||||
name=name,
|
name=name,
|
||||||
type=type,
|
type=type,
|
||||||
|
enabled=enabled,
|
||||||
**kwargs)
|
**kwargs)
|
||||||
|
|
||||||
def delete(self, service):
|
def delete(self, service):
|
||||||
|
@@ -19,6 +19,7 @@ class EndpointTests(utils.TestCase, utils.CrudTests):
|
|||||||
kwargs.setdefault('region', uuid.uuid4().hex)
|
kwargs.setdefault('region', uuid.uuid4().hex)
|
||||||
kwargs.setdefault('service_id', uuid.uuid4().hex)
|
kwargs.setdefault('service_id', uuid.uuid4().hex)
|
||||||
kwargs.setdefault('url', uuid.uuid4().hex)
|
kwargs.setdefault('url', uuid.uuid4().hex)
|
||||||
|
kwargs.setdefault('enabled', True)
|
||||||
return kwargs
|
return kwargs
|
||||||
|
|
||||||
def test_create_public_interface(self):
|
def test_create_public_interface(self):
|
||||||
|
@@ -17,4 +17,5 @@ class ServiceTests(utils.TestCase, utils.CrudTests):
|
|||||||
kwargs = super(ServiceTests, self).new_ref(**kwargs)
|
kwargs = super(ServiceTests, self).new_ref(**kwargs)
|
||||||
kwargs.setdefault('name', uuid.uuid4().hex)
|
kwargs.setdefault('name', uuid.uuid4().hex)
|
||||||
kwargs.setdefault('type', uuid.uuid4().hex)
|
kwargs.setdefault('type', uuid.uuid4().hex)
|
||||||
|
kwargs.setdefault('enabled', True)
|
||||||
return kwargs
|
return kwargs
|
||||||
|
Reference in New Issue
Block a user