Initial commit

Author: webwurst

Dockerfile

@@ -0,0 +1,12 @@
+FROM python:3.6-alpine
+
+RUN pip install \
+  "kubernetes==1.0.0b1" \
+  "jinja2~=2.9.5" \
+  "pyyaml~=3.12" \
+  "click~=6.7"
+
+WORKDIR /usr/src/app
+COPY . /usr/src/app
+
+CMD ["python", "./opy.py"]

README.md

@@ -1 +1,45 @@
-# operator-example-python
+# Kubernetes Operator
+
+Experimantal example written in Python. Work in progress. Improve me if you like :)
+
+
+Some commands to test:
+
+```bash
+docker build --tag local/opy .
+
+context="my-kubectl-config-context"
+
+
+kubectl --context $context apply --filename ./ghost/ghost-thirdparty.yaml
+
+docker run -v $HOME/.kube:/root/.kube -t local/opy python opy.py \
+  --context $context \
+  --api-version experimantal.giantswarm.com/v1 \
+  --kind Ghost
+
+kubectl --context $context create --filename ./ghost/ghost-1.yaml
+
+kubectl --context $context create --filename ./ghost/ghost-2.yaml
+
+kubectl --context $context get --all-namespaces ghosts
+
+
+kubectl --context $context get --all-namespaces ingress -o wide
+
+kubectl --context $context run -ti --rm tiny-tools --image giantswarm/tiny-tools curl ghost-1.ghost-test-1.svc:2368
+
+
+kubectl --context $context --namespace ghost-test-1 delete ghost ghost-1
+
+kubectl --context $context --namespace ghost-another-test delete ghost ghost-2
+
+kubectl --context $context delete thirdpartyresource ghost.experimantal.giantswarm.com
+
+kubectl --context $context delete namespace --now ghost-test-1
+
+kubectl --context $context delete namespace --now ghost-another-test
+
+kubectl --context $context get namespaces
+
+```

generic_api.py

@@ -0,0 +1,52 @@
+from __future__ import absolute_import
+import sys
+import os
+import re
+
+# python 2 and python 3 compatibility library
+from six import iteritems
+
+from kubernetes.client.configuration import Configuration
+from kubernetes.client.api_client import ApiClient
+
+
+class GenericApi(object):
+
+    def __init__(self, api_client=None):
+        config = Configuration()
+        if api_client:
+            self.api_client = api_client
+        else:
+            if not config.api_client:
+                config.api_client = ApiClient()
+            self.api_client = config.api_client
+
+    def list_generic(self, **kwargs):
+        # print(kwargs)
+        kwargs['_return_http_data_only'] = True
+        if kwargs.get('callback'):
+            return self._list_generic(**kwargs)
+        else:
+            (data) = self._list_generic(**kwargs)
+            print(data)
+            return data
+
+    def _list_generic(self, **kwargs):
+        resource_path = kwargs.pop('resource_path')
+        kwargs['header_params'] = {
+          'Accept': self.api_client.select_header_accept(['application/json', 'application/json;stream=watch']),
+          'Content-Type': self.api_client.select_header_content_type(['*/*'])
+        }
+        kwargs['auth_settings'] = ['BearerToken']
+        kwargs['response_type'] = object
+        if 'query_params' not in kwargs:
+          kwargs['query_params'] = {}
+        if 'timeout_seconds' in kwargs:
+            kwargs['query_params']['timeoutSeconds'] = kwargs.pop('timeout_seconds')
+        if 'watch' in kwargs:
+            kwargs['query_params']['watch'] = kwargs.pop('watch')
+        return self.api_client.call_api(resource_path, 'GET', **kwargs)
+
+    def call_api(self, resource_path, method, **kwargs):
+        kwargs['response_type'] = object
+        return self.api_client.call_api(resource_path, method, **kwargs)

ghost/ghost-1.yaml

@@ -0,0 +1,16 @@
+apiVersion: experimantal.giantswarm.com/v1
+kind: Ghost
+metadata:
+  name: ghost-1
+  namespace: ghost-test-1
+spec:
+  url: "ghost-1.kube.thisone.rocks"
+  mail:
+    from: '"Custom Name" <myemail@address.com>'
+    service:
+      type: Sparkpost
+      auth:
+        user: SMTP_Injection
+        pass:
+  database:
+    client: sqlite3

ghost/ghost-2.yaml

@@ -0,0 +1,16 @@
+apiVersion: experimantal.giantswarm.com/v1
+kind: Ghost
+metadata:
+  name: ghost-2
+  namespace: ghost-another-test
+spec:
+  # url: "ghost-2.some.other.url"
+  mail:
+    from: '"Custom Name" <myemail@address.com>'
+    service:
+      type: Sparkpost
+      auth:
+        user: SMTP_Injection
+        pass:
+  database:
+    client: sqlite3

ghost/ghost-thirdparty.yaml

@@ -0,0 +1,7 @@
+apiVersion: extensions/v1beta1
+kind: ThirdPartyResource
+description: "An operator to manage Ghost deployments."
+metadata:
+  name: "ghost.experimantal.giantswarm.com"
+versions:
+  - name: v1

ghost/manifests/0-namespace.yaml

@@ -0,0 +1,4 @@
+apiVersion: v1
+kind: Namespace
+metadata:
+  name: {{ metadata.namespace }}

ghost/manifests/configmap.yaml

@@ -0,0 +1,42 @@
+apiVersion: v1
+kind: ConfigMap
+metadata:
+  name: {{ metadata.name }}
+  namespace: {{ metadata.namespace }}
+  labels:
+    app: {{ metadata.name }}
+    thirdparty: ghost
+data:
+  config.example.js: |
+    var path = require('path'),
+      config;
+
+    config = {
+      production: {
+        url: '{{ spec.url }}',
+          mail: {
+            transport: 'SMTP',
+            options: {
+              service: '{{ spec.mail.service.type }}',
+              auth: {
+                user: '{{ spec.mail.service.auth.user }}',
+                pass: '{{ spec.mail.service.auth.pass }}'
+              }
+            }
+          },
+        database: {
+          # if mariadb, sqlite3, ..
+          client: 'sqlite3',
+          connection: {
+            filename: path.join(__dirname, '/content/data/ghost.db')
+          },
+          debug: false
+        },
+        server: {
+          host: '0.0.0.0',
+          port: '2368'
+        }
+      }
+    };
+
+    module.exports = config;

ghost/manifests/deployment.yaml

@@ -0,0 +1,72 @@
+apiVersion: extensions/v1beta1
+kind: Deployment
+metadata:
+  name: {{ metadata.name }}
+  namespace: {{ metadata.namespace }}
+  labels:
+    app: {{ metadata.name }}
+    thirdparty: ghost
+spec:
+  replicas: 1
+  template:
+    metadata:
+      labels:
+        app: {{ metadata.name }}
+        thirdparty: ghost
+    spec:
+      containers:
+      - name: {{ metadata.name }}
+        # image: bitnami/ghost
+        image: ghost:0.11.3
+        imagePullPolicy: IfNotPresent
+        # env:
+        # - name: MARIADB_HOST
+        #   value: mariadb
+        # - name: MARIADB_PORT
+        #   value: "3306"
+        # - name: MARIADB_PASSWORD
+        #   value: ghost
+        #   # valueFrom:
+        #   #   secretKeyRef:
+        # - name: GHOST_HOST
+        #   value: {{ host }}
+        # # - name: GHOST_PORT
+        # - name: GHOST_USERNAME
+        #   value: admin
+        # - name: GHOST_PASSWORD
+        #   value: password
+        #   # valueFrom:
+        #   #   secretKeyRef:
+        #   #     name:
+        #   #     key: ghost-password
+        ports:
+        - name: http
+          containerPort: 2368
+        livenessProbe:
+          httpGet:
+            path: /
+            port: http
+          initialDelaySeconds: 120
+          timeoutSeconds: 5
+        # readinessProbe:
+        #   exec:
+        #     command:
+        #     - sh
+        #     - -c
+        #     - nami status ghost | grep "ghost is running"
+        #   initialDelaySeconds: 5
+        #   timeoutSeconds: 1
+#         resources:
+      #   volumeMounts:
+      #   - name: ghost-data
+      #     mountPath: /bitnami/ghost
+      # volumes:
+      # - name: ghost-data
+      #   emptyDir: {}
+
+      # - name: config
+      #   configmap > /etc/ghost
+
+      # /var/lib/ghost/content for content?
+      #    apps, data, images and themes
+      #    ^needed, maybe init-container

ghost/manifests/ingress.yaml

@@ -0,0 +1,27 @@
+apiVersion: extensions/v1beta1
+kind: Ingress
+metadata:
+  name: {{ metadata.name }}
+  namespace: {{ metadata.namespace }}
+  labels:
+    app: {{ metadata.name }}
+    thirdparty: Ghost
+  # annotations:
+  #   kubernetes.io/tls-acme: "true"
+spec:
+  # rules:
+  # - host: {{ spec.url }}
+  #   http:
+  #     paths:
+  #     - path: /
+  #       backend:
+  #         serviceName: {{ metadata.name }}
+  #         servicePort: 2368
+  # tls:
+  # - secretName: {{ metadata.name }}-tls
+  #   hosts:
+  #   - {{ spec.url }}
+
+  backend:
+    serviceName: {{ metadata.name }}
+    servicePort: 2368