xCAT/confluent
2
0
Fork 0
mirror of https://github.com/xcat2/confluent.git synced 2025-02-19 12:05:13 +00:00
Code Issues Projects Releases Wiki Activity

Provide deletion of collective member

Browse Source
This commit is contained in:
Jarrod Johnson 2019-10-10 08:50:42 -04:00
parent 8a4a219a14
commit 6ce6740b77
1 changed files with 24 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
confluent_server/confluent/config/configmanager.py
View File

@ -780,6 +780,30 @@ def add_collective_member(name, address, fingerprint):
exec_on_followers('_true_add_collective_member', name, address, fingerprint)
_true_add_collective_member(name, address, fingerprint)
def del_collective_member(name):
if cfgleader:
return exec_on_leader('add_collective_member', name)
if cfgstreams:
exec_on_followers('_true_add_collective_member', name)
_true_del_collective_member(name)
def _true_del_collective_member(name, sync=True):
name = confluent.util.stringify(name)
if _cfgstore is None:
return
if 'collective' not in _cfgstore:
return
if name not in _cfgstore['collective']:
return
del _cfgstore['collective'][name]
with _dirtylock:
if 'collectivedirty' not in _cfgstore:
_cfgstore['collectivedirty'] = set([])
_cfgstore['collectivedirty'].add(name)
if sync:
ConfigManager._bg_sync_to_file()
_pending_collective_updates = {}