projects
/
ganeti-local
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Rename OpAssignGroupNodes and LUAssignGroupNodes
[ganeti-local]
/
lib
/
client
/
gnt_cluster.py
diff --git
a/lib/client/gnt_cluster.py
b/lib/client/gnt_cluster.py
index
3f45a5b
..
39c1a4e
100644
(file)
--- a/
lib/client/gnt_cluster.py
+++ b/
lib/client/gnt_cluster.py
@@
-145,7
+145,7
@@
def InitCluster(opts, args):
primary_ip_version=primary_ip_version,
prealloc_wipe_disks=opts.prealloc_wipe_disks,
)
primary_ip_version=primary_ip_version,
prealloc_wipe_disks=opts.prealloc_wipe_disks,
)
- op = opcodes.OpPostInitCluster()
+ op = opcodes.OpClusterPostInit()
SubmitOpCode(op, opts=opts)
return 0
SubmitOpCode(op, opts=opts)
return 0
@@
-198,7
+198,7
@@
def RenameCluster(opts, args):
if not AskUser(usertext):
return 1
if not AskUser(usertext):
return 1
- op = opcodes.OpRenameCluster(name=new_name)
+ op = opcodes.OpClusterRename(name=new_name)
result = SubmitOpCode(op, opts=opts, cl=cl)
if result:
result = SubmitOpCode(op, opts=opts, cl=cl)
if result:
@@
-217,7
+217,7
@@
def RedistributeConfig(opts, args):
@return: the desired exit code
"""
@return: the desired exit code
"""
- op = opcodes.OpRedistributeConfig()
+ op = opcodes.OpClusterRedistConf()
SubmitOrSend(op, opts)
return 0
SubmitOrSend(op, opts)
return 0
@@
-435,7
+435,7
@@
def VerifyCluster(opts, args):
skip_checks = []
if opts.skip_nplusone_mem:
skip_checks.append(constants.VERIFY_NPLUSONE_MEM)
skip_checks = []
if opts.skip_nplusone_mem:
skip_checks.append(constants.VERIFY_NPLUSONE_MEM)
- op = opcodes.OpVerifyCluster(skip_checks=skip_checks,
+ op = opcodes.OpClusterVerify(skip_checks=skip_checks,
verbose=opts.verbose,
error_codes=opts.error_codes,
debug_simulate_errors=opts.simulate_errors)
verbose=opts.verbose,
error_codes=opts.error_codes,
debug_simulate_errors=opts.simulate_errors)
@@
-457,10
+457,10
@@
def VerifyDisks(opts, args):
"""
cl = GetClient()
"""
cl = GetClient()
- op = opcodes.OpVerifyDisks()
+ op = opcodes.OpClusterVerifyDisks()
result = SubmitOpCode(op, opts=opts, cl=cl)
if not isinstance(result, (list, tuple)) or len(result) != 3:
result = SubmitOpCode(op, opts=opts, cl=cl)
if not isinstance(result, (list, tuple)) or len(result) != 3:
- raise errors.ProgrammerError("Unknown result type for OpVerifyDisks")
+ raise errors.ProgrammerError("Unknown result type for OpClusterVerifyDisks")
bad_nodes, instances, missing = result
bad_nodes, instances, missing = result
@@
-520,7
+520,7
@@
def RepairDiskSizes(opts, args):
@return: the desired exit code
"""
@return: the desired exit code
"""
- op = opcodes.OpRepairDiskSizes(instances=args)
+ op = opcodes.OpClusterRepairDiskSizes(instances=args)
SubmitOpCode(op, opts=opts)
SubmitOpCode(op, opts=opts)
@@
-789,7
+789,7
@@
def SetClusterParams(opts, args):
else:
opts.reserved_lvs = utils.UnescapeAndSplit(opts.reserved_lvs, sep=",")
else:
opts.reserved_lvs = utils.UnescapeAndSplit(opts.reserved_lvs, sep=",")
- op = opcodes.OpSetClusterParams(vg_name=vg_name,
+ op = opcodes.OpClusterSetParams(vg_name=vg_name,
drbd_helper=drbd_helper,
enabled_hypervisors=hvlist,
hvparams=hvparams,
drbd_helper=drbd_helper,
enabled_hypervisors=hvlist,
hvparams=hvparams,