github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-10 04:27:54 +00:00
Code Issues Projects Releases Wiki Activity

Removing cadvisor and normalizing python quotes.

Browse Source
This commit is contained in:
Matt Bruzek 2015-04-21 16:46:21 -05:00
parent c1a56187b8
commit 60e0a77a0c
1 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
cluster/juju/charms/trusty/kubernetes/hooks/hooks.py
View File

@ -71,21 +71,21 @@ def relation_changed():
# Check required keys # Check required keys
for k in ('etcd_servers', 'kubeapi_server'): for k in ('etcd_servers', 'kubeapi_server'):
if not template_data.get(k): if not template_data.get(k):
print("Missing data for %s %s" % (k, template_data)) print('Missing data for %s %s' % (k, template_data))
return return
print("Running with\n%s" % template_data) print('Running with\n%s' % template_data)
# Setup kubernetes supplemental group # Setup kubernetes supplemental group
setup_kubernetes_group() setup_kubernetes_group()
# Register upstart managed services # Register upstart managed services
for n in ("cadvisor", "kubelet", "proxy"): for n in ('kubelet', 'proxy'):
if render_upstart(n, template_data) or not host.service_running(n): if render_upstart(n, template_data) or not host.service_running(n):
print("Starting %s" % n) print('Starting %s' % n)
host.service_restart(n) host.service_restart(n)
# Register machine via api # Register machine via api
print("Registering machine") print('Registering machine')
register_machine(template_data['kubeapi_server']) register_machine(template_data['kubeapi_server'])
# Save the marker (for restarts to detect prev install) # Save the marker (for restarts to detect prev install)
@ -95,7 +95,7 @@ def relation_changed():
def get_template_data(): def get_template_data():
rels = hookenv.relations() rels = hookenv.relations()
template_data = hookenv.Config() template_data = hookenv.Config()
template_data.CONFIG_FILE_NAME = ".unit-state" template_data.CONFIG_FILE_NAME = '.unit-state'
overlay_type = get_scoped_rel_attr('network', rels, 'overlay_type') overlay_type = get_scoped_rel_attr('network', rels, 'overlay_type')
etcd_servers = get_rel_hosts('etcd', rels, ('hostname', 'port')) etcd_servers = get_rel_hosts('etcd', rels, ('hostname', 'port'))
@ -104,7 +104,7 @@ def get_template_data():
# kubernetes master isn't ha yet. # kubernetes master isn't ha yet.
if api_servers: if api_servers:
api_info = api_servers.pop() api_info = api_servers.pop()
api_servers = "http://%s:%s" % (api_info[0], api_info[1]) api_servers = 'http://%s:%s' % (api_info[0], api_info[1])
template_data['overlay_type'] = overlay_type template_data['overlay_type'] = overlay_type
template_data['kubelet_bind_addr'] = _bind_addr( template_data['kubelet_bind_addr'] = _bind_addr(
@ -112,7 +112,7 @@ def get_template_data():
template_data['proxy_bind_addr'] = _bind_addr( template_data['proxy_bind_addr'] = _bind_addr(
hookenv.unit_get('public-address')) hookenv.unit_get('public-address'))
template_data['kubeapi_server'] = api_servers template_data['kubeapi_server'] = api_servers
template_data['etcd_servers'] = ",".join([ template_data['etcd_servers'] = ','.join([
'http://%s:%s' % (s[0], s[1]) for s in sorted(etcd_servers)]) 'http://%s:%s' % (s[0], s[1]) for s in sorted(etcd_servers)])
template_data['identifier'] = os.environ['JUJU_UNIT_NAME'].replace( template_data['identifier'] = os.environ['JUJU_UNIT_NAME'].replace(
'/', '-') '/', '-')
@ -125,7 +125,7 @@ def _bind_addr(addr):
try: try:
return socket.gethostbyname(addr) return socket.gethostbyname(addr)
except socket.error: except socket.error:
raise ValueError("Could not resolve private address") raise ValueError('Could not resolve private address')
def _encode(d): def _encode(d):
@ -186,8 +186,8 @@ def register_machine(apiserver, retry=False):
with open('/proc/meminfo') as fh: with open('/proc/meminfo') as fh:
info = fh.readline() info = fh.readline()
mem = info.strip().split(":")[1].strip().split()[0] mem = info.strip().split(':')[1].strip().split()[0]
cpus = os.sysconf("SC_NPROCESSORS_ONLN") cpus = os.sysconf('SC_NPROCESSORS_ONLN')
registration_request = Registrator() registration_request = Registrator()
registration_request.data['Kind'] = 'Minion' registration_request.data['Kind'] = 'Minion'
@ -201,7 +201,7 @@ def register_machine(apiserver, retry=False):
response, result = registration_request.register(parsed.hostname, response, result = registration_request.register(parsed.hostname,
parsed.port, parsed.port,
"/api/v1beta3/nodes") '/api/v1beta3/nodes')
print(response) print(response)