[Trivial] Remove two unused methods of PartitionCoordinator

Change-Id: If3993c62e5a4086630d96af27450e9eb43bc393e
This commit is contained in:
liusheng 2016-05-04 10:28:46 +08:00
parent b5ebdaf58d
commit d13f01f0c2

View File

@ -164,15 +164,6 @@ class PartitionCoordinator(object):
LOG.exception(_LE('Error sending a heartbeat to coordination '
'backend.'))
def watch_group(self, namespace, callback):
if self._coordinator:
self._coordinator.watch_join_group(namespace, callback)
self._coordinator.watch_leave_group(namespace, callback)
def run_watchers(self):
if self._coordinator:
self._coordinator.run_watchers()
def join_group(self, group_id):
if (not self._coordinator or not self._coordinator.is_started
or not group_id):