mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-31 23:37:01 +00:00
Wipe the old charm(s)
This commit is contained in:
Charles Butler
parent
eb0e25f5bd
commit
a750bf667f
1
cluster/juju/charms/trusty/.gitignore
vendored
1
cluster/juju/charms/trusty/.gitignore
vendored
@ -1 +0,0 @@
|
|||||||
/docker
|
|
||||||
@ -1 +0,0 @@
|
|||||||
.git
|
|
||||||
@ -1,5 +0,0 @@
|
|||||||
*~
|
|
||||||
.bzr
|
|
||||||
.venv
|
|
||||||
unit_tests/__pycache__
|
|
||||||
*.pyc
|
|
||||||
@ -1,5 +0,0 @@
|
|||||||
omit:
|
|
||||||
- .git
|
|
||||||
- .gitignore
|
|
||||||
- .gitmodules
|
|
||||||
- revision
|
|
||||||
@ -1,43 +0,0 @@
|
|||||||
# Copyright 2016 The Kubernetes Authors All rights reserved.
|
|
||||||
#
|
|
||||||
# Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
# you may not use this file except in compliance with the License.
|
|
||||||
# You may obtain a copy of the License at
|
|
||||||
#
|
|
||||||
# http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
#
|
|
||||||
# Unless required by applicable law or agreed to in writing, software
|
|
||||||
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
# See the License for the specific language governing permissions and
|
|
||||||
# limitations under the License.
|
|
||||||
|
|
||||||
build: virtualenv lint test
|
|
||||||
|
|
||||||
virtualenv:
|
|
||||||
virtualenv .venv
|
|
||||||
.venv/bin/pip install -q -r requirements.txt
|
|
||||||
|
|
||||||
lint: virtualenv
|
|
||||||
@.venv/bin/flake8 hooks --exclude=charmhelpers --ignore=W391
|
|
||||||
@.venv/bin/charm proof
|
|
||||||
|
|
||||||
test: virtualenv
|
|
||||||
@CHARM_DIR=. PYTHONPATH=./hooks .venv/bin/py.test -v unit_tests/*
|
|
||||||
|
|
||||||
functional-test:
|
|
||||||
@bundletester
|
|
||||||
|
|
||||||
release: check-path virtualenv
|
|
||||||
@.venv/bin/pip install git-vendor
|
|
||||||
@.venv/bin/git-vendor sync -d ${KUBERNETES_MASTER_BZR}
|
|
||||||
|
|
||||||
check-path:
|
|
||||||
ifndef KUBERNETES_MASTER_BZR
|
|
||||||
$(error KUBERNETES_MASTER_BZR is undefined)
|
|
||||||
endif
|
|
||||||
|
|
||||||
clean:
|
|
||||||
rm -rf .venv
|
|
||||||
find -name *.pyc -delete
|
|
||||||
rm -rf unit_tests/.cache
|
|
||||||
@ -1,126 +0,0 @@
|
|||||||
# Kubernetes Master Charm
|
|
||||||
|
|
||||||
[Kubernetes](https://github.com/kubernetes/kubernetes) is an open
|
|
||||||
source system for managing containerized applications across multiple hosts.
|
|
||||||
Kubernetes uses [Docker](http://www.docker.io/) to package, instantiate and run
|
|
||||||
containerized applications.
|
|
||||||
|
|
||||||
The Kubernetes Juju charms enable you to run Kubernetes on all the cloud
|
|
||||||
platforms that Juju supports.
|
|
||||||
|
|
||||||
A Kubernetes deployment consists of several independent charms that can be
|
|
||||||
scaled to meet your needs
|
|
||||||
|
|
||||||
### Etcd
|
|
||||||
Etcd is a key value store for Kubernetes. All persistent master state
|
|
||||||
is stored in `etcd`.
|
|
||||||
|
|
||||||
### Flannel-docker
|
|
||||||
Flannel is a
|
|
||||||
[software defined networking](http://en.wikipedia.org/wiki/Software-defined_networking)
|
|
||||||
component that provides individual subnets for each machine in the cluster.
|
|
||||||
|
|
||||||
### Docker
|
|
||||||
Docker is an open platform for distributing applications for system administrators.
|
|
||||||
|
|
||||||
### Kubernetes master
|
|
||||||
The controlling unit in a Kubernetes cluster is called the master. It is the
|
|
||||||
main management contact point providing many management services for the worker
|
|
||||||
nodes.
|
|
||||||
|
|
||||||
### Kubernetes minion
|
|
||||||
The servers that perform the work are known as minions. Minions must be able to
|
|
||||||
communicate with the master and run the workloads that are assigned to them.
|
|
||||||
|
|
||||||
|
|
||||||
## Usage
|
|
||||||
|
|
||||||
|
|
||||||
#### Deploying the Development Focus
|
|
||||||
|
|
||||||
To deploy a Kubernetes environment in Juju :
|
|
||||||
|
|
||||||
juju deploy cs:~kubernetes/trusty/etcd
|
|
||||||
juju deploy cs:trusty/flannel-docker
|
|
||||||
juju deploy cs:trusty/docker
|
|
||||||
juju deploy local:trusty/kubernetes-master
|
|
||||||
juju deploy local:trusty/kubernetes
|
|
||||||
|
|
||||||
juju add-relation etcd flannel-docker
|
|
||||||
juju add-relation flannel-docker:network docker:network
|
|
||||||
juju add-relation flannel-docker:docker-host docker
|
|
||||||
juju add-relation etcd kubernetes
|
|
||||||
juju add-relation etcd kubernetes-master
|
|
||||||
juju add-relation kubernetes kubernetes-master
|
|
||||||
|
|
||||||
|
|
||||||
#### Deploying the recommended configuration
|
|
||||||
|
|
||||||
Use the 'juju quickstart' command to deploy a Kubernetes cluster to any cloud
|
|
||||||
supported by Juju.
|
|
||||||
|
|
||||||
The charm store version of the Kubernetes bundle can be deployed as follows:
|
|
||||||
|
|
||||||
juju quickstart u/kubernetes/kubernetes-cluster
|
|
||||||
|
|
||||||
> Note: The charm store bundle may be locked to a specific Kubernetes release.
|
|
||||||
|
|
||||||
Alternately you could deploy a Kubernetes bundle straight from github or a file:
|
|
||||||
|
|
||||||
juju quickstart https://raw.githubusercontent.com/kubernetes/kubernetes/master/cluster/juju/bundles/local.yaml
|
|
||||||
|
|
||||||
The command above does few things for you:
|
|
||||||
|
|
||||||
- Starts a curses based gui for managing your cloud or MAAS credentials
|
|
||||||
- Looks for a bootstrapped deployment environment, and bootstraps if
|
|
||||||
required. This will launch a bootstrap node in your chosen
|
|
||||||
deployment environment (machine 0).
|
|
||||||
- Deploys the Juju GUI to your environment onto the bootstrap node.
|
|
||||||
- Provisions 4 machines, and deploys the Kubernetes services on top of
|
|
||||||
them (Kubernetes-master, two Kubernetes minions using flannel, and etcd).
|
|
||||||
- Orchestrates the relations among the services, and exits.
|
|
||||||
|
|
||||||
Now you should have a running Kubernetes. Run `juju status
|
|
||||||
--format=oneline` to see the address of your kubernetes-master unit.
|
|
||||||
|
|
||||||
For further reading on [Juju Quickstart](https://pypi.python.org/pypi/juju-quickstart)
|
|
||||||
|
|
||||||
Go to the [Getting started with Juju guide](https://github.com/kubernetes/kubernetes/blob/master/docs/getting-started-guides/juju.md)
|
|
||||||
for more information about deploying a development Kubernetes cluster.
|
|
||||||
|
|
||||||
|
|
||||||
#### Post Deployment
|
|
||||||
|
|
||||||
To interact with the kubernetes environment, either build or
|
|
||||||
[download](https://github.com/kubernetes/kubernetes/releases) the
|
|
||||||
[kubectl](https://github.com/kubernetes/kubernetes/blob/master/docs/user-guide/kubectl/kubectl.md)
|
|
||||||
binary (available in the releases binary tarball) and point it to the master with :
|
|
||||||
|
|
||||||
|
|
||||||
$ juju status kubernetes-master | grep public
|
|
||||||
public-address: 104.131.108.99
|
|
||||||
$ export KUBERNETES_MASTER="104.131.108.99"
|
|
||||||
|
|
||||||
# Configuration
|
|
||||||
For you convenience this charm supports changing the version of kubernetes binaries.
|
|
||||||
This can be done through the Juju GUI or on the command line:
|
|
||||||
|
|
||||||
juju set kubernetes version=”v0.10.0”
|
|
||||||
|
|
||||||
If the charm does not already contain the tar file with the desired architecture
|
|
||||||
and version it will attempt to download the kubernetes binaries using the gsutil
|
|
||||||
command.
|
|
||||||
|
|
||||||
Congratulations you know have deployed a Kubernetes environment! Use the
|
|
||||||
[kubectl](https://github.com/kubernetes/kubernetes/blob/master/docs/user-guide/kubectl/kubectl.md)
|
|
||||||
to interact with the environment.
|
|
||||||
|
|
||||||
# Kubernetes information
|
|
||||||
|
|
||||||
- [Kubernetes github project](https://github.com/kubernetes/kubernetes)
|
|
||||||
- [Kubernetes issue tracker](https://github.com/kubernetes/kubernetes/issues)
|
|
||||||
- [Kubernetes Documenation](https://github.com/kubernetes/kubernetes/tree/master/docs)
|
|
||||||
- [Kubernetes releases](https://github.com/kubernetes/kubernetes/releases)
|
|
||||||
|
|
||||||
|
|
||||||
[]()
|
|
||||||
@ -1,33 +0,0 @@
|
|||||||
options:
|
|
||||||
version:
|
|
||||||
type: string
|
|
||||||
default: "v1.0.0"
|
|
||||||
description: |
|
|
||||||
The kubernetes release to use in this charm. The binary files are
|
|
||||||
compiled from the source identified by this tag in github. Using the
|
|
||||||
value of "source" will use the master kubernetes branch when compiling
|
|
||||||
the binaries.
|
|
||||||
username:
|
|
||||||
type: string
|
|
||||||
default: "admin"
|
|
||||||
description: |
|
|
||||||
The initial user for the kubernetes basic authentication file.
|
|
||||||
password:
|
|
||||||
type: string
|
|
||||||
default: ""
|
|
||||||
description: |
|
|
||||||
The password for the kubernetes basic authentication. If this value is
|
|
||||||
empty, a password will be generated at random for the username.
|
|
||||||
apiserver-cert:
|
|
||||||
type: string
|
|
||||||
default: ""
|
|
||||||
description: |
|
|
||||||
The ssl certificate to use for tls communication to the Kubernetes api
|
|
||||||
server. If this value is empty a self signed certificate and key will
|
|
||||||
be generated.
|
|
||||||
apiserver-key:
|
|
||||||
type: string
|
|
||||||
default: ""
|
|
||||||
description: |
|
|
||||||
The private key to use for tls communication to the Kubernetes api
|
|
||||||
server. If this value is empty a key and certificate will be generated.
|
|
||||||
@ -1,13 +0,0 @@
|
|||||||
Copyright 2015 Google Inc. All rights reserved.
|
|
||||||
|
|
||||||
Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
you may not use this file except in compliance with the License.
|
|
||||||
You may obtain a copy of the License at
|
|
||||||
|
|
||||||
http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
|
|
||||||
Unless required by applicable law or agreed to in writing, software
|
|
||||||
distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
See the License for the specific language governing permissions and
|
|
||||||
limitations under the License.
|
|
||||||
@ -1,20 +0,0 @@
|
|||||||
description "Kubernetes Controller"
|
|
||||||
|
|
||||||
start on runlevel [2345]
|
|
||||||
stop on runlevel [!2345]
|
|
||||||
|
|
||||||
limit nofile 20000 20000
|
|
||||||
|
|
||||||
kill timeout 30 # wait 30s between SIGTERM and SIGKILL.
|
|
||||||
|
|
||||||
exec /usr/local/bin/apiserver \
|
|
||||||
--allow-privileged=true \
|
|
||||||
--basic-auth-file=/srv/kubernetes/basic-auth.csv \
|
|
||||||
--bind-address=%(api_private_address)s \
|
|
||||||
--etcd-servers=%(etcd_servers)s \
|
|
||||||
--insecure-bind-address=%(api_private_address)s \
|
|
||||||
--logtostderr=true \
|
|
||||||
--secure-port=6443 \
|
|
||||||
--service-cluster-ip-range=10.244.240.0/20 \
|
|
||||||
--tls-cert-file=/srv/kubernetes/apiserver.crt \
|
|
||||||
--tls-private-key-file=/srv/kubernetes/apiserver.key
|
|
||||||
@ -1,13 +0,0 @@
|
|||||||
description "Kubernetes Controller"
|
|
||||||
|
|
||||||
start on runlevel [2345]
|
|
||||||
stop on runlevel [!2345]
|
|
||||||
|
|
||||||
limit nofile 20000 20000
|
|
||||||
|
|
||||||
kill timeout 30 # wait 30s between SIGTERM and SIGKILL.
|
|
||||||
|
|
||||||
exec /usr/local/bin/controller-manager \
|
|
||||||
--address=%(bind_address)s \
|
|
||||||
--logtostderr=true \
|
|
||||||
--master=%(api_http_uri)s
|
|
||||||
@ -1,10 +0,0 @@
|
|||||||
# This file configures ngnix to serve Kubernetes binaries using http.
|
|
||||||
# The charms find the location path from the api relation to the charm.
|
|
||||||
server {
|
|
||||||
listen 80 default_server;
|
|
||||||
root %(alias)s;
|
|
||||||
|
|
||||||
location %(web_uri)s {
|
|
||||||
alias %(alias)s;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,27 +0,0 @@
|
|||||||
# Proxy HTTPS from the public address to the kube-apiserver running at 6443.
|
|
||||||
server {
|
|
||||||
listen 443;
|
|
||||||
server_name localhost;
|
|
||||||
|
|
||||||
root html;
|
|
||||||
index index.html index.htm;
|
|
||||||
|
|
||||||
ssl on;
|
|
||||||
ssl_certificate /srv/kubernetes/apiserver.crt;
|
|
||||||
ssl_certificate_key /srv/kubernetes/apiserver.key;
|
|
||||||
ssl_session_timeout 5m;
|
|
||||||
|
|
||||||
# don't use SSLv3 because of POODLE
|
|
||||||
ssl_protocols TLSv1 TLSv1.1 TLSv1.2;
|
|
||||||
ssl_ciphers ECDH+AESGCM:DH+AESGCM:ECDH+AES256:DH+AES256:ECDH+AES128:DH+AES:ECDH+3DES:DH+3DES:RSA+AESGCM:RSA+AES:RSA+3DES:!aNULL:!MD5:!DSS;
|
|
||||||
ssl_prefer_server_ciphers on;
|
|
||||||
|
|
||||||
location / {
|
|
||||||
proxy_buffering off;
|
|
||||||
proxy_pass %(api_https_uri)s;
|
|
||||||
proxy_connect_timeout 159s;
|
|
||||||
proxy_send_timeout 600s;
|
|
||||||
proxy_read_timeout 600s;
|
|
||||||
proxy_redirect off;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,13 +0,0 @@
|
|||||||
description "Kubernetes Scheduler"
|
|
||||||
|
|
||||||
start on runlevel [2345]
|
|
||||||
stop on runlevel [!2345]
|
|
||||||
|
|
||||||
limit nofile 20000 20000
|
|
||||||
|
|
||||||
kill timeout 30 # wait 30s between SIGTERM and SIGKILL.
|
|
||||||
|
|
||||||
exec /usr/local/bin/scheduler \
|
|
||||||
--address=%(bind_address)s \
|
|
||||||
--logtostderr=true \
|
|
||||||
--master=%(api_http_uri)s
|
|
||||||
@ -1,16 +0,0 @@
|
|||||||
#!/usr/bin/env python
|
|
||||||
|
|
||||||
# Copyright 2015 The Kubernetes Authors All rights reserved.
|
|
||||||
#
|
|
||||||
# Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
# you may not use this file except in compliance with the License.
|
|
||||||
# You may obtain a copy of the License at
|
|
||||||
#
|
|
||||||
# http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
#
|
|
||||||
# Unless required by applicable law or agreed to in writing, software
|
|
||||||
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
# See the License for the specific language governing permissions and
|
|
||||||
# limitations under the License.
|
|
||||||
|
|
||||||
@ -1 +0,0 @@
|
|||||||
hooks.py
|
|
||||||
@ -1 +0,0 @@
|
|||||||
hooks.py
|
|
||||||
@ -1,326 +0,0 @@
|
|||||||
#!/usr/bin/env python
|
|
||||||
|
|
||||||
# Copyright 2015 The Kubernetes Authors All rights reserved.
|
|
||||||
#
|
|
||||||
# Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
# you may not use this file except in compliance with the License.
|
|
||||||
# You may obtain a copy of the License at
|
|
||||||
#
|
|
||||||
# http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
#
|
|
||||||
# Unless required by applicable law or agreed to in writing, software
|
|
||||||
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
# See the License for the specific language governing permissions and
|
|
||||||
# limitations under the License.
|
|
||||||
|
|
||||||
"""
|
|
||||||
The main hook file is called by Juju.
|
|
||||||
"""
|
|
||||||
import contextlib
|
|
||||||
import os
|
|
||||||
import socket
|
|
||||||
import subprocess
|
|
||||||
import sys
|
|
||||||
from charmhelpers.core import hookenv, host
|
|
||||||
from charmhelpers.contrib import ssl
|
|
||||||
from kubernetes_installer import KubernetesInstaller
|
|
||||||
from path import Path
|
|
||||||
|
|
||||||
hooks = hookenv.Hooks()
|
|
||||||
|
|
||||||
|
|
||||||
@contextlib.contextmanager
|
|
||||||
def check_sentinel(filepath):
|
|
||||||
"""
|
|
||||||
A context manager method to write a file while the code block is doing
|
|
||||||
something and remove the file when done.
|
|
||||||
"""
|
|
||||||
fail = False
|
|
||||||
try:
|
|
||||||
yield filepath.exists()
|
|
||||||
except:
|
|
||||||
fail = True
|
|
||||||
filepath.touch()
|
|
||||||
raise
|
|
||||||
finally:
|
|
||||||
if fail is False and filepath.exists():
|
|
||||||
filepath.remove()
|
|
||||||
|
|
||||||
|
|
||||||
@hooks.hook('config-changed')
|
|
||||||
def config_changed():
|
|
||||||
"""
|
|
||||||
On the execution of the juju event 'config-changed' this function
|
|
||||||
determines the appropriate architecture and the configured version to
|
|
||||||
create kubernetes binary files.
|
|
||||||
"""
|
|
||||||
hookenv.log('Starting config-changed')
|
|
||||||
charm_dir = Path(hookenv.charm_dir())
|
|
||||||
config = hookenv.config()
|
|
||||||
# Get the version of kubernetes to install.
|
|
||||||
version = config['version']
|
|
||||||
username = config['username']
|
|
||||||
password = config['password']
|
|
||||||
certificate = config['apiserver-cert']
|
|
||||||
key = config['apiserver-key']
|
|
||||||
|
|
||||||
if version == 'master':
|
|
||||||
# The 'master' branch of kuberentes is used when master is configured.
|
|
||||||
branch = 'master'
|
|
||||||
elif version == 'local':
|
|
||||||
# Check for kubernetes binaries in the local files/output directory.
|
|
||||||
branch = None
|
|
||||||
else:
|
|
||||||
# Create a branch to a tag to get the release version.
|
|
||||||
branch = 'tags/{0}'.format(version)
|
|
||||||
|
|
||||||
cert_file = '/srv/kubernetes/apiserver.crt'
|
|
||||||
key_file = '/srv/kubernetes/apiserver.key'
|
|
||||||
# When the cert or key changes we need to restart the apiserver.
|
|
||||||
if config.changed('apiserver-cert') or config.changed('apiserver-key'):
|
|
||||||
hookenv.log('Certificate or key has changed.')
|
|
||||||
if not certificate or not key:
|
|
||||||
generate_cert(key=key_file, cert=cert_file)
|
|
||||||
else:
|
|
||||||
hookenv.log('Writing new certificate and key to server.')
|
|
||||||
with open(key_file, 'w') as file:
|
|
||||||
file.write(key)
|
|
||||||
with open(cert_file, 'w') as file:
|
|
||||||
file.write(certificate)
|
|
||||||
# Restart apiserver as the certificate or key has changed.
|
|
||||||
if host.service_running('apiserver'):
|
|
||||||
host.service_restart('apiserver')
|
|
||||||
# Reload nginx because it proxies https to apiserver.
|
|
||||||
if host.service_running('nginx'):
|
|
||||||
host.service_reload('nginx')
|
|
||||||
|
|
||||||
if config.changed('username') or config.changed('password'):
|
|
||||||
hookenv.log('Username or password changed, creating authentication.')
|
|
||||||
basic_auth(username, username, password)
|
|
||||||
if host.service_running('apiserver'):
|
|
||||||
host.service_restart('apiserver')
|
|
||||||
|
|
||||||
# Get package architecture, rather than arch from the kernel (uname -m).
|
|
||||||
arch = subprocess.check_output(['dpkg', '--print-architecture']).strip()
|
|
||||||
|
|
||||||
if not branch:
|
|
||||||
output_path = charm_dir / 'files/output'
|
|
||||||
kube_installer = KubernetesInstaller(arch, version, output_path)
|
|
||||||
else:
|
|
||||||
|
|
||||||
# Build the kuberentes binaries from source on the units.
|
|
||||||
kubernetes_dir = Path('/opt/kubernetes')
|
|
||||||
|
|
||||||
# Construct the path to the binaries using the arch.
|
|
||||||
output_path = kubernetes_dir / '_output/local/bin/linux' / arch
|
|
||||||
kube_installer = KubernetesInstaller(arch, version, output_path)
|
|
||||||
|
|
||||||
if not kubernetes_dir.exists():
|
|
||||||
message = 'The kubernetes source directory {0} does not exist. ' \
|
|
||||||
'Was the kubernetes repository cloned during the install?'
|
|
||||||
print(message.format(kubernetes_dir))
|
|
||||||
exit(1)
|
|
||||||
|
|
||||||
# Change to the kubernetes directory (git repository).
|
|
||||||
with kubernetes_dir:
|
|
||||||
# Create a command to get the current branch.
|
|
||||||
git_branch = 'git branch | grep "\*" | cut -d" " -f2'
|
|
||||||
current_branch = subprocess.check_output(git_branch, shell=True)
|
|
||||||
current_branch = current_branch.strip()
|
|
||||||
print('Current branch: ', current_branch)
|
|
||||||
# Create the path to a file to indicate if the build was broken.
|
|
||||||
broken_build = charm_dir / '.broken_build'
|
|
||||||
# write out the .broken_build file while this block is executing.
|
|
||||||
with check_sentinel(broken_build) as last_build_failed:
|
|
||||||
print('Last build failed: ', last_build_failed)
|
|
||||||
# Rebuild if current version is different or last build failed.
|
|
||||||
if current_branch != version or last_build_failed:
|
|
||||||
kube_installer.build(branch)
|
|
||||||
if not output_path.isdir():
|
|
||||||
broken_build.touch()
|
|
||||||
|
|
||||||
# Create the symoblic links to the right directories.
|
|
||||||
kube_installer.install()
|
|
||||||
|
|
||||||
relation_changed()
|
|
||||||
|
|
||||||
hookenv.log('The config-changed hook completed successfully.')
|
|
||||||
|
|
||||||
|
|
||||||
@hooks.hook('etcd-relation-changed', 'minions-api-relation-changed')
|
|
||||||
def relation_changed():
|
|
||||||
template_data = get_template_data()
|
|
||||||
|
|
||||||
# Check required keys
|
|
||||||
for k in ('etcd_servers',):
|
|
||||||
if not template_data.get(k):
|
|
||||||
print 'Missing data for', k, template_data
|
|
||||||
return
|
|
||||||
|
|
||||||
print 'Running with\n', template_data
|
|
||||||
|
|
||||||
# Render and restart as needed
|
|
||||||
for n in ('apiserver', 'controller-manager', 'scheduler'):
|
|
||||||
if render_file(n, template_data) or not host.service_running(n):
|
|
||||||
host.service_restart(n)
|
|
||||||
|
|
||||||
# Render the file that makes the kubernetes binaries available to minions.
|
|
||||||
if render_file(
|
|
||||||
'distribution', template_data,
|
|
||||||
'conf.tmpl', '/etc/nginx/sites-enabled/distribution') or \
|
|
||||||
not host.service_running('nginx'):
|
|
||||||
host.service_reload('nginx')
|
|
||||||
# Render the default nginx template.
|
|
||||||
if render_file(
|
|
||||||
'nginx', template_data,
|
|
||||||
'conf.tmpl', '/etc/nginx/sites-enabled/default') or \
|
|
||||||
not host.service_running('nginx'):
|
|
||||||
host.service_reload('nginx')
|
|
||||||
|
|
||||||
# Send api endpoint to minions
|
|
||||||
notify_minions()
|
|
||||||
|
|
||||||
|
|
||||||
@hooks.hook('network-relation-changed')
|
|
||||||
def network_relation_changed():
|
|
||||||
relation_id = hookenv.relation_id()
|
|
||||||
hookenv.relation_set(relation_id, ignore_errors=True)
|
|
||||||
|
|
||||||
|
|
||||||
def notify_minions():
|
|
||||||
print('Notify minions.')
|
|
||||||
config = hookenv.config()
|
|
||||||
for r in hookenv.relation_ids('minions-api'):
|
|
||||||
hookenv.relation_set(
|
|
||||||
r,
|
|
||||||
hostname=hookenv.unit_private_ip(),
|
|
||||||
port=8080,
|
|
||||||
version=config['version'])
|
|
||||||
print('Notified minions of version ' + config['version'])
|
|
||||||
|
|
||||||
|
|
||||||
def basic_auth(name, id, pwd=None, file='/srv/kubernetes/basic-auth.csv'):
|
|
||||||
"""
|
|
||||||
Create a basic authentication file for kubernetes. The file is a csv file
|
|
||||||
with 3 columns: password, user name, user id. From the Kubernetes docs:
|
|
||||||
The basic auth credentials last indefinitely, and the password cannot be
|
|
||||||
changed without restarting apiserver.
|
|
||||||
"""
|
|
||||||
if not pwd:
|
|
||||||
import random
|
|
||||||
import string
|
|
||||||
alphanumeric = string.ascii_letters + string.digits
|
|
||||||
pwd = ''.join(random.choice(alphanumeric) for _ in range(16))
|
|
||||||
lines = []
|
|
||||||
auth_file = Path(file)
|
|
||||||
if auth_file.isfile():
|
|
||||||
lines = auth_file.lines()
|
|
||||||
for line in lines:
|
|
||||||
target = ',{0},{1}'.format(name, id)
|
|
||||||
if target in line:
|
|
||||||
lines.remove(line)
|
|
||||||
auth_line = '{0},{1},{2}'.format(pwd, name, id)
|
|
||||||
lines.append(auth_line)
|
|
||||||
auth_file.write_lines(lines)
|
|
||||||
|
|
||||||
|
|
||||||
def generate_cert(common_name=None,
|
|
||||||
key='/srv/kubernetes/apiserver.key',
|
|
||||||
cert='/srv/kubernetes/apiserver.crt'):
|
|
||||||
"""
|
|
||||||
Create the certificate and key for the Kubernetes tls enablement.
|
|
||||||
"""
|
|
||||||
hookenv.log('Generating new self signed certificate and key', 'INFO')
|
|
||||||
if not common_name:
|
|
||||||
common_name = hookenv.unit_get('public-address')
|
|
||||||
if os.path.isfile(key) or os.path.isfile(cert):
|
|
||||||
hookenv.log('Overwriting the existing certificate or key', 'WARNING')
|
|
||||||
hookenv.log('Generating certificate for {0}'.format(common_name), 'INFO')
|
|
||||||
# Generate the self signed certificate with the public address as CN.
|
|
||||||
# https://pythonhosted.org/charmhelpers/api/charmhelpers.contrib.ssl.html
|
|
||||||
ssl.generate_selfsigned(key, cert, cn=common_name)
|
|
||||||
|
|
||||||
|
|
||||||
def get_template_data():
|
|
||||||
rels = hookenv.relations()
|
|
||||||
config = hookenv.config()
|
|
||||||
version = config['version']
|
|
||||||
template_data = {}
|
|
||||||
template_data['etcd_servers'] = ','.join([
|
|
||||||
'http://%s:%s' % (s[0], s[1]) for s in sorted(
|
|
||||||
get_rel_hosts('etcd', rels, ('hostname', 'port')))])
|
|
||||||
template_data['minions'] = ','.join(get_rel_hosts('minions-api', rels))
|
|
||||||
private_ip = hookenv.unit_private_ip()
|
|
||||||
public_ip = hookenv.unit_public_ip()
|
|
||||||
template_data['api_public_address'] = _bind_addr(public_ip)
|
|
||||||
template_data['api_private_address'] = _bind_addr(private_ip)
|
|
||||||
template_data['bind_address'] = '127.0.0.1'
|
|
||||||
template_data['api_http_uri'] = 'http://%s:%s' % (private_ip, 8080)
|
|
||||||
template_data['api_https_uri'] = 'https://%s:%s' % (private_ip, 6443)
|
|
||||||
|
|
||||||
arch = subprocess.check_output(['dpkg', '--print-architecture']).strip()
|
|
||||||
|
|
||||||
template_data['web_uri'] = '/kubernetes/%s/local/bin/linux/%s/' % (version,
|
|
||||||
arch)
|
|
||||||
if version == 'local':
|
|
||||||
template_data['alias'] = hookenv.charm_dir() + '/files/output/'
|
|
||||||
else:
|
|
||||||
directory = '/opt/kubernetes/_output/local/bin/linux/%s/' % arch
|
|
||||||
template_data['alias'] = directory
|
|
||||||
_encode(template_data)
|
|
||||||
return template_data
|
|
||||||
|
|
||||||
|
|
||||||
def _bind_addr(addr):
|
|
||||||
if addr.replace('.', '').isdigit():
|
|
||||||
return addr
|
|
||||||
try:
|
|
||||||
return socket.gethostbyname(addr)
|
|
||||||
except socket.error:
|
|
||||||
raise ValueError('Could not resolve address %s' % addr)
|
|
||||||
|
|
||||||
|
|
||||||
def _encode(d):
|
|
||||||
for k, v in d.items():
|
|
||||||
if isinstance(v, unicode):
|
|
||||||
d[k] = v.encode('utf8')
|
|
||||||
|
|
||||||
|
|
||||||
def get_rel_hosts(rel_name, rels, keys=('private-address',)):
|
|
||||||
hosts = []
|
|
||||||
for r, data in rels.get(rel_name, {}).items():
|
|
||||||
for unit_id, unit_data in data.items():
|
|
||||||
if unit_id == hookenv.local_unit():
|
|
||||||
continue
|
|
||||||
values = [unit_data.get(k) for k in keys]
|
|
||||||
if not all(values):
|
|
||||||
continue
|
|
||||||
hosts.append(len(values) == 1 and values[0] or values)
|
|
||||||
return hosts
|
|
||||||
|
|
||||||
|
|
||||||
def render_file(name, data, src_suffix='upstart.tmpl', tgt_path=None):
|
|
||||||
tmpl_path = os.path.join(
|
|
||||||
os.environ.get('CHARM_DIR'), 'files', '%s.%s' % (name, src_suffix))
|
|
||||||
|
|
||||||
with open(tmpl_path) as fh:
|
|
||||||
tmpl = fh.read()
|
|
||||||
rendered = tmpl % data
|
|
||||||
|
|
||||||
if tgt_path is None:
|
|
||||||
tgt_path = '/etc/init/%s.conf' % name
|
|
||||||
|
|
||||||
if os.path.exists(tgt_path):
|
|
||||||
with open(tgt_path) as fh:
|
|
||||||
contents = fh.read()
|
|
||||||
if contents == rendered:
|
|
||||||
return False
|
|
||||||
|
|
||||||
with open(tgt_path, 'w') as fh:
|
|
||||||
fh.write(rendered)
|
|
||||||
return True
|
|
||||||
|
|
||||||
|
|
||||||
if __name__ == '__main__':
|
|
||||||
hooks.execute(sys.argv)
|
|
||||||
@ -1 +0,0 @@
|
|||||||
install.py
|
|
||||||
@ -1,119 +0,0 @@
|
|||||||
#!/usr/bin/env python
|
|
||||||
|
|
||||||
# Copyright 2015 The Kubernetes Authors All rights reserved.
|
|
||||||
#
|
|
||||||
# Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
# you may not use this file except in compliance with the License.
|
|
||||||
# You may obtain a copy of the License at
|
|
||||||
#
|
|
||||||
# http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
#
|
|
||||||
# Unless required by applicable law or agreed to in writing, software
|
|
||||||
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
# See the License for the specific language governing permissions and
|
|
||||||
# limitations under the License.
|
|
||||||
|
|
||||||
import setup
|
|
||||||
setup.pre_install()
|
|
||||||
import subprocess
|
|
||||||
|
|
||||||
from charmhelpers import fetch
|
|
||||||
from charmhelpers.core import hookenv
|
|
||||||
from charmhelpers.fetch import archiveurl
|
|
||||||
from path import Path
|
|
||||||
|
|
||||||
|
|
||||||
def install():
|
|
||||||
install_packages()
|
|
||||||
hookenv.log('Installing go')
|
|
||||||
download_go()
|
|
||||||
|
|
||||||
hookenv.log('Adding kubernetes and go to the path')
|
|
||||||
address = hookenv.unit_private_ip()
|
|
||||||
strings = [
|
|
||||||
'export GOROOT=/usr/local/go\n',
|
|
||||||
'export PATH=$PATH:$GOROOT/bin\n',
|
|
||||||
'export KUBERNETES_MASTER=http://{0}:8080\n'.format(address),
|
|
||||||
]
|
|
||||||
update_rc_files(strings)
|
|
||||||
hookenv.log('Downloading kubernetes code')
|
|
||||||
clone_repository()
|
|
||||||
|
|
||||||
# Create the directory to store the keys and auth files.
|
|
||||||
srv = Path('/srv/kubernetes')
|
|
||||||
if not srv.isdir():
|
|
||||||
srv.makedirs_p()
|
|
||||||
|
|
||||||
hookenv.open_port(8080)
|
|
||||||
hookenv.open_port(6443)
|
|
||||||
hookenv.open_port(443)
|
|
||||||
|
|
||||||
hookenv.log('Install complete')
|
|
||||||
|
|
||||||
|
|
||||||
def download_go():
|
|
||||||
"""
|
|
||||||
Kubernetes charm strives to support upstream. Part of this is installing a
|
|
||||||
fairly recent edition of GO. This fetches the golang archive and installs
|
|
||||||
it in /usr/local
|
|
||||||
"""
|
|
||||||
go_url = 'https://storage.googleapis.com/golang/go1.4.2.linux-amd64.tar.gz'
|
|
||||||
go_sha1 = '5020af94b52b65cc9b6f11d50a67e4bae07b0aff'
|
|
||||||
handler = archiveurl.ArchiveUrlFetchHandler()
|
|
||||||
handler.install(go_url, '/usr/local', go_sha1, 'sha1')
|
|
||||||
|
|
||||||
|
|
||||||
def clone_repository():
|
|
||||||
"""
|
|
||||||
Clone the upstream repository into /opt/kubernetes for deployment
|
|
||||||
compilation of kubernetes. Subsequently used during upgrades.
|
|
||||||
"""
|
|
||||||
|
|
||||||
repository = 'https://github.com/kubernetes/kubernetes.git'
|
|
||||||
kubernetes_directory = Path('/opt/kubernetes')
|
|
||||||
# Since we can not clone twice, check for the directory and remove it.
|
|
||||||
if kubernetes_directory.isdir():
|
|
||||||
kubernetes_directory.rmtree_p()
|
|
||||||
|
|
||||||
command = ['git', 'clone', repository, kubernetes_directory]
|
|
||||||
print(command)
|
|
||||||
output = subprocess.check_output(command)
|
|
||||||
print(output)
|
|
||||||
|
|
||||||
|
|
||||||
def install_packages():
|
|
||||||
"""
|
|
||||||
Install required packages to build the k8s source, and syndicate between
|
|
||||||
minion nodes. In addition, fetch pip to handle python dependencies
|
|
||||||
"""
|
|
||||||
hookenv.log('Installing Debian packages')
|
|
||||||
# Create the list of packages to install.
|
|
||||||
apt_packages = ['apache2-utils',
|
|
||||||
'build-essential',
|
|
||||||
'docker.io',
|
|
||||||
'git',
|
|
||||||
'make',
|
|
||||||
'nginx',
|
|
||||||
'python-pip', ]
|
|
||||||
fetch.apt_install(fetch.filter_installed_packages(apt_packages))
|
|
||||||
|
|
||||||
|
|
||||||
def update_rc_files(strings, rc_files=None):
|
|
||||||
"""
|
|
||||||
Preseed the bash environment for ubuntu and root with K8's env vars to
|
|
||||||
make interfacing with the api easier. (see: kubectrl docs)
|
|
||||||
"""
|
|
||||||
if not rc_files:
|
|
||||||
rc_files = [Path('/home/ubuntu/.bashrc'), Path('/root/.bashrc')]
|
|
||||||
|
|
||||||
for rc_file in rc_files:
|
|
||||||
lines = rc_file.lines()
|
|
||||||
for string in strings:
|
|
||||||
if string not in lines:
|
|
||||||
lines.append(string)
|
|
||||||
rc_file.write_lines(lines)
|
|
||||||
|
|
||||||
|
|
||||||
if __name__ == "__main__":
|
|
||||||
install()
|
|
||||||
@ -1,107 +0,0 @@
|
|||||||
#!/usr/bin/env python
|
|
||||||
|
|
||||||
# Copyright 2015 The Kubernetes Authors All rights reserved.
|
|
||||||
#
|
|
||||||
# Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
# you may not use this file except in compliance with the License.
|
|
||||||
# You may obtain a copy of the License at
|
|
||||||
#
|
|
||||||
# http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
#
|
|
||||||
# Unless required by applicable law or agreed to in writing, software
|
|
||||||
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
# See the License for the specific language governing permissions and
|
|
||||||
# limitations under the License.
|
|
||||||
|
|
||||||
import os
|
|
||||||
import shlex
|
|
||||||
import subprocess
|
|
||||||
from path import Path
|
|
||||||
|
|
||||||
|
|
||||||
def run(command, shell=False):
|
|
||||||
""" A convience method for executing all the commands. """
|
|
||||||
print(command)
|
|
||||||
if shell is False:
|
|
||||||
command = shlex.split(command)
|
|
||||||
output = subprocess.check_output(command, shell=shell)
|
|
||||||
print(output)
|
|
||||||
return output
|
|
||||||
|
|
||||||
|
|
||||||
class KubernetesInstaller():
|
|
||||||
"""
|
|
||||||
This class contains the logic needed to install kuberentes binary files.
|
|
||||||
"""
|
|
||||||
|
|
||||||
def __init__(self, arch, version, output_dir):
|
|
||||||
""" Gather the required variables for the install. """
|
|
||||||
# The kubernetes-master charm needs certain commands to be aliased.
|
|
||||||
self.aliases = {'kube-apiserver': 'apiserver',
|
|
||||||
'kube-controller-manager': 'controller-manager',
|
|
||||||
'kube-proxy': 'kube-proxy',
|
|
||||||
'kube-scheduler': 'scheduler',
|
|
||||||
'kubectl': 'kubectl',
|
|
||||||
'kubelet': 'kubelet'}
|
|
||||||
self.arch = arch
|
|
||||||
self.version = version
|
|
||||||
self.output_dir = Path(output_dir)
|
|
||||||
|
|
||||||
def build(self, branch):
|
|
||||||
""" Build kubernetes from a github repository using the Makefile. """
|
|
||||||
# Remove any old build artifacts.
|
|
||||||
make_clean = 'make clean'
|
|
||||||
run(make_clean)
|
|
||||||
# Always checkout the master to get the latest repository information.
|
|
||||||
git_checkout_cmd = 'git checkout master'
|
|
||||||
run(git_checkout_cmd)
|
|
||||||
# When checking out a tag, delete the old branch (not master).
|
|
||||||
if branch != 'master':
|
|
||||||
git_drop_branch = 'git branch -D {0}'.format(self.version)
|
|
||||||
print(git_drop_branch)
|
|
||||||
rc = subprocess.call(git_drop_branch.split())
|
|
||||||
if rc != 0:
|
|
||||||
print('returned: %d' % rc)
|
|
||||||
# Make sure the git repository is up-to-date.
|
|
||||||
git_fetch = 'git fetch origin {0}'.format(branch)
|
|
||||||
run(git_fetch)
|
|
||||||
|
|
||||||
if branch == 'master':
|
|
||||||
git_reset = 'git reset --hard origin/master'
|
|
||||||
run(git_reset)
|
|
||||||
else:
|
|
||||||
# Checkout a branch of kubernetes so the repo is correct.
|
|
||||||
checkout = 'git checkout -b {0} {1}'.format(self.version, branch)
|
|
||||||
run(checkout)
|
|
||||||
|
|
||||||
# Create an environment with the path to the GO binaries included.
|
|
||||||
go_path = ('/usr/local/go/bin', os.environ.get('PATH', ''))
|
|
||||||
go_env = os.environ.copy()
|
|
||||||
go_env['PATH'] = ':'.join(go_path)
|
|
||||||
print(go_env['PATH'])
|
|
||||||
|
|
||||||
# Compile the binaries with the make command using the WHAT variable.
|
|
||||||
make_what = "make all WHAT='cmd/kube-apiserver cmd/kubectl "\
|
|
||||||
"cmd/kube-controller-manager plugin/cmd/kube-scheduler "\
|
|
||||||
"cmd/kubelet cmd/kube-proxy'"
|
|
||||||
print(make_what)
|
|
||||||
rc = subprocess.call(shlex.split(make_what), env=go_env)
|
|
||||||
|
|
||||||
def install(self, install_dir=Path('/usr/local/bin')):
|
|
||||||
""" Install kubernetes binary files from the output directory. """
|
|
||||||
|
|
||||||
if not install_dir.isdir():
|
|
||||||
install_dir.makedirs_p()
|
|
||||||
|
|
||||||
# Create the symbolic links to the real kubernetes binaries.
|
|
||||||
for key, value in self.aliases.iteritems():
|
|
||||||
target = self.output_dir / key
|
|
||||||
if target.exists():
|
|
||||||
link = install_dir / value
|
|
||||||
if link.exists():
|
|
||||||
link.remove()
|
|
||||||
target.symlink(link)
|
|
||||||
else:
|
|
||||||
print('Error target file {0} does not exist.'.format(target))
|
|
||||||
exit(1)
|
|
||||||
@ -1 +0,0 @@
|
|||||||
hooks.py
|
|
||||||
@ -1 +0,0 @@
|
|||||||
hooks.py
|
|
||||||
@ -1,47 +0,0 @@
|
|||||||
#!/usr/bin/env python
|
|
||||||
|
|
||||||
# Copyright 2015 The Kubernetes Authors All rights reserved.
|
|
||||||
#
|
|
||||||
# Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
# you may not use this file except in compliance with the License.
|
|
||||||
# You may obtain a copy of the License at
|
|
||||||
#
|
|
||||||
# http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
#
|
|
||||||
# Unless required by applicable law or agreed to in writing, software
|
|
||||||
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
# See the License for the specific language governing permissions and
|
|
||||||
# limitations under the License.
|
|
||||||
|
|
||||||
|
|
||||||
def pre_install():
|
|
||||||
"""
|
|
||||||
Do any setup required before the install hook.
|
|
||||||
"""
|
|
||||||
install_charmhelpers()
|
|
||||||
install_path()
|
|
||||||
|
|
||||||
|
|
||||||
def install_charmhelpers():
|
|
||||||
"""
|
|
||||||
Install the charmhelpers library, if not present.
|
|
||||||
"""
|
|
||||||
try:
|
|
||||||
import charmhelpers # noqa
|
|
||||||
except ImportError:
|
|
||||||
import subprocess
|
|
||||||
subprocess.check_call(['apt-get', 'install', '-y', 'python-pip'])
|
|
||||||
subprocess.check_call(['pip', 'install', 'charmhelpers'])
|
|
||||||
|
|
||||||
|
|
||||||
def install_path():
|
|
||||||
"""
|
|
||||||
Install the path.py library, when not present.
|
|
||||||
"""
|
|
||||||
try:
|
|
||||||
import path # noqa
|
|
||||||
except ImportError:
|
|
||||||
import subprocess
|
|
||||||
subprocess.check_call(['apt-get', 'install', '-y', 'python-pip'])
|
|
||||||
subprocess.check_call(['pip', 'install', 'path.py'])
|
|
||||||
File diff suppressed because one or more lines are too long
|
Before Width: | Height: | Size: 76 KiB |
@ -1,21 +0,0 @@
|
|||||||
name: kubernetes-master
|
|
||||||
summary: Container Cluster Management Master
|
|
||||||
description: |
|
|
||||||
Provides a kubernetes api endpoint, scheduler for managing containers.
|
|
||||||
maintainers:
|
|
||||||
- Matt Bruzek <matthew.bruzek@canonical.com>
|
|
||||||
- Whit Morriss <whit.morriss@canonical.com>
|
|
||||||
- Charles Butler <charles.butler@canonical.com>
|
|
||||||
tags:
|
|
||||||
- ops
|
|
||||||
- network
|
|
||||||
provides:
|
|
||||||
client-api:
|
|
||||||
interface: kubernetes-client
|
|
||||||
minions-api:
|
|
||||||
interface: kubernetes-api
|
|
||||||
requires:
|
|
||||||
etcd:
|
|
||||||
interface: etcd
|
|
||||||
network:
|
|
||||||
interface: overlay-network
|
|
||||||
@ -1,75 +0,0 @@
|
|||||||
kubernetes-master
|
|
||||||
-----------------
|
|
||||||
|
|
||||||
notes on src
|
|
||||||
------------
|
|
||||||
current provider responsibilities
|
|
||||||
- instances
|
|
||||||
- load blanacers
|
|
||||||
- zones (not useful as its only for apiserver).
|
|
||||||
|
|
||||||
provider functionality currently hardcoded to gce across codebase
|
|
||||||
- persistent storage
|
|
||||||
|
|
||||||
|
|
||||||
ideas
|
|
||||||
-----
|
|
||||||
- juju provider impl
|
|
||||||
- file provider for machines/minions
|
|
||||||
- openvpn as overlay per extant salt config.
|
|
||||||
|
|
||||||
cloud
|
|
||||||
-----
|
|
||||||
|
|
||||||
todo
|
|
||||||
----
|
|
||||||
- token auth file
|
|
||||||
- format csv -> token, user, uid
|
|
||||||
- config privileged
|
|
||||||
- config log-level
|
|
||||||
- config / check logs collection endpoint
|
|
||||||
- config / version and binary location via url
|
|
||||||
|
|
||||||
Q/A
|
|
||||||
----
|
|
||||||
|
|
||||||
https://botbot.me/freenode/google-containers/2014-10-17/?msg=23696683&page=6
|
|
||||||
|
|
||||||
Q. The new volumes/storage provider api appears to be hardcoded to
|
|
||||||
gce.. Is there a plan to abstract that anytime soon?
|
|
||||||
A. effectively it is abstract enough for the moment, no plans to
|
|
||||||
change, but willing subject to suitable abstraction.
|
|
||||||
|
|
||||||
Q.The zone provider api appears to return the address only of the api
|
|
||||||
server afaics. How is that useful? afaics the better semantic would be
|
|
||||||
an attribute on the minions to instantiate multiple templates across
|
|
||||||
zones?
|
|
||||||
A. apparently not considered, current solution for ha is multiple k8s
|
|
||||||
per zone with external lb. pointed out this was inane.
|
|
||||||
|
|
||||||
|
|
||||||
Q. Several previous platforms supported have been moved to the icebox,
|
|
||||||
just curious what was subject to bitrot. the salt/shell script for
|
|
||||||
those platforms or something more api intrinsic?
|
|
||||||
A. apparently the change to ship binaries instead of build from src
|
|
||||||
broke them.. somehow.
|
|
||||||
|
|
||||||
Q. i'm mostly interested in flannel due to its portability. Does the
|
|
||||||
inter pod networking setup need to include the other components of the
|
|
||||||
system, ie does api talk directly to containers, or only via kubelet.
|
|
||||||
A. api server only talks to kubelet
|
|
||||||
|
|
||||||
|
|
||||||
Q. Status of HA?
|
|
||||||
A. not done yet, election package merged, nothing using it.
|
|
||||||
|
|
||||||
Afaics design discussion doesn't take place on the list.
|
|
||||||
|
|
||||||
Q. Is minion registration supported, ie. bypassing cloud provider
|
|
||||||
filter all instances via regex match?
|
|
||||||
A. not done yet, pull request in review for minions in etcd (not
|
|
||||||
found, perhaps merged)
|
|
||||||
|
|
||||||
-------------
|
|
||||||
cadvisor usage helper
|
|
||||||
https://github.com/GoogleCloudPlatform/heapster
|
|
||||||
@ -1,5 +0,0 @@
|
|||||||
flake8
|
|
||||||
pytest
|
|
||||||
bundletester
|
|
||||||
path.py
|
|
||||||
charmhelpers
|
|
||||||
@ -1,134 +0,0 @@
|
|||||||
#!/usr/bin/env python
|
|
||||||
|
|
||||||
# Copyright 2015 The Kubernetes Authors All rights reserved.
|
|
||||||
#
|
|
||||||
# Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
# you may not use this file except in compliance with the License.
|
|
||||||
# You may obtain a copy of the License at
|
|
||||||
#
|
|
||||||
# http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
#
|
|
||||||
# Unless required by applicable law or agreed to in writing, software
|
|
||||||
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
# See the License for the specific language governing permissions and
|
|
||||||
# limitations under the License.
|
|
||||||
|
|
||||||
from mock import patch
|
|
||||||
from mock import ANY
|
|
||||||
from path import Path
|
|
||||||
import pytest
|
|
||||||
import subprocess
|
|
||||||
import sys
|
|
||||||
|
|
||||||
# Add the hooks directory to the python path.
|
|
||||||
hooks_dir = Path('__file__').parent.abspath() / 'hooks'
|
|
||||||
sys.path.insert(0, hooks_dir.abspath())
|
|
||||||
# Import the module to be tested.
|
|
||||||
import kubernetes_installer
|
|
||||||
|
|
||||||
|
|
||||||
def test_run():
|
|
||||||
""" Test the run method both with valid commands and invalid commands. """
|
|
||||||
ls = 'ls -l {0}/kubernetes_installer.py'.format(hooks_dir)
|
|
||||||
output = kubernetes_installer.run(ls, False)
|
|
||||||
assert output
|
|
||||||
assert 'kubernetes_installer.py' in output
|
|
||||||
output = kubernetes_installer.run(ls, True)
|
|
||||||
assert output
|
|
||||||
assert 'kubernetes_installer.py' in output
|
|
||||||
|
|
||||||
invalid_directory = Path('/not/a/real/directory')
|
|
||||||
assert not invalid_directory.exists()
|
|
||||||
invalid_command = 'ls {0}'.format(invalid_directory)
|
|
||||||
with pytest.raises(subprocess.CalledProcessError) as error:
|
|
||||||
kubernetes_installer.run(invalid_command)
|
|
||||||
print(error)
|
|
||||||
with pytest.raises(subprocess.CalledProcessError) as error:
|
|
||||||
kubernetes_installer.run(invalid_command, shell=True)
|
|
||||||
print(error)
|
|
||||||
|
|
||||||
|
|
||||||
class TestKubernetesInstaller():
|
|
||||||
|
|
||||||
def makeone(self, *args, **kw):
|
|
||||||
""" Create the KubernetesInstaller object and return it. """
|
|
||||||
from kubernetes_installer import KubernetesInstaller
|
|
||||||
return KubernetesInstaller(*args, **kw)
|
|
||||||
|
|
||||||
def test_init(self):
|
|
||||||
""" Test that the init method correctly assigns the variables. """
|
|
||||||
ki = self.makeone('i386', '3.0.1', '/tmp/does_not_exist')
|
|
||||||
assert ki.aliases
|
|
||||||
assert 'kube-apiserver' in ki.aliases
|
|
||||||
assert 'kube-controller-manager' in ki.aliases
|
|
||||||
assert 'kube-scheduler' in ki.aliases
|
|
||||||
assert 'kubectl' in ki.aliases
|
|
||||||
assert 'kubelet' in ki.aliases
|
|
||||||
assert ki.arch == 'i386'
|
|
||||||
assert ki.version == '3.0.1'
|
|
||||||
assert ki.output_dir == Path('/tmp/does_not_exist')
|
|
||||||
|
|
||||||
@patch('kubernetes_installer.run')
|
|
||||||
@patch('kubernetes_installer.subprocess.call')
|
|
||||||
def test_build(self, cmock, rmock):
|
|
||||||
""" Test the build method with master and non-master branches. """
|
|
||||||
directory = Path('/tmp/kubernetes_installer_test/build')
|
|
||||||
ki = self.makeone('amd64', 'v99.00.11', directory)
|
|
||||||
assert not directory.exists(), 'The %s directory exists!' % directory
|
|
||||||
# Call the build method with "master" branch.
|
|
||||||
ki.build("master")
|
|
||||||
# TODO: run is called many times but mock only remembers last one.
|
|
||||||
rmock.assert_called_with('git reset --hard origin/master')
|
|
||||||
|
|
||||||
# TODO: call is complex and hard to verify with mock, fix that.
|
|
||||||
# this is not doing what we think it should be doing, magic mock
|
|
||||||
# makes this tricky.
|
|
||||||
# list['foo', 'baz'], env = ANY
|
|
||||||
make_args = ['make', 'all', 'WHAT=cmd/kube-apiserver cmd/kubectl cmd/kube-controller-manager plugin/cmd/kube-scheduler cmd/kubelet cmd/kube-proxy'] # noqa
|
|
||||||
cmock.assert_called_once_with(make_args, env=ANY)
|
|
||||||
|
|
||||||
@patch('kubernetes_installer.run')
|
|
||||||
@patch('kubernetes_installer.subprocess.call')
|
|
||||||
def test_schenanigans(self, cmock, rmock):
|
|
||||||
""" Test the build method with master and non-master branches. """
|
|
||||||
directory = Path('/tmp/kubernetes_installer_test/build')
|
|
||||||
ki = self.makeone('amd64', 'v99.00.11', directory)
|
|
||||||
assert not directory.exists(), 'The %s directory exists!' % directory
|
|
||||||
|
|
||||||
# Call the build method with something other than "master" branch.
|
|
||||||
ki.build("branch")
|
|
||||||
# TODO: run is called many times, but mock only remembers last one.
|
|
||||||
rmock.assert_called_with('git checkout -b v99.00.11 branch')
|
|
||||||
# TODO: call is complex and hard to verify with mock, fix that.
|
|
||||||
assert cmock.called
|
|
||||||
|
|
||||||
directory.rmtree_p()
|
|
||||||
|
|
||||||
def test_install(self):
|
|
||||||
""" Test the install method that it creates the correct links. """
|
|
||||||
directory = Path('/tmp/kubernetes_installer_test/install')
|
|
||||||
ki = self.makeone('ppc64le', '1.2.3', directory)
|
|
||||||
assert not directory.exists(), 'The %s directory exits!' % directory
|
|
||||||
directory.makedirs_p()
|
|
||||||
# Create the files for the install method to link to.
|
|
||||||
(directory / 'kube-apiserver').touch()
|
|
||||||
(directory / 'kube-controller-manager').touch()
|
|
||||||
(directory / 'kube-proxy').touch()
|
|
||||||
(directory / 'kube-scheduler').touch()
|
|
||||||
(directory / 'kubectl').touch()
|
|
||||||
(directory / 'kubelet').touch()
|
|
||||||
|
|
||||||
results = directory / 'install/results/go/here'
|
|
||||||
assert not results.exists()
|
|
||||||
ki.install(results)
|
|
||||||
assert results.isdir()
|
|
||||||
# Check that all the files were correctly aliased and are links.
|
|
||||||
assert (results / 'apiserver').islink()
|
|
||||||
assert (results / 'controller-manager').islink()
|
|
||||||
assert (results / 'kube-proxy').islink()
|
|
||||||
assert (results / 'scheduler').islink()
|
|
||||||
assert (results / 'kubectl').islink()
|
|
||||||
assert (results / 'kubelet').islink()
|
|
||||||
|
|
||||||
directory.rmtree_p()
|
|
||||||
@ -1,116 +0,0 @@
|
|||||||
#!/usr/bin/env python
|
|
||||||
|
|
||||||
# Copyright 2015 The Kubernetes Authors All rights reserved.
|
|
||||||
#
|
|
||||||
# Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
# you may not use this file except in compliance with the License.
|
|
||||||
# You may obtain a copy of the License at
|
|
||||||
#
|
|
||||||
# http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
#
|
|
||||||
# Unless required by applicable law or agreed to in writing, software
|
|
||||||
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
# See the License for the specific language governing permissions and
|
|
||||||
# limitations under the License.
|
|
||||||
|
|
||||||
from mock import patch, Mock, MagicMock
|
|
||||||
from path import Path
|
|
||||||
import pytest
|
|
||||||
import sys
|
|
||||||
|
|
||||||
# Munge the python path so we can find our hook code
|
|
||||||
d = Path('__file__').parent.abspath() / 'hooks'
|
|
||||||
sys.path.insert(0, d.abspath())
|
|
||||||
|
|
||||||
# Import the modules from the hook
|
|
||||||
import install
|
|
||||||
|
|
||||||
|
|
||||||
class TestInstallHook():
|
|
||||||
|
|
||||||
@patch('install.Path')
|
|
||||||
def test_update_rc_files(self, pmock):
|
|
||||||
"""
|
|
||||||
Test happy path on updating env files. Assuming everything
|
|
||||||
exists and is in place.
|
|
||||||
"""
|
|
||||||
pmock.return_value.lines.return_value = ['line1', 'line2']
|
|
||||||
install.update_rc_files(['test1', 'test2'])
|
|
||||||
pmock.return_value.write_lines.assert_called_with(['line1', 'line2',
|
|
||||||
'test1', 'test2'])
|
|
||||||
|
|
||||||
def test_update_rc_files_with_nonexistent_path(self):
|
|
||||||
"""
|
|
||||||
Test an unhappy path if the bashrc/users do not exist.
|
|
||||||
"""
|
|
||||||
p = [Path('/home/deadbeefdoesnotexist/.bashrc')]
|
|
||||||
with pytest.raises(OSError) as exinfo:
|
|
||||||
install.update_rc_files(['test1', 'test2'], rc_files=p)
|
|
||||||
|
|
||||||
@patch('install.fetch')
|
|
||||||
@patch('install.hookenv')
|
|
||||||
def test_package_installation(self, hemock, ftmock):
|
|
||||||
"""
|
|
||||||
Verify we are calling the known essentials to build and syndicate
|
|
||||||
kubes.
|
|
||||||
"""
|
|
||||||
pkgs = ['apache2-utils',
|
|
||||||
'build-essential',
|
|
||||||
'docker.io',
|
|
||||||
'git',
|
|
||||||
'make',
|
|
||||||
'nginx',
|
|
||||||
'python-pip',]
|
|
||||||
install.install_packages()
|
|
||||||
hemock.log.assert_called_with('Installing Debian packages')
|
|
||||||
ftmock.filter_installed_packages.assert_called_with(pkgs)
|
|
||||||
|
|
||||||
@patch('install.archiveurl.ArchiveUrlFetchHandler')
|
|
||||||
def test_go_download(self, aumock):
|
|
||||||
"""
|
|
||||||
Test that we are actually handing off to charm-helpers to
|
|
||||||
download a specific archive of Go. This is non-configurable so
|
|
||||||
its reasonably safe to assume we're going to always do this,
|
|
||||||
and when it changes we shall curse the brittleness of this test.
|
|
||||||
"""
|
|
||||||
ins_mock = aumock.return_value.install
|
|
||||||
install.download_go()
|
|
||||||
url = 'https://storage.googleapis.com/golang/go1.4.2.linux-amd64.tar.gz' # noqa
|
|
||||||
sha1 = '5020af94b52b65cc9b6f11d50a67e4bae07b0aff'
|
|
||||||
ins_mock.assert_called_with(url, '/usr/local', sha1, 'sha1')
|
|
||||||
|
|
||||||
@patch('install.subprocess')
|
|
||||||
def test_clone_repository(self, spmock):
|
|
||||||
"""
|
|
||||||
We're not using a unit-tested git library - so ensure our subprocess
|
|
||||||
call is consistent. If we change this, we want to know we've broken it.
|
|
||||||
"""
|
|
||||||
install.clone_repository()
|
|
||||||
repo = 'https://github.com/kubernetes/kubernetes.git'
|
|
||||||
direct = '/opt/kubernetes'
|
|
||||||
spmock.check_output.assert_called_with(['git', 'clone', repo, direct])
|
|
||||||
|
|
||||||
@patch('install.install_packages')
|
|
||||||
@patch('install.download_go')
|
|
||||||
@patch('install.clone_repository')
|
|
||||||
@patch('install.update_rc_files')
|
|
||||||
@patch('install.Path')
|
|
||||||
@patch('install.hookenv')
|
|
||||||
def test_install_main(self, hemock, pmock, urmock, crmock, dgmock, ipmock):
|
|
||||||
"""
|
|
||||||
Ensure the driver/main method is calling all the supporting methods.
|
|
||||||
"""
|
|
||||||
install.install()
|
|
||||||
|
|
||||||
assert(ipmock.called)
|
|
||||||
assert(dgmock.called)
|
|
||||||
assert(crmock.called)
|
|
||||||
assert(urmock.called)
|
|
||||||
|
|
||||||
assert(pmock.called)
|
|
||||||
pmock.assert_called_with('/srv/kubernetes')
|
|
||||||
|
|
||||||
hemock.open_port.assert_any_call(443)
|
|
||||||
hemock.open_port.assert_any_call(8080)
|
|
||||||
hemock.open_port.assert_any_call(6443)
|
|
||||||
@ -1 +0,0 @@
|
|||||||
.git
|
|
||||||
@ -1,6 +0,0 @@
|
|||||||
.bzr
|
|
||||||
*.pyc
|
|
||||||
*~
|
|
||||||
*\#*
|
|
||||||
/files/.kubernetes-*
|
|
||||||
.venv
|
|
||||||
@ -1,5 +0,0 @@
|
|||||||
omit:
|
|
||||||
- .git
|
|
||||||
- .gitignore
|
|
||||||
- .gitmodules
|
|
||||||
- revision
|
|
||||||
@ -1,43 +0,0 @@
|
|||||||
# Copyright 2016 The Kubernetes Authors All rights reserved.
|
|
||||||
#
|
|
||||||
# Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
# you may not use this file except in compliance with the License.
|
|
||||||
# You may obtain a copy of the License at
|
|
||||||
#
|
|
||||||
# http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
#
|
|
||||||
# Unless required by applicable law or agreed to in writing, software
|
|
||||||
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
# See the License for the specific language governing permissions and
|
|
||||||
# limitations under the License.
|
|
||||||
|
|
||||||
build: virtualenv lint test
|
|
||||||
|
|
||||||
virtualenv:
|
|
||||||
virtualenv .venv
|
|
||||||
.venv/bin/pip install -q -r requirements.txt
|
|
||||||
|
|
||||||
lint: virtualenv
|
|
||||||
@.venv/bin/flake8 hooks --exclude=charmhelpers --ignore=W391
|
|
||||||
@.venv/bin/charm proof
|
|
||||||
|
|
||||||
test: virtualenv
|
|
||||||
@CHARM_DIR=. PYTHONPATH=./hooks .venv/bin/py.test unit_tests/*
|
|
||||||
|
|
||||||
functional-test:
|
|
||||||
@bundletester
|
|
||||||
|
|
||||||
release: check-path virtualenv
|
|
||||||
@.venv/bin/pip install git-vendor
|
|
||||||
@.venv/bin/git-vendor sync -d ${KUBERNETES_BZR}
|
|
||||||
|
|
||||||
check-path:
|
|
||||||
ifndef KUBERNETES_BZR
|
|
||||||
$(error KUBERNETES_BZR is undefined)
|
|
||||||
endif
|
|
||||||
|
|
||||||
clean:
|
|
||||||
rm -rf .venv
|
|
||||||
find -name *.pyc -delete
|
|
||||||
rm -rf unit_tests/.cache
|
|
||||||
@ -1,122 +0,0 @@
|
|||||||
# Kubernetes Node Charm
|
|
||||||
|
|
||||||
[Kubernetes](https://github.com/kubernetes/kubernetes) is an open
|
|
||||||
source system for managing containerized applications across multiple hosts.
|
|
||||||
Kubernetes uses [Docker](http://www.docker.io/) to package, instantiate and run
|
|
||||||
containerized applications.
|
|
||||||
|
|
||||||
The Kubernetes Juju charms enable you to run Kubernetes on all the cloud
|
|
||||||
platforms that Juju supports.
|
|
||||||
|
|
||||||
A Kubernetes deployment consists of several independent charms that can be
|
|
||||||
scaled to meet your needs
|
|
||||||
|
|
||||||
### Etcd
|
|
||||||
Etcd is a key value store for Kubernetes. All persistent master state
|
|
||||||
is stored in `etcd`.
|
|
||||||
|
|
||||||
### Flannel-docker
|
|
||||||
Flannel is a
|
|
||||||
[software defined networking](http://en.wikipedia.org/wiki/Software-defined_networking)
|
|
||||||
component that provides individual subnets for each machine in the cluster.
|
|
||||||
|
|
||||||
### Docker
|
|
||||||
Docker is an open platform for distributing applications for system administrators.
|
|
||||||
|
|
||||||
### Kubernetes master
|
|
||||||
The controlling unit in a Kubernetes cluster is called the master. It is the
|
|
||||||
main management contact point providing many management services for the worker
|
|
||||||
nodes.
|
|
||||||
|
|
||||||
### Kubernetes node
|
|
||||||
The servers that perform the work are known as nodes (previously minions).
|
|
||||||
Nodes must be able to
|
|
||||||
communicate with the master and run the workloads that are assigned to them.
|
|
||||||
|
|
||||||
|
|
||||||
## Usage
|
|
||||||
|
|
||||||
#### Deploying the Development Focus
|
|
||||||
|
|
||||||
To deploy a Kubernetes environment in Juju :
|
|
||||||
|
|
||||||
juju deploy cs:~kubernetes/trusty/etcd
|
|
||||||
juju deploy cs:trusty/flannel-docker
|
|
||||||
juju deploy cs:trusty/docker
|
|
||||||
juju deploy local:trusty/kubernetes-master
|
|
||||||
juju deploy local:trusty/kubernetes
|
|
||||||
|
|
||||||
juju add-relation etcd flannel-docker
|
|
||||||
juju add-relation flannel-docker:network docker:network
|
|
||||||
juju add-relation flannel-docker:docker-host docker
|
|
||||||
juju add-relation etcd kubernetes
|
|
||||||
juju add-relation etcd kubernetes-master
|
|
||||||
juju add-relation kubernetes kubernetes-master
|
|
||||||
|
|
||||||
|
|
||||||
#### Deploying the recommended configuration
|
|
||||||
|
|
||||||
Use the 'juju quickstart' command to deploy a Kubernetes cluster to any cloud
|
|
||||||
supported by Juju.
|
|
||||||
|
|
||||||
The charm store version of the Kubernetes bundle can be deployed as follows:
|
|
||||||
|
|
||||||
juju quickstart u/kubernetes/kubernetes-cluster
|
|
||||||
|
|
||||||
> Note: The charm store bundle may be locked to a specific Kubernetes release.
|
|
||||||
|
|
||||||
Alternately you could deploy a Kubernetes bundle straight from github or a file:
|
|
||||||
|
|
||||||
juju quickstart https://raw.githubusercontent.com/kubernetes/kubernetes/master/cluster/juju/bundles/local.yaml
|
|
||||||
|
|
||||||
The command above does few things for you:
|
|
||||||
|
|
||||||
- Starts a curses based gui for managing your cloud or MAAS credentials
|
|
||||||
- Looks for a bootstrapped deployment environment, and bootstraps if
|
|
||||||
required. This will launch a bootstrap node in your chosen
|
|
||||||
deployment environment (machine 0).
|
|
||||||
- Deploys the Juju GUI to your environment onto the bootstrap node.
|
|
||||||
- Provisions 4 machines, and deploys the Kubernetes services on top of
|
|
||||||
them (Kubernetes-master, two Kubernetes nodes using flannel, and etcd).
|
|
||||||
- Orchestrates the relations among the services, and exits.
|
|
||||||
|
|
||||||
Now you should have a running Kubernetes. Run `juju status
|
|
||||||
--format=oneline` to see the address of your kubernetes-master unit.
|
|
||||||
|
|
||||||
|
|
||||||
#### Post Deployment
|
|
||||||
|
|
||||||
To interact with the kubernetes environment, either build or
|
|
||||||
[download](https://github.com/kubernetes/kubernetes/releases) the
|
|
||||||
[kubectl](https://github.com/kubernetes/kubernetes/blob/master/docs/user-guide/kubectl/kubectl.md)
|
|
||||||
binary (available in the releases binary tarball) and point it to the master with :
|
|
||||||
|
|
||||||
|
|
||||||
$ juju status kubernetes-master | grep public
|
|
||||||
public-address: 104.131.108.99
|
|
||||||
$ export KUBERNETES_MASTER="104.131.108.99"
|
|
||||||
|
|
||||||
# Configuration
|
|
||||||
For you convenience this charm supports changing the version of the Kubernetes
|
|
||||||
release through a configuration option.
|
|
||||||
This can be done through the Juju GUI or on the command line:
|
|
||||||
|
|
||||||
juju set kubernetes version=”v0.10.0”
|
|
||||||
|
|
||||||
If the charm does not already contain the tar file with the desired architecture
|
|
||||||
and version it will attempt to download the kubernetes binaries using the gsutil
|
|
||||||
command.
|
|
||||||
|
|
||||||
Congratulations you know have deployed a Kubernetes environment! Use the
|
|
||||||
[kubectl](https://github.com/kubernetes/kubernetes/blob/master/docs/user-guide/kubectl/kubectl.md)
|
|
||||||
to interact with the environment.
|
|
||||||
|
|
||||||
# Kubernetes information
|
|
||||||
|
|
||||||
- [Kubernetes github project](https://github.com/kubernetes/kubernetes)
|
|
||||||
- [Kubernetes issue tracker](https://github.com/kubernetes/kubernetes/issues)
|
|
||||||
- [Kubernetes Documenation](https://github.com/kubernetes/kubernetes/tree/master/docs)
|
|
||||||
- [Kubernetes releases](https://github.com/kubernetes/kubernetes/releases)
|
|
||||||
|
|
||||||
|
|
||||||
[]()
|
|
||||||
@ -1,13 +0,0 @@
|
|||||||
Copyright 2015 Google Inc. All rights reserved.
|
|
||||||
|
|
||||||
Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
you may not use this file except in compliance with the License.
|
|
||||||
You may obtain a copy of the License at
|
|
||||||
|
|
||||||
http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
|
|
||||||
Unless required by applicable law or agreed to in writing, software
|
|
||||||
distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
See the License for the specific language governing permissions and
|
|
||||||
limitations under the License.
|
|
||||||
@ -1,16 +0,0 @@
|
|||||||
description "cadvisor container metrics"
|
|
||||||
|
|
||||||
start on started docker
|
|
||||||
stop on stopping docker
|
|
||||||
|
|
||||||
limit nofile 20000 20000
|
|
||||||
|
|
||||||
kill timeout 60 # wait 60s between SIGTERM and SIGKILL.
|
|
||||||
|
|
||||||
exec docker run \
|
|
||||||
--volume=/var/run:/var/run:rw \
|
|
||||||
--volume=/sys/fs/cgroup:/sys/fs/cgroup:ro \
|
|
||||||
--volume=/var/lib/docker/:/var/lib/docker:ro \
|
|
||||||
--publish=127.0.0.1:4193:8080 \
|
|
||||||
--name=cadvisor \
|
|
||||||
google/cadvisor:latest
|
|
||||||
@ -1,16 +0,0 @@
|
|||||||
description "kubernetes kubelet"
|
|
||||||
|
|
||||||
start on runlevel [2345]
|
|
||||||
stop on runlevel [!2345]
|
|
||||||
|
|
||||||
limit nofile 20000 20000
|
|
||||||
|
|
||||||
kill timeout 60 # wait 60s between SIGTERM and SIGKILL.
|
|
||||||
|
|
||||||
exec /usr/local/bin/kubelet \
|
|
||||||
--address=%(kubelet_bind_addr)s \
|
|
||||||
--allow-privileged=true \
|
|
||||||
--api-servers=%(kubeapi_server)s \
|
|
||||||
--hostname-override=%(kubelet_bind_addr)s \
|
|
||||||
--cadvisor-port=4193 \
|
|
||||||
--logtostderr=true
|
|
||||||
@ -1,13 +0,0 @@
|
|||||||
description "kubernetes proxy"
|
|
||||||
|
|
||||||
start on runlevel [2345]
|
|
||||||
stop on runlevel [!2345]
|
|
||||||
|
|
||||||
limit nofile 20000 20000
|
|
||||||
|
|
||||||
kill timeout 60 # wait 60s between SIGTERM and SIGKILL.
|
|
||||||
|
|
||||||
exec /usr/local/bin/proxy \
|
|
||||||
--master=%(kubeapi_server)s \
|
|
||||||
--logtostderr=true \
|
|
||||||
--hostname-override=%(kubelet_bind_addr)s
|
|
||||||
@ -1 +0,0 @@
|
|||||||
hooks.py
|
|
||||||
@ -1 +0,0 @@
|
|||||||
hooks.py
|
|
||||||
@ -1,244 +0,0 @@
|
|||||||
#!/usr/bin/env python
|
|
||||||
|
|
||||||
# Copyright 2015 The Kubernetes Authors All rights reserved.
|
|
||||||
#
|
|
||||||
# Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
# you may not use this file except in compliance with the License.
|
|
||||||
# You may obtain a copy of the License at
|
|
||||||
#
|
|
||||||
# http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
#
|
|
||||||
# Unless required by applicable law or agreed to in writing, software
|
|
||||||
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
# See the License for the specific language governing permissions and
|
|
||||||
# limitations under the License.
|
|
||||||
|
|
||||||
"""
|
|
||||||
The main hook file that is called by Juju.
|
|
||||||
"""
|
|
||||||
import os
|
|
||||||
import socket
|
|
||||||
import subprocess
|
|
||||||
import sys
|
|
||||||
import urlparse
|
|
||||||
|
|
||||||
from charmhelpers.core import hookenv, host
|
|
||||||
from kubernetes_installer import KubernetesInstaller
|
|
||||||
from path import Path
|
|
||||||
|
|
||||||
from lib.registrator import Registrator
|
|
||||||
|
|
||||||
hooks = hookenv.Hooks()
|
|
||||||
|
|
||||||
|
|
||||||
@hooks.hook('api-relation-changed')
|
|
||||||
def api_relation_changed():
|
|
||||||
"""
|
|
||||||
On the relation to the api server, this function determines the appropriate
|
|
||||||
architecture and the configured version to copy the kubernetes binary files
|
|
||||||
from the kubernetes-master charm and installs it locally on this machine.
|
|
||||||
"""
|
|
||||||
hookenv.log('Starting api-relation-changed')
|
|
||||||
charm_dir = Path(hookenv.charm_dir())
|
|
||||||
# Get the package architecture, rather than the from the kernel (uname -m).
|
|
||||||
arch = subprocess.check_output(['dpkg', '--print-architecture']).strip()
|
|
||||||
kubernetes_bin_dir = Path('/opt/kubernetes/bin')
|
|
||||||
# Get the version of kubernetes to install.
|
|
||||||
version = subprocess.check_output(['relation-get', 'version']).strip()
|
|
||||||
print('Relation version: ', version)
|
|
||||||
if not version:
|
|
||||||
print('No version present in the relation.')
|
|
||||||
exit(0)
|
|
||||||
version_file = charm_dir / '.version'
|
|
||||||
if version_file.exists():
|
|
||||||
previous_version = version_file.text()
|
|
||||||
print('Previous version: ', previous_version)
|
|
||||||
if version == previous_version:
|
|
||||||
exit(0)
|
|
||||||
# Can not download binaries while the service is running, so stop it.
|
|
||||||
# TODO: Figure out a better way to handle upgraded kubernetes binaries.
|
|
||||||
for service in ('kubelet', 'proxy'):
|
|
||||||
if host.service_running(service):
|
|
||||||
host.service_stop(service)
|
|
||||||
command = ['relation-get', 'private-address']
|
|
||||||
# Get the kubernetes-master address.
|
|
||||||
server = subprocess.check_output(command).strip()
|
|
||||||
print('Kubernetes master private address: ', server)
|
|
||||||
installer = KubernetesInstaller(arch, version, server, kubernetes_bin_dir)
|
|
||||||
installer.download()
|
|
||||||
installer.install()
|
|
||||||
# Write the most recently installed version number to the file.
|
|
||||||
version_file.write_text(version)
|
|
||||||
relation_changed()
|
|
||||||
|
|
||||||
|
|
||||||
@hooks.hook('etcd-relation-changed',
|
|
||||||
'network-relation-changed')
|
|
||||||
def relation_changed():
|
|
||||||
"""Connect the parts and go :-)
|
|
||||||
"""
|
|
||||||
template_data = get_template_data()
|
|
||||||
|
|
||||||
# Check required keys
|
|
||||||
for k in ('etcd_servers', 'kubeapi_server'):
|
|
||||||
if not template_data.get(k):
|
|
||||||
print('Missing data for %s %s' % (k, template_data))
|
|
||||||
return
|
|
||||||
print('Running with\n%s' % template_data)
|
|
||||||
|
|
||||||
# Setup kubernetes supplemental group
|
|
||||||
setup_kubernetes_group()
|
|
||||||
|
|
||||||
# Register upstart managed services
|
|
||||||
for n in ('kubelet', 'proxy'):
|
|
||||||
if render_upstart(n, template_data) or not host.service_running(n):
|
|
||||||
print('Starting %s' % n)
|
|
||||||
host.service_restart(n)
|
|
||||||
|
|
||||||
# Register machine via api
|
|
||||||
print('Registering machine')
|
|
||||||
register_machine(template_data['kubeapi_server'])
|
|
||||||
|
|
||||||
# Save the marker (for restarts to detect prev install)
|
|
||||||
template_data.save()
|
|
||||||
|
|
||||||
|
|
||||||
def get_template_data():
|
|
||||||
rels = hookenv.relations()
|
|
||||||
template_data = hookenv.Config()
|
|
||||||
template_data.CONFIG_FILE_NAME = '.unit-state'
|
|
||||||
|
|
||||||
overlay_type = get_scoped_rel_attr('network', rels, 'overlay_type')
|
|
||||||
etcd_servers = get_rel_hosts('etcd', rels, ('hostname', 'port'))
|
|
||||||
api_servers = get_rel_hosts('api', rels, ('hostname', 'port'))
|
|
||||||
|
|
||||||
# kubernetes master isn't ha yet.
|
|
||||||
if api_servers:
|
|
||||||
api_info = api_servers.pop()
|
|
||||||
api_servers = 'http://%s:%s' % (api_info[0], api_info[1])
|
|
||||||
|
|
||||||
template_data['overlay_type'] = overlay_type
|
|
||||||
template_data['kubelet_bind_addr'] = _bind_addr(
|
|
||||||
hookenv.unit_private_ip())
|
|
||||||
template_data['proxy_bind_addr'] = _bind_addr(
|
|
||||||
hookenv.unit_get('public-address'))
|
|
||||||
template_data['kubeapi_server'] = api_servers
|
|
||||||
template_data['etcd_servers'] = ','.join([
|
|
||||||
'http://%s:%s' % (s[0], s[1]) for s in sorted(etcd_servers)])
|
|
||||||
template_data['identifier'] = os.environ['JUJU_UNIT_NAME'].replace(
|
|
||||||
'/', '-')
|
|
||||||
return _encode(template_data)
|
|
||||||
|
|
||||||
|
|
||||||
def _bind_addr(addr):
|
|
||||||
if addr.replace('.', '').isdigit():
|
|
||||||
return addr
|
|
||||||
try:
|
|
||||||
return socket.gethostbyname(addr)
|
|
||||||
except socket.error:
|
|
||||||
raise ValueError('Could not resolve private address')
|
|
||||||
|
|
||||||
|
|
||||||
def _encode(d):
|
|
||||||
for k, v in d.items():
|
|
||||||
if isinstance(v, unicode):
|
|
||||||
d[k] = v.encode('utf8')
|
|
||||||
return d
|
|
||||||
|
|
||||||
|
|
||||||
def get_scoped_rel_attr(rel_name, rels, attr):
|
|
||||||
private_ip = hookenv.unit_private_ip()
|
|
||||||
for r, data in rels.get(rel_name, {}).items():
|
|
||||||
for unit_id, unit_data in data.items():
|
|
||||||
if unit_data.get('private-address') != private_ip:
|
|
||||||
continue
|
|
||||||
if unit_data.get(attr):
|
|
||||||
return unit_data.get(attr)
|
|
||||||
|
|
||||||
|
|
||||||
def get_rel_hosts(rel_name, rels, keys=('private-address',)):
|
|
||||||
hosts = []
|
|
||||||
for r, data in rels.get(rel_name, {}).items():
|
|
||||||
for unit_id, unit_data in data.items():
|
|
||||||
if unit_id == hookenv.local_unit():
|
|
||||||
continue
|
|
||||||
values = [unit_data.get(k) for k in keys]
|
|
||||||
if not all(values):
|
|
||||||
continue
|
|
||||||
hosts.append(len(values) == 1 and values[0] or values)
|
|
||||||
return hosts
|
|
||||||
|
|
||||||
|
|
||||||
def render_upstart(name, data):
|
|
||||||
tmpl_path = os.path.join(
|
|
||||||
os.environ.get('CHARM_DIR'), 'files', '%s.upstart.tmpl' % name)
|
|
||||||
|
|
||||||
with open(tmpl_path) as fh:
|
|
||||||
tmpl = fh.read()
|
|
||||||
rendered = tmpl % data
|
|
||||||
|
|
||||||
tgt_path = '/etc/init/%s.conf' % name
|
|
||||||
|
|
||||||
if os.path.exists(tgt_path):
|
|
||||||
with open(tgt_path) as fh:
|
|
||||||
contents = fh.read()
|
|
||||||
if contents == rendered:
|
|
||||||
return False
|
|
||||||
|
|
||||||
with open(tgt_path, 'w') as fh:
|
|
||||||
fh.write(rendered)
|
|
||||||
return True
|
|
||||||
|
|
||||||
|
|
||||||
def register_machine(apiserver, retry=False):
|
|
||||||
parsed = urlparse.urlparse(apiserver)
|
|
||||||
# identity = hookenv.local_unit().replace('/', '-')
|
|
||||||
private_address = hookenv.unit_private_ip()
|
|
||||||
|
|
||||||
with open('/proc/meminfo') as fh:
|
|
||||||
info = fh.readline()
|
|
||||||
mem = info.strip().split(':')[1].strip().split()[0]
|
|
||||||
cpus = os.sysconf('SC_NPROCESSORS_ONLN')
|
|
||||||
|
|
||||||
# https://github.com/kubernetes/kubernetes/blob/master/docs/admin/node.md
|
|
||||||
registration_request = Registrator()
|
|
||||||
registration_request.data['kind'] = 'Node'
|
|
||||||
registration_request.data['id'] = private_address
|
|
||||||
registration_request.data['name'] = private_address
|
|
||||||
registration_request.data['metadata']['name'] = private_address
|
|
||||||
registration_request.data['spec']['capacity']['mem'] = mem + ' K'
|
|
||||||
registration_request.data['spec']['capacity']['cpu'] = cpus
|
|
||||||
registration_request.data['spec']['externalID'] = private_address
|
|
||||||
registration_request.data['status']['hostIP'] = private_address
|
|
||||||
|
|
||||||
try:
|
|
||||||
response, result = registration_request.register(parsed.hostname,
|
|
||||||
parsed.port,
|
|
||||||
'/api/v1/nodes')
|
|
||||||
except socket.error:
|
|
||||||
hookenv.status_set('blocked',
|
|
||||||
'Error communicating with Kubenetes Master')
|
|
||||||
return
|
|
||||||
|
|
||||||
print(response)
|
|
||||||
|
|
||||||
try:
|
|
||||||
registration_request.command_succeeded(response, result)
|
|
||||||
except ValueError:
|
|
||||||
# This happens when we have already registered
|
|
||||||
# for now this is OK
|
|
||||||
pass
|
|
||||||
|
|
||||||
|
|
||||||
def setup_kubernetes_group():
|
|
||||||
output = subprocess.check_output(['groups', 'kubernetes'])
|
|
||||||
|
|
||||||
# TODO: check group exists
|
|
||||||
if 'docker' not in output:
|
|
||||||
subprocess.check_output(
|
|
||||||
['usermod', '-a', '-G', 'docker', 'kubernetes'])
|
|
||||||
|
|
||||||
|
|
||||||
if __name__ == '__main__':
|
|
||||||
hooks.execute(sys.argv)
|
|
||||||
@ -1,33 +0,0 @@
|
|||||||
#!/bin/bash
|
|
||||||
|
|
||||||
set -ex
|
|
||||||
|
|
||||||
# Install is guaranteed to run once per rootfs
|
|
||||||
|
|
||||||
echo "Installing kubernetes-node on $JUJU_UNIT_NAME"
|
|
||||||
|
|
||||||
apt-get update -qq
|
|
||||||
apt-get install -q -y \
|
|
||||||
bridge-utils \
|
|
||||||
python-dev \
|
|
||||||
python-pip \
|
|
||||||
wget
|
|
||||||
|
|
||||||
pip install -r $CHARM_DIR/python_requirements.txt
|
|
||||||
|
|
||||||
# Create the necessary kubernetes group.
|
|
||||||
groupadd --force kubernetes
|
|
||||||
|
|
||||||
if grep -q "^kubernetes:" /etc/passwd; then
|
|
||||||
echo "The kubernetes user already exists!"
|
|
||||||
else
|
|
||||||
# Create the user when kubernetes does not exist.
|
|
||||||
useradd -d /var/lib/kubernetes \
|
|
||||||
-g kubernetes \
|
|
||||||
-s /sbin/nologin \
|
|
||||||
--system \
|
|
||||||
kubernetes
|
|
||||||
fi
|
|
||||||
|
|
||||||
install -d -m 0744 -o kubernetes -g kubernetes /var/lib/kubernetes
|
|
||||||
install -d -m 0744 -o kubernetes -g kubernetes /etc/kubernetes/manifests
|
|
||||||
@ -1,68 +0,0 @@
|
|||||||
#!/usr/bin/env python
|
|
||||||
|
|
||||||
# Copyright 2015 The Kubernetes Authors All rights reserved.
|
|
||||||
#
|
|
||||||
# Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
# you may not use this file except in compliance with the License.
|
|
||||||
# You may obtain a copy of the License at
|
|
||||||
#
|
|
||||||
# http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
#
|
|
||||||
# Unless required by applicable law or agreed to in writing, software
|
|
||||||
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
# See the License for the specific language governing permissions and
|
|
||||||
# limitations under the License.
|
|
||||||
|
|
||||||
import subprocess
|
|
||||||
from path import Path
|
|
||||||
|
|
||||||
|
|
||||||
class KubernetesInstaller():
|
|
||||||
"""
|
|
||||||
This class contains the logic needed to install kuberentes binary files.
|
|
||||||
"""
|
|
||||||
|
|
||||||
def __init__(self, arch, version, master, output_dir):
|
|
||||||
""" Gather the required variables for the install. """
|
|
||||||
# The kubernetes charm needs certain commands to be aliased.
|
|
||||||
self.aliases = {'kube-proxy': 'proxy',
|
|
||||||
'kubelet': 'kubelet'}
|
|
||||||
self.arch = arch
|
|
||||||
self.version = version
|
|
||||||
self.master = master
|
|
||||||
self.output_dir = output_dir
|
|
||||||
|
|
||||||
def download(self):
|
|
||||||
""" Download the kuberentes binaries from the kubernetes master. """
|
|
||||||
url = 'http://{0}/kubernetes/{1}/local/bin/linux/{2}'.format(
|
|
||||||
self.master, self.version, self.arch)
|
|
||||||
if not self.output_dir.isdir():
|
|
||||||
self.output_dir.makedirs_p()
|
|
||||||
|
|
||||||
for key in self.aliases:
|
|
||||||
uri = '{0}/{1}'.format(url, key)
|
|
||||||
destination = self.output_dir / key
|
|
||||||
wget = 'wget -nv {0} -O {1}'.format(uri, destination)
|
|
||||||
print(wget)
|
|
||||||
output = subprocess.check_output(wget.split())
|
|
||||||
print(output)
|
|
||||||
destination.chmod(0o755)
|
|
||||||
|
|
||||||
def install(self, install_dir=Path('/usr/local/bin')):
|
|
||||||
""" Create links to the binary files to the install directory. """
|
|
||||||
|
|
||||||
if not install_dir.isdir():
|
|
||||||
install_dir.makedirs_p()
|
|
||||||
|
|
||||||
# Create the symbolic links to the real kubernetes binaries.
|
|
||||||
for key, value in self.aliases.iteritems():
|
|
||||||
target = self.output_dir / key
|
|
||||||
if target.exists():
|
|
||||||
link = install_dir / value
|
|
||||||
if link.exists():
|
|
||||||
link.remove()
|
|
||||||
target.symlink(link)
|
|
||||||
else:
|
|
||||||
print('Error target file {0} does not exist.'.format(target))
|
|
||||||
exit(1)
|
|
||||||
@ -1,16 +0,0 @@
|
|||||||
#!/usr/bin/env python
|
|
||||||
|
|
||||||
# Copyright 2015 The Kubernetes Authors All rights reserved.
|
|
||||||
#
|
|
||||||
# Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
# you may not use this file except in compliance with the License.
|
|
||||||
# You may obtain a copy of the License at
|
|
||||||
#
|
|
||||||
# http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
#
|
|
||||||
# Unless required by applicable law or agreed to in writing, software
|
|
||||||
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
# See the License for the specific language governing permissions and
|
|
||||||
# limitations under the License.
|
|
||||||
|
|
||||||
@ -1,96 +0,0 @@
|
|||||||
#!/usr/bin/env python
|
|
||||||
|
|
||||||
# Copyright 2015 The Kubernetes Authors All rights reserved.
|
|
||||||
#
|
|
||||||
# Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
# you may not use this file except in compliance with the License.
|
|
||||||
# You may obtain a copy of the License at
|
|
||||||
#
|
|
||||||
# http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
#
|
|
||||||
# Unless required by applicable law or agreed to in writing, software
|
|
||||||
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
# See the License for the specific language governing permissions and
|
|
||||||
# limitations under the License.
|
|
||||||
|
|
||||||
import httplib
|
|
||||||
import json
|
|
||||||
import time
|
|
||||||
|
|
||||||
|
|
||||||
class Registrator:
|
|
||||||
|
|
||||||
def __init__(self):
|
|
||||||
self.ds = {
|
|
||||||
"creationTimestamp": "",
|
|
||||||
"kind": "Node",
|
|
||||||
"name": "", # private_address
|
|
||||||
"metadata": {
|
|
||||||
"name": "", # private_address,
|
|
||||||
},
|
|
||||||
"spec": {
|
|
||||||
"externalID": "", # private_address
|
|
||||||
"capacity": {
|
|
||||||
"mem": "", # mem + ' K',
|
|
||||||
"cpu": "", # cpus
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"status": {
|
|
||||||
"conditions": [],
|
|
||||||
"hostIP": "", # private_address
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@property
|
|
||||||
def data(self):
|
|
||||||
''' Returns a data-structure for population to make a request. '''
|
|
||||||
return self.ds
|
|
||||||
|
|
||||||
def register(self, hostname, port, api_path):
|
|
||||||
''' Contact the API Server for a new registration '''
|
|
||||||
headers = {"Content-type": "application/json",
|
|
||||||
"Accept": "application/json"}
|
|
||||||
connection = httplib.HTTPConnection(hostname, port, timeout=12)
|
|
||||||
print 'CONN {}'.format(connection)
|
|
||||||
connection.request("POST", api_path, json.dumps(self.data), headers)
|
|
||||||
response = connection.getresponse()
|
|
||||||
body = response.read()
|
|
||||||
print(body)
|
|
||||||
result = json.loads(body)
|
|
||||||
print("Response status:%s reason:%s body:%s" %
|
|
||||||
(response.status, response.reason, result))
|
|
||||||
return response, result
|
|
||||||
|
|
||||||
def update(self):
|
|
||||||
''' Contact the API Server to update a registration '''
|
|
||||||
# do a get on the API for the node
|
|
||||||
# repost to the API with any modified data
|
|
||||||
pass
|
|
||||||
|
|
||||||
def save(self):
|
|
||||||
''' Marshall the registration data '''
|
|
||||||
# TODO
|
|
||||||
pass
|
|
||||||
|
|
||||||
def command_succeeded(self, response, result):
|
|
||||||
''' Evaluate response data to determine if the command successful '''
|
|
||||||
if response.status in [200, 201, 409]:
|
|
||||||
# The 409 response is when a unit is already registered. We do not
|
|
||||||
# have an update method above, so for now, accept whats in etcd and
|
|
||||||
# assume registered.
|
|
||||||
print("Registered")
|
|
||||||
return True
|
|
||||||
elif response.status in (500,) and result.get(
|
|
||||||
'message', '').startswith('The requested resource does not exist'): # noqa
|
|
||||||
# There is something fishy in the kube api here (0.4 dev), first
|
|
||||||
# time to register a new node, we always seem to get this error.
|
|
||||||
# http://issue.k8s.io/1995
|
|
||||||
time.sleep(1)
|
|
||||||
print("Retrying registration...")
|
|
||||||
raise ValueError("Registration returned 500, retry")
|
|
||||||
# return register_machine(apiserver, retry=True)
|
|
||||||
else:
|
|
||||||
print("Registration error")
|
|
||||||
# TODO - get request data
|
|
||||||
raise RuntimeError("Unable to register machine with")
|
|
||||||
@ -1 +0,0 @@
|
|||||||
hooks.py
|
|
||||||
@ -1,15 +0,0 @@
|
|||||||
#!/bin/bash
|
|
||||||
|
|
||||||
set -ex
|
|
||||||
|
|
||||||
# Start is guaranteed to be called once when after the unit is installed
|
|
||||||
# *AND* once every time a machine is rebooted.
|
|
||||||
|
|
||||||
if [ ! -f $CHARM_DIR/.unit-state ]
|
|
||||||
then
|
|
||||||
exit 0;
|
|
||||||
fi
|
|
||||||
|
|
||||||
service docker restart
|
|
||||||
service proxy restart
|
|
||||||
service kubelet restart
|
|
||||||
File diff suppressed because one or more lines are too long
|
Before Width: | Height: | Size: 76 KiB |
@ -1,23 +0,0 @@
|
|||||||
name: kubernetes
|
|
||||||
summary: Container Cluster Management Node
|
|
||||||
maintainers:
|
|
||||||
- Matt Bruzek <matthew.bruzek@canonical.com>
|
|
||||||
- Whit Morriss <whit.morriss@canonical.com>
|
|
||||||
- Charles Butler <charles.butler@canonical.com>
|
|
||||||
description: |
|
|
||||||
Provides a kubernetes node for running containers
|
|
||||||
See http://goo.gl/CSggxE
|
|
||||||
tags:
|
|
||||||
- ops
|
|
||||||
- network
|
|
||||||
subordinate: true
|
|
||||||
requires:
|
|
||||||
etcd:
|
|
||||||
interface: etcd
|
|
||||||
api:
|
|
||||||
interface: kubernetes-api
|
|
||||||
network:
|
|
||||||
interface: overlay-network
|
|
||||||
docker-host:
|
|
||||||
interface: juju-info
|
|
||||||
scope: container
|
|
||||||
@ -1 +0,0 @@
|
|||||||
path.py
|
|
||||||
@ -1,4 +0,0 @@
|
|||||||
flake8
|
|
||||||
pytest
|
|
||||||
bundletester
|
|
||||||
path.py
|
|
||||||
@ -1,60 +0,0 @@
|
|||||||
#!/usr/bin/env python
|
|
||||||
|
|
||||||
# Copyright 2015 The Kubernetes Authors All rights reserved.
|
|
||||||
#
|
|
||||||
# Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
# you may not use this file except in compliance with the License.
|
|
||||||
# You may obtain a copy of the License at
|
|
||||||
#
|
|
||||||
# http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
#
|
|
||||||
# Unless required by applicable law or agreed to in writing, software
|
|
||||||
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
# See the License for the specific language governing permissions and
|
|
||||||
# limitations under the License.
|
|
||||||
|
|
||||||
import json
|
|
||||||
from mock import MagicMock, patch
|
|
||||||
from path import Path
|
|
||||||
import pytest
|
|
||||||
import sys
|
|
||||||
|
|
||||||
d = Path('__file__').parent.abspath() / 'hooks'
|
|
||||||
sys.path.insert(0, d.abspath())
|
|
||||||
|
|
||||||
from lib.registrator import Registrator
|
|
||||||
|
|
||||||
|
|
||||||
class TestRegistrator():
|
|
||||||
|
|
||||||
def setup_method(self, method):
|
|
||||||
self.r = Registrator()
|
|
||||||
|
|
||||||
def test_data_type(self):
|
|
||||||
if type(self.r.data) is not dict:
|
|
||||||
pytest.fail("Invalid type")
|
|
||||||
|
|
||||||
@patch('json.loads')
|
|
||||||
@patch('httplib.HTTPConnection')
|
|
||||||
def test_register(self, httplibmock, jsonmock):
|
|
||||||
self.r.register('foo', 80, '/v1/test')
|
|
||||||
|
|
||||||
httplibmock.assert_called_with('foo', 80, timeout=12)
|
|
||||||
requestmock = httplibmock().request
|
|
||||||
requestmock.assert_called_with(
|
|
||||||
"POST", "/v1/test",
|
|
||||||
json.dumps(self.r.data),
|
|
||||||
{"Content-type": "application/json",
|
|
||||||
"Accept": "application/json"})
|
|
||||||
|
|
||||||
def test_command_succeeded(self):
|
|
||||||
response = MagicMock()
|
|
||||||
result = json.loads('{"status": "Failure", "kind": "Status", "code": 409, "apiVersion": "v1", "reason": "AlreadyExists", "details": {"kind": "node", "name": "10.200.147.200"}, "message": "node \\"10.200.147.200\\" already exists", "creationTimestamp": null}') # noqa
|
|
||||||
response.status = 200
|
|
||||||
self.r.command_succeeded(response, result)
|
|
||||||
response.status = 409
|
|
||||||
self.r.command_succeeded(response, result)
|
|
||||||
response.status = 500
|
|
||||||
with pytest.raises(RuntimeError):
|
|
||||||
self.r.command_succeeded(response, result)
|
|
||||||
@ -1,24 +0,0 @@
|
|||||||
#!/usr/bin/env python
|
|
||||||
|
|
||||||
# Copyright 2015 The Kubernetes Authors All rights reserved.
|
|
||||||
#
|
|
||||||
# Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
# you may not use this file except in compliance with the License.
|
|
||||||
# You may obtain a copy of the License at
|
|
||||||
#
|
|
||||||
# http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
#
|
|
||||||
# Unless required by applicable law or agreed to in writing, software
|
|
||||||
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
# See the License for the specific language governing permissions and
|
|
||||||
# limitations under the License.
|
|
||||||
|
|
||||||
# import pytest
|
|
||||||
|
|
||||||
|
|
||||||
class TestHooks():
|
|
||||||
|
|
||||||
# TODO: Actually write tests.
|
|
||||||
def test_fake(self):
|
|
||||||
pass
|
|
||||||
Loading…
Reference in New Issue
Block a user