Loki output (#102)

- Loki plugin example
- Fluentbit fix version
- New logo

README.md

@@ -1,4 +1,4 @@
-<p align="center"><img src="docs/img/logo.png" width="260"></p>
+<p align="center"><img src="docs/img/logging.svg" width="260"></p>
 <p align="center">
 
   <a href="https://hub.docker.com/r/banzaicloud/logging-operator/">
@@ -65,7 +65,7 @@ Logging-operator is a core part of the [Pipeline](https://beta.banzaicloud.io) p
 
 This operator helps you to pack together logging information with your applications. With the help of Custom Resource Definition you can describe the behaviour of your application within its charts. The operator does the rest.
 
-<p align="center"><img src="docs/img/log_helm.gif" width="660"></p>
+<p align="center"><img src="docs/img/loggingo_flow.png" width="660"></p>
 
 ## Example with helm chart
 The following steps set up an example configuration for sending nginx logs to S3.

deploy/crds/logging_v1alpha1_fluentbit_cr.yaml

@@ -13,7 +13,7 @@ spec:
   tls:
     enabled: false
   image:
-    tag: "latest"
+    tag: "1.1.3"
     repository: "fluent/fluent-bit"
     pullPolicy: "IfNotPresent"
   resources: {}

deploy/crds/logging_v1alpha1_fluentd_cr.yaml

@@ -13,7 +13,7 @@ spec:
   tls:
     enabled: false
   image:
-    tag: "v1.4.2"
+    tag: "v1.5.0"
     repository: "banzaicloud/fluentd"
     pullPolicy: "IfNotPresent"
   volumeModImage:

docs/plugins/loki.md

@@ -0,0 +1,27 @@
+# Plugin loki
+## Variables
+| Variable name | Default | Applied function |
+|---|---|---|
+| pattern | - |  |
+| url | - | loki url |
+| username | - |  |
+| password | - |  |
+| extraLabels | - |  |
+| flushInterval | 10s |  |
+| chunkLimitSize | 1m |  |
+| flushAtShutdown | true |  |
+## Plugin template
+```
+<match {{ .pattern }}.**>
+  @type kubernetes_loki
+  url {{ .url }}
+  username {{ .username }}
+  password {{ .password }}
+  extra_labels {{ .extraLabels }}
+  <buffer>
+    flush_interval {{ .flushInterval }}
+    chunk_limit_size {{ .chunkLimitSize }}
+    flush_at_shutdown {{ .flushAtShutdown }}
+  </buffer>
+</match>
+```

example/loki_output.yaml

@@ -0,0 +1,24 @@
+apiVersion: "logging.banzaicloud.com/v1alpha1"
+kind: "Plugin"
+metadata:
+  name: "loki-demo"
+spec:
+  input:
+    label:
+      app: "nginx-logging-demo"
+  output:
+    - type: "loki"
+      name: "loki-demo"
+      parameters:
+        - name: url
+          value: "http://loki:3100"
+        - name: username
+          value: ""
+        - name: password
+          value: ""
+        - name: extraLabels
+          value: "{\"env\":\"dev\"}"
+        - name: flushInterval
+          value: "10s"
+        - name: bufferChunkLimit
+          value: "1m"

pkg/resources/plugins/init.go

@@ -74,4 +74,5 @@ func init() {
 	RegisterPlugin(AlibabaOutput, AlibabaTemplate, AlibabaDefaultValues)
 	RegisterPlugin(ParserFilter, ParserFilterTemplate, ParserFilterDefaultValues)
 	RegisterPlugin(ElasticsearchOutput, ElasticsearchTemplate, ElasticsearchDefaultValues)
+	RegisterPlugin(LokiOutput, LokiTemplate, LokiDefaultValues)
 }

pkg/resources/plugins/loki.go

@@ -0,0 +1,46 @@
+/*
+ * Copyright © 2019 Banzai Cloud
+ *
+ * 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.
+ */
+
+package plugins
+
+// LokiOutput CRD name
+const LokiOutput = "loki"
+
+// LokiDefaultValues for Loki output plugin
+var LokiDefaultValues = map[string]string{
+	"url":             "",
+	"username":        "",
+	"password":        "",
+	"extraLabels":     "",
+	"flushInterval":   "10s",
+	"chunkLimitSize":  "1m",
+	"flushAtShutdown": "true",
+}
+
+// LokiTemplate for Loki output plugin
+const LokiTemplate = `
+<match {{ .pattern }}.**>
+  @type kubernetes_loki
+  url {{ .url }}
+  username {{ .username }}
+  password {{ .password }}
+  extra_labels {{ .extraLabels }}
+  <buffer>
+    flush_interval {{ .flushInterval }}
+    chunk_limit_size {{ .chunkLimitSize }}
+    flush_at_shutdown {{ .flushAtShutdown }}
+  </buffer>
+</match>`