Rename kubernetes processor -> add_kubernetes_metadata

filebeat/processor/kubernetes/indexing.go → filebeat/processor/add_kubernetes_metadata/indexing.go

@@ -1,23 +1,23 @@
-package kubernetes
+package add_kubernetes_metadata
 
 import (
 	"fmt"
 	"strings"
 
 	"github.com/elastic/beats/libbeat/common"
 	"github.com/elastic/beats/libbeat/logp"
-	"github.com/elastic/beats/libbeat/processors/kubernetes"
+	"github.com/elastic/beats/libbeat/processors/add_kubernetes_metadata"
 )
 
 func init() {
-	kubernetes.Indexing.AddMatcher(LogPathMatcherName, newLogsPathMatcher)
+	add_kubernetes_metadata.Indexing.AddMatcher(LogPathMatcherName, newLogsPathMatcher)
 	cfg := common.NewConfig()
 
 	//Add a container indexer config by default.
-	kubernetes.Indexing.AddDefaultIndexerConfig(kubernetes.ContainerIndexerName, *cfg)
+	add_kubernetes_metadata.Indexing.AddDefaultIndexerConfig(add_kubernetes_metadata.ContainerIndexerName, *cfg)
 
 	//Add a log path matcher which can extract container ID from the "source" field.
-	kubernetes.Indexing.AddDefaultMatcherConfig(LogPathMatcherName, *cfg)
+	add_kubernetes_metadata.Indexing.AddDefaultMatcherConfig(LogPathMatcherName, *cfg)
 }
 
 const LogPathMatcherName = "logs_path"
@@ -26,7 +26,7 @@ type LogPathMatcher struct {
 	LogsPath string
 }
 
-func newLogsPathMatcher(cfg common.Config) (kubernetes.Matcher, error) {
+func newLogsPathMatcher(cfg common.Config) (add_kubernetes_metadata.Matcher, error) {
 	config := struct {
 		LogsPath string `config:"logs_path"`
 	}{

filebeat/processor/kubernetes/indexing_test.go → filebeat/processor/add_kubernetes_metadata/indexing_test.go

@@ -1,4 +1,4 @@
-package kubernetes
+package add_kubernetes_metadata
 
 import (
 	"fmt"

libbeat/beat/beat.go

@@ -65,8 +65,8 @@ import (
 	_ "github.com/elastic/beats/libbeat/processors/actions"
 	_ "github.com/elastic/beats/libbeat/processors/add_cloud_metadata"
 	_ "github.com/elastic/beats/libbeat/processors/add_docker_metadata"
+	_ "github.com/elastic/beats/libbeat/processors/add_kubernetes_metadata"
 	_ "github.com/elastic/beats/libbeat/processors/add_locale"
-	_ "github.com/elastic/beats/libbeat/processors/kubernetes"
 
 	// Register default monitoring reporting
 	_ "github.com/elastic/beats/libbeat/monitoring/report/elasticsearch"

libbeat/docs/processors-using.asciidoc

@@ -43,7 +43,7 @@ The supported processors are:
  * <<drop-event,`drop_event`>>
  * <<drop-fields,`drop_fields`>>
  * <<include-fields,`include_fields`>>
- * <<kubernetes,`kubernetes`>>
+ * <<add-kubernetes-metadata,`add_kubernetes_metadata`>>
  * <<add-docker-metadata,`add_docker_metadata`>>
 
 [[conditions]]
@@ -492,17 +492,18 @@ section.
 NOTE: If you define an empty list of fields under `include_fields`, then only
 the required fields, `@timestamp` and `type`, are exported.
 
-[[kubernetes]]
+[[add-kubernetes-metadata]]
 === Adding Kubernetes Metadata
 
-The `kubernetes` processor annotates each event with relevant metadata based on
-which Kubernetes pod the event originated from. Each event is annotated with:
+The `add_kubernetes_metadata` processor annotates each event with relevant
+metadata based on which Kubernetes pod the event originated from. Each event is
+annotated with:
 
 * Pod Name
 * Namespace
 * Labels
 
-The `kubernetes` processor has two basic building blocks which are:
+The `add_kubernetes_metadata` processor has two basic building blocks which are:
 
 * Indexers
 * Matchers
@@ -526,7 +527,7 @@ Kubernetes.
 [source,yaml]
 -------------------------------------------------------------------------------
 processors:
-- kubernetes:
+- add_kubernetes_metadata:
     in_cluster: true
 -------------------------------------------------------------------------------
 
@@ -536,7 +537,7 @@ the Kubernetes node.
 [source,yaml]
 -------------------------------------------------------------------------------
 processors:
-- kubernetes:
+- add_kubernetes_metadata:
     in_cluster: false
     host: <hostname>
     kube_config: ${HOME}/.kube/config
@@ -548,7 +549,7 @@ enables ones that the user is interested in.
 [source,yaml]
 -------------------------------------------------------------------------------
 processors:
-- kubernetes:
+- add_kubernetes_metadata:
     in_cluster: false
     host: <hostname>
     kube_config: ~/.kube/config

libbeat/processors/kubernetes/config.go → libbeat/processors/add_kubernetes_metadata/config.go

@@ -1,4 +1,4 @@
-package kubernetes
+package add_kubernetes_metadata
 
 import (
 	"time"

libbeat/processors/kubernetes/indexing.go → libbeat/processors/add_kubernetes_metadata/indexing.go

@@ -1,4 +1,4 @@
-package kubernetes
+package add_kubernetes_metadata
 
 import (
 	"fmt"

libbeat/processors/kubernetes/indexing_test.go → libbeat/processors/add_kubernetes_metadata/indexing_test.go

@@ -1,4 +1,4 @@
-package kubernetes
+package add_kubernetes_metadata
 
 import (
 	"testing"

libbeat/processors/kubernetes/kubernetes.go → libbeat/processors/add_kubernetes_metadata/kubernetes.go

@@ -1,4 +1,4 @@
-package kubernetes
+package add_kubernetes_metadata
 
 import (
 	"context"
@@ -30,7 +30,7 @@ type kubernetesAnnotator struct {
 }
 
 func init() {
-	processors.RegisterPlugin("kubernetes", newKubernetesAnnotator)
+	processors.RegisterPlugin("add_kubernetes_metadata", newKubernetesAnnotator)
 
 	// Register default indexers
 	Indexing.AddIndexer(PodNameIndexerName, NewPodNameIndexer)
@@ -208,7 +208,7 @@ func (k kubernetesAnnotator) Run(event common.MapStr) (common.MapStr, error) {
 	return event, nil
 }
 
-func (k kubernetesAnnotator) String() string { return "kubernetes" }
+func (k kubernetesAnnotator) String() string { return "add_kubernetes_metadata" }
 
 func validate(config kubeAnnotatorConfig) error {
 	if !config.InCluster && config.KubeConfig == "" {

libbeat/processors/kubernetes/podwatcher.go → libbeat/processors/add_kubernetes_metadata/podwatcher.go

@@ -1,4 +1,4 @@
-package kubernetes
+package add_kubernetes_metadata
 
 import (
 	"context"

libbeat/processors/kubernetes/registry.go → libbeat/processors/add_kubernetes_metadata/registry.go

@@ -1,4 +1,4 @@
-package kubernetes
+package add_kubernetes_metadata
 
 import (
 	"errors"

libbeat/processors/kubernetes/types.go → libbeat/processors/add_kubernetes_metadata/types.go

@@ -1,4 +1,4 @@
-package kubernetes
+package add_kubernetes_metadata
 
 type ObjectMeta struct {
 	Annotations       map[string]string `json:"annotations"`