Add NATS Streaming provisioner

Gopkg.toml

@@ -87,3 +87,15 @@ required = [
   name = "sigs.k8s.io/controller-runtime"
   # HEAD as of 2018-09-19
   revision = "5373e8e1f3188ff4266902a6fc86372bc14b3815"
+
+[[override]]
+  name = "github.com/nats-io/go-nats"
+  version = "1.6.0"
+
+[[override]]
+  name = "github.com/nats-io/go-nats-streaming"
+  version = "0.4.0"
+
+[[override]]
+  name = "github.com/nats-io/nats-streaming-server"
+  version = "0.11.0"

config/provisioners/natss/README.md

@@ -0,0 +1,44 @@
+# NATS Streaming Channels
+
+
+### Deployment steps:
+
+1. Setup [Knative Eventing](../../../DEVELOPMENT.md).
+1. If not done already, install a [NATS Streaming](natss)  
+1. Apply the 'natss' ClusterChannelProvisioner, Controller, and Dispatcher.
+     ```shell
+     ko apply -f config/provisioners/natss/provisioner.yaml
+     ````
+1. Create Channels that reference the 'natss'.
+
+    ```yaml
+    apiVersion: eventing.knative.dev/v1alpha1
+    kind: Channel
+    metadata:
+      name: foo
+    spec:
+      provisioner:
+        apiVersion: eventing.knative.dev/v1alpha1
+        kind: ClusterChannelProvisioner
+        name: natss
+    ```
+
+### Components
+
+The major components are:
+* NATS Streaming
+* ClusterChannelProvisioner Controller
+* Channel Controller
+* Channel Dispatcher
+
+The ClusterChannelProvisioner Controller and the Channel Controller are colocated in one Pod.
+```shell
+kubectl get deployment -n knative-eventing natss-controller
+```
+
+The Channel Dispatcher receives and distributes all events. There is a single Dispatcher for all
+natss Channels.
+```shell
+kubectl get deployment -n knative-eventing natss-dispatcher
+```
+

config/provisioners/natss/natss/README.md

@@ -0,0 +1,12 @@
+# NATS Streaming - simple installation
+
+1. For an installation of a simple NATS Streaming server, a setup is provided:
+   ```sbtshell
+   kubectl create namespace natss
+   kubectl label namespace natss istio-injection=enabled
+   kubectl apply -n natss -f config/provisioners/natss/natss/natss.yaml
+   ```
+NATS Streaming is deployed as a StatefulSet, using "nats-streaming" ConfigMap in the namespace "natss". 
+
+For tuning NATS Streaming, see:
+https://github.com/nats-io/nats-streaming-server#configuring

config/provisioners/natss/natss/natss.yaml

@@ -0,0 +1,101 @@
+apiVersion: v1
+kind: ConfigMap
+metadata:
+  labels:
+    app: nats-streaming
+  name: nats-streaming
+  namespace: natss
+data:
+  gnatsd.conf: |
+    # configuration file used to override default NATS server settings
+  stan.conf: |
+    # content of configuration file used to override default NATS Streaming server settings
+---  
+apiVersion: v1
+kind: Service
+metadata:
+  name: nats-streaming
+  namespace: natss
+  labels:
+    app: nats-streaming
+spec:
+  type: ClusterIP
+  ports:
+  - name: client
+    port: 4222
+    protocol: TCP
+    targetPort: client
+  selector:
+    app: nats-streaming
+  sessionAffinity: None
+---
+apiVersion: apps/v1beta1
+kind: StatefulSet
+metadata:
+  name: nats-streaming
+  namespace: natss
+  labels:
+    app: nats-streaming
+spec:
+  serviceName: nats-streaming
+  replicas: 1
+  selector:
+    matchLabels:
+      app: nats-streaming
+  template:
+    metadata:
+      annotations:
+        sidecar.istio.io/inject: "true"
+      labels:
+        app: nats-streaming
+    spec:
+      containers:
+        - name: nats-streaming
+          image: nats-streaming:0.11.0
+          imagePullPolicy: IfNotPresent
+          args:
+          - -D
+          - -SD
+          - --cluster_id=knative-nats-streaming
+          - --http_port=8222
+          - --max_age=24h
+          - --store=FILE
+          - --dir=/var/lib/nats-streaming/core-nats-streaming/$(POD_NAME)
+          - --port=4222
+          - --config=/etc/nats-streaming/core-nats-streaming/gnatsd.conf
+          - --stan_config=/etc/nats-streaming/core-nats-streaming/stan.conf
+          env:
+            - name: POD_NAME
+              valueFrom:
+                fieldRef:
+                  fieldPath: metadata.name
+          ports:
+          - containerPort: 4222
+            name: client
+            protocol: TCP
+          - containerPort: 8222
+            name: monitoring
+            protocol: TCP            
+          volumeMounts:
+          - mountPath: /var/lib/nats-streaming/core-nats-streaming
+            name: datadir
+          - mountPath: /etc/nats-streaming/core-nats-streaming
+            name: config-volume
+          resources:
+            requests:
+              cpu: "100m"
+            limits:
+              memory: "32M"          
+      volumes:
+      - configMap:
+          name: nats-streaming
+        name: config-volume
+  volumeClaimTemplates:
+  - metadata:
+      name: datadir
+    spec:
+      accessModes:
+        - "ReadWriteOnce"
+      resources:
+        requests:
+          storage: "1Gi"