Add oss_integration to logging operator

Author: baluchicken

cmd/logging-operator/fluentd/fluentd.go

@@ -424,7 +424,7 @@ func newFluentdDeployment(fdc *fluentdDeploymentConfig) *extensionv1.Deployment
 					Containers: []corev1.Container{
 						{
 							Name:  "fluentd",
-							Image: "banzaicloud/fluentd:v1.1.3",
+							Image: "banzaicloud/fluentd:v1.1.4",
 							Ports: []corev1.ContainerPort{
 								{
 									Name:          "monitor",

pkg/plugins/alibaba.go

@@ -0,0 +1,28 @@
+package plugins
+
+// AlibabaOutput CRD name
+const AlibabaOutput = "alibaba"
+
+// AlibabaDefaultValues for Alibaba OSS output plugin
+var AlibabaDefaultValues = map[string]string{
+	"buffer_chunk_limit": "256m",
+	"buffer_path":        "/buffers/ali",
+	"time_slice_format":  "%Y%m%d",
+	"time_slice_wait":    "10m",
+}
+
+// AlibabaTemplate for Alibaba OSS output plugin
+const AlibabaTemplate = `
+<match {{ .pattern }}.**>
+  @type oss
+  oss_key_id {{ .aliKeyId }}
+  oss_key_secret {{ .aliKeySecret }}
+  oss_bucket {{ .bucket }}
+  oss_endpoint {{ .aliBucketEndpoint }}
+  oss_object_key_format "%{time_slice}/%{host}-%{uuid}.%{file_ext}"
+
+  buffer_path /buffers/ali
+  buffer_chunk_limit 256m
+  time_slice_format %Y%m%d
+  time_slice_wait 10m
+</match>`

pkg/plugins/azure.go

@@ -3,15 +3,15 @@ package plugins
 // AzureOutput CRD name
 const AzureOutput = "azure"
 
-// AzureDefaultValues for Google Cloud Storage output plugin
+// AzureDefaultValues for Azure ObjectStore output plugin
 var AzureDefaultValues = map[string]string{
 	"bufferTimeKey":  "3600",
 	"bufferTimeWait": "10m",
 	"bufferPath":     "/buffers/azure",
 	"format":         "json",
 }
 
-// AzureTemplate for Google Cloud Storage output plugin
+// AzureTemplate for Azure ObjectStore output plugin
 const AzureTemplate = `
 <match {{ .pattern }}.**>
   @type azurestorage

pkg/plugins/init.go

@@ -45,5 +45,6 @@ func init() {
 	RegisterPlugin(S3Output, S3Template, S3DefaultValues)
 	RegisterPlugin(GCSOutput, GCSTemplate, GCSDefaultValues)
 	RegisterPlugin(AzureOutput, AzureTemplate, AzureDefaultValues)
+	RegisterPlugin(AlibabaOutput, AlibabaTemplate, AlibabaDefaultValues)
 	RegisterPlugin(ParserFilter, ParserFilterTemplate, ParserFilterDefaultValues)
 }