kubernetes-sigs
/
kubespray
mirror of https://github.com/kubernetes-sigs/kubespray.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Use kubectl apply instead of create/replace (#1610) 

Disable checks for existing resources to speed up execution.
pull/1624/head
Matthew Mosesohn 2017-09-06 09:36:54 +03:00 committed by GitHub
parent 85c237bc1d
commit 4c88ac69f2
1 changed files with 4 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
library/kube.py
View File

@ -139,7 +139,7 @@ class KubeManager(object):
if check and self.exists(): if check and self.exists():
return [] return []
cmd = ['create'] cmd = ['apply']
if not self.filename: if not self.filename:
self.module.fail_json(msg='filename required to create') self.module.fail_json(msg='filename required to create')
@ -150,10 +150,7 @@ class KubeManager(object):
def replace(self): def replace(self):
if not self.force and not self.exists(): cmd = ['apply']
return []
cmd = ['replace']
if self.force: if self.force:
cmd.append('--force') cmd.append('--force')
@ -271,7 +268,7 @@ def main():
manager = KubeManager(module) manager = KubeManager(module)
state = module.params.get('state') state = module.params.get('state')
if state == 'present': if state == 'present':
result = manager.create() result = manager.create(check=False)
elif state == 'absent': elif state == 'absent':
result = manager.delete() result = manager.delete()
@ -283,11 +280,7 @@ def main():
result = manager.stop() result = manager.stop()
elif state == 'latest': elif state == 'latest':
if manager.exists(): result = manager.replace()
manager.force = True
result = manager.replace()
else:
result = manager.create(check=False)
else: else:
module.fail_json(msg='Unrecognized state %s.' % state) module.fail_json(msg='Unrecognized state %s.' % state)