Merge pull request #53 from hjacobs/mock

Mock

README.rst

@@ -61,6 +61,18 @@ Afterwards you can open "kube-ops-view" via the kubectl proxy:
 Now direct your browser to http://localhost:8001/api/v1/proxy/namespaces/default/services/kube-ops-view/
 
 
+Mock Mode
+=========
+
+You can start the app in "mock mode" to see all UI features without running any Kubernetes cluster:
+
+.. code-block:: bash
+
+    $ pip3 install -r requirements.txt
+    $ (cd app && npm start &)
+    $ MOCK=true ./app.py
+
+
 Configuration
 =============
 
@@ -71,7 +83,9 @@ The following environment variables are supported:
 ``CREDENTIALS_DIR``
     Directory to read (OAuth) credentials from --- these credentials are only used for non-localhost cluster URLs.
 ``DEBUG``
-    Set to a non-empty value for local development to reload code changes.
+    Set to "true" for local development to reload code changes.
+``MOCK``
+    Set to "true" to mock Kubernetes cluster data.
 
 
 Supported Browsers

app.py

@@ -22,9 +22,10 @@ DEFAULT_CLUSTERS = 'http://localhost:8001/'
 CREDENTIALS_DIR = os.getenv('CREDENTIALS_DIR', '')
 AUTHORIZE_URL = os.getenv('AUTHORIZE_URL')
 APP_URL = os.getenv('APP_URL')
+MOCK = os.getenv('MOCK', '').lower() == 'true'
 
 app = Flask(__name__)
-app.debug = os.getenv('DEBUG') == 'true'
+app.debug = os.getenv('DEBUG', '').lower() == 'true'
 app.secret_key = os.getenv('SECRET_KEY', 'development')
 
 oauth = OAuth(app)
@@ -98,9 +99,49 @@ def index():
     return flask.render_template('index.html', app_js=app_js)
 
 
-@app.route('/kubernetes-clusters')
+def hash_int(x: int):
-@authorize
+    x = ((x >> 16) ^ x) * 0x45d9f3b
-def get_clusters():
+    x = ((x >> 16) ^ x) * 0x45d9f3b
+    x = (x >> 16) ^ x
+    return x
+
+
+def generate_mock_cluster_data(index: int):
+    '''Generate deterministic (no randomness!) mock data'''
+    nodes = []
+    pod_phases = ['Pending', 'Running', 'Running']
+    for i in range(10):
+        labels = {}
+        if i < 2:
+            labels['master'] = 'true'
+        pods = []
+        for j in range(hash_int((index + 1) * (i + 1)) % 32):
+            phase = pod_phases[hash_int((index + 1) * (i + 1) * (j + 1)) % len(pod_phases)]
+            containers = []
+            for k in range(1):
+                containers.append({'name': 'myapp', 'image': 'foo/bar/{}'.format(j), 'resources': {'requests': {'cpu': '100m', 'memory': '100Mi'}}})
+            status = {'phase': phase}
+            if phase == 'Running':
+                if j % 10 == 0:
+                    status['containerStatuses'] = [{'ready': False, 'state': {'waiting': {'reason': 'CrashLoopBackOff'}}}]
+            pods.append({'name': 'my-pod-{}'.format(j), 'namespace': 'kube-system' if j < 3 else 'default', 'labels': labels, 'status': status, 'containers': containers})
+        nodes.append({'name': 'node-{}'.format(i), 'labels': labels, 'status': {'capacity': {'cpu': '4', 'memory': '32Gi', 'pods': '110'}}, 'pods': pods})
+    unassigned_pods = []
+    return {
+        'api_server_url': 'https://kube-{}.example.org'.format(index),
+        'nodes': nodes,
+        'unassigned_pods': unassigned_pods
+    }
+
+
+def get_mock_clusters():
+    clusters = []
+    for i in range(3):
+        clusters.append(generate_mock_cluster_data(i))
+    return clusters
+
+
+def get_kubernetes_clusters():
     clusters = []
     for api_server_url in (os.getenv('CLUSTERS') or DEFAULT_CLUSTERS).split(','):
         if 'localhost' not in api_server_url:
@@ -152,6 +193,16 @@ def get_clusters():
         except:
             logging.exception('Failed to get metrics')
         clusters.append({'api_server_url': api_server_url, 'nodes': nodes, 'unassigned_pods': unassigned_pods})
+    return clusters
+
+
+@app.route('/kubernetes-clusters')
+@authorize
+def get_clusters():
+    if MOCK:
+        clusters = get_mock_clusters()
+    else:
+        clusters = get_kubernetes_clusters()
 
     return json.dumps({'kubernetes_clusters': clusters}, separators=(',', ':'))
 

app/src/app.js

@@ -101,7 +101,7 @@ export default class App {
     }
 
     animatePodCreation(originalPod, globalX, globalY) {
-        const pod = new Pod(originalPod.pod, this.tooltip, false)
+        const pod = new Pod(originalPod.pod, this.tooltip, null)
         pod.draw()
         const targetPosition = new PIXI.Point(globalX, globalY)
         const angle = Math.random()*Math.PI*2

app/src/cluster.js

@@ -13,7 +13,7 @@ export default class Cluster extends PIXI.Graphics {
     draw () {
         var rows = [10, 10]
         for (var node of this.cluster.nodes) {
-            var nodeBox = new Node(node, this.tooltip)
+            var nodeBox = new Node(node, this, this.tooltip)
             nodeBox.draw()
             if (nodeBox.isMaster()) {
                 nodeBox.x = rows[0]
@@ -30,7 +30,7 @@ export default class Cluster extends PIXI.Graphics {
 
 
         for (const pod of this.cluster.unassigned_pods) {
-            var podBox = Pod.getOrCreate(pod, this.tooltip)
+            var podBox = Pod.getOrCreate(pod, this, this.tooltip)
             podBox.x = rows[0]
             podBox.y = 20
             podBox.draw()

app/src/node.js

@@ -4,9 +4,10 @@ import {parseResource} from './utils.js'
 const PIXI = require('pixi.js')
 
 export default class Node extends PIXI.Graphics {
-    constructor(node, tooltip) {
+    constructor(node, cluster, tooltip) {
         super()
         this.node = node
+        this.cluster = cluster
         this.tooltip = tooltip
     }
 
@@ -82,7 +83,7 @@ export default class Node extends PIXI.Graphics {
         var py = 20
         for (const pod of this.node.pods) {
             if (pod.namespace != 'kube-system') {
-                const podBox = Pod.getOrCreate(pod, this.tooltip) //new Pod(pod, this.tooltip)
+                const podBox = Pod.getOrCreate(pod, this.cluster, this.tooltip) //new Pod(pod, this.tooltip)
                 podBox.x = px
                 podBox.y = py
                 nodeBox.addChild(podBox.draw())
@@ -98,7 +99,7 @@ export default class Node extends PIXI.Graphics {
         py = 100
         for (const pod of this.node.pods) {
             if (pod.namespace == 'kube-system') {
-                const podBox = Pod.getOrCreate(pod, this.tooltip) //new Pod(pod, this.tooltip)
+                const podBox = Pod.getOrCreate(pod, this.cluster, this.tooltip) //new Pod(pod, this.tooltip)
                 podBox.x = px
                 podBox.y = py
                 nodeBox.addChild(podBox.draw())

app/src/pod.js

@@ -5,15 +5,15 @@ export const ALL_PODS = {}
 
 export class Pod extends PIXI.Graphics {
 
-    constructor(pod, tooltip, register=true) {
+    constructor(pod, tooltip, cluster) {
         super()
         this.pod = pod
         this.tooltip = tooltip
         this.tick = null
         this._progress = 1
 
-        if (register) {
+        if (cluster) {
-            ALL_PODS[pod.namespace + '/' + pod.name] = this
+            ALL_PODS[cluster.cluster.api_server_url + '/' + pod.namespace + '/' + pod.name] = this
         }
     }
 
@@ -51,8 +51,8 @@ export class Pod extends PIXI.Graphics {
         }
     }
 
-    static getOrCreate(pod, tooltip) {
+    static getOrCreate(pod, cluster, tooltip) {
-        const existingPod = ALL_PODS[pod.namespace + '/' + pod.name]
+        const existingPod = ALL_PODS[cluster.cluster.api_server_url + '/' + pod.namespace + '/' + pod.name]
         if (existingPod) {
             existingPod.pod = pod
             existingPod.clear()

tox.ini

@@ -0,0 +1,3 @@
+[flake8]
+max-line-length=120
+ignore=E402