Merge pull request #94 from eranra/add_hostip

add hostip for k8s

Author: eranra

README.md

@@ -307,7 +307,7 @@ The fifth rule `add_kubernetes` generates new fields with kubernetes information
 matching the `input` value (`srcIP` in the example above) with kubernetes `nodes`, `pods` and `services` IPs.
 All the kubernetes fields will be named by appending `output` value
 (`srcK8S` in the example above) to the kubernetes metadata field names
-(e.g., `Namespace`, `Name`, `Type`, `OwnerName`, `OwnerType` )
+(e.g., `Namespace`, `Name`, `Type`, `HostIP`, `OwnerName`, `OwnerType` )
 
 In addition, if the `parameters` value is not empty, fields with kubernetes labels 
 will be generated, and named by appending `parameters` value to the label keys.   

pkg/pipeline/transform/kubernetes/kubernetes.go

@@ -62,6 +62,7 @@ type Info struct {
 	Labels          map[string]string
 	OwnerReferences []metav1.OwnerReference
 	Owner           Owner
+	HostIP          string
 }
 
 func (k *KubeData) GetInfo(ip string) (*Info, error) {
@@ -78,6 +79,7 @@ func (k *KubeData) GetInfo(ip string) (*Info, error) {
 					Namespace:       pod.Namespace,
 					Labels:          pod.Labels,
 					OwnerReferences: pod.OwnerReferences,
+					HostIP:          pod.Status.HostIP,
 				}
 			case typeNode:
 				node := objs[0].(*v1.Node)

pkg/pipeline/transform/kubernetes/kubernetes_test.go

@@ -43,7 +43,7 @@ type InformerInterface interface {
 }
 
 func (indexMock *IndexerMock) ByIndex(indexName, indexedValue string) ([]interface{}, error) {
-	pod := fakePod("podName", "podNamespace", "podHost")
+	pod := fakePod("podName", "podNamespace", "podHostIP")
 	podInterface := interface{}(pod)
 	return []interface{}{podInterface}, nil
 }
@@ -77,6 +77,7 @@ func TestKubeData_getInfo(t *testing.T) {
 		Type:      "Pod",
 		Name:      "podName",
 		Namespace: "podNamespace",
+		HostIP:    "podHostIP",
 		Owner:     Owner{Name: "podName", Type: "Pod"},
 	}
 	kubeData = KubeData{ipInformers: map[string]cache.SharedIndexInformer{}}

pkg/pipeline/transform/transform_network.go

@@ -140,6 +140,9 @@ func (n *Network) Transform(inputEntry config.GenericMap) config.GenericMap {
 					outputEntries[rule.Parameters+"_"+labelKey] = labelValue
 				}
 			}
+			if kubeInfo.HostIP != "" {
+				outputEntries[rule.Output+"_HostIP"] = kubeInfo.HostIP
+			}
 		default:
 			log.Panicf("unknown type %s for transform.Network rule: %v", rule.Type, rule)
 		}