summaryrefslogtreecommitdiff
path: root/trove/taskmanager/manager.py
diff options
context:
space:
mode:
authorMorgan Jones <morgan@parelastic.com>2015-07-20 11:36:57 -0400
committerCraig Vyvial <cp16net@gmail.com>2015-09-04 03:24:20 -0500
commitb3f62412c255ef5e37fc289329c65fc9f067210f (patch)
tree5ac1b6e466a1a88c7da2317809cd5e671bde87dd /trove/taskmanager/manager.py
parentf8f318352729d38a6e70e63a47b919dc9aad95c2 (diff)
downloadtrove-b3f62412c255ef5e37fc289329c65fc9f067210f.tar.gz
Redis Cluster Initial Implementation
Implements support for clustering for the Redis database, including a clustering stategy and guest agent APIs. Includes support for the new cluster scaling methods. Includes unit tests and int-tests (run cluster specific int-tests with "redstack int-tests --group=dbaas.api.redis"). Change-Id: Id701a75b5a8cf1fa2c69f0111ee820021bd16c09 Depends-On: Icc9b4eea8ed7db1455692823d29586088cfc9434 Implements: blueprint redis-cluster
Diffstat (limited to 'trove/taskmanager/manager.py')
-rw-r--r--trove/taskmanager/manager.py8
1 files changed, 8 insertions, 0 deletions
diff --git a/trove/taskmanager/manager.py b/trove/taskmanager/manager.py
index ec96ef22..91e38c32 100644
--- a/trove/taskmanager/manager.py
+++ b/trove/taskmanager/manager.py
@@ -342,6 +342,14 @@ class Manager(periodic_task.PeriodicTasks):
cluster_tasks = models.load_cluster_tasks(context, cluster_id)
cluster_tasks.create_cluster(context, cluster_id)
+ def grow_cluster(self, context, cluster_id, new_instance_ids):
+ cluster_tasks = models.load_cluster_tasks(context, cluster_id)
+ cluster_tasks.grow_cluster(context, cluster_id, new_instance_ids)
+
+ def shrink_cluster(self, context, cluster_id, instance_ids):
+ cluster_tasks = models.load_cluster_tasks(context, cluster_id)
+ cluster_tasks.shrink_cluster(context, cluster_id, instance_ids)
+
def delete_cluster(self, context, cluster_id):
cluster_tasks = models.load_cluster_tasks(context, cluster_id)
cluster_tasks.delete_cluster(context, cluster_id)