Merge pull request #154 from getanteon/feat/named-ports

Feat/named ports

aggregator/persist.go

@@ -82,17 +82,20 @@ func (a *Aggregator) processSvc(d k8s.K8sResourceMessage) {
 	service := d.Object.(*corev1.Service)
 
 	ports := []struct {
+		Name     string "json:\"name\""
 		Src      int32  "json:\"src\""
 		Dest     int32  "json:\"dest\""
 		Protocol string "json:\"protocol\""
 	}{}
 
 	for _, port := range service.Spec.Ports {
 		ports = append(ports, struct {
+			Name     string "json:\"name\""
 			Src      int32  "json:\"src\""
 			Dest     int32  "json:\"dest\""
 			Protocol string "json:\"protocol\""
 		}{
+			Name:     port.Name, // https://kubernetes.io/docs/concepts/services-networking/service/#field-spec-ports
 			Src:      port.Port,
 			Dest:     int32(port.TargetPort.IntValue()),
 			Protocol: string(port.Protocol),
@@ -268,6 +271,7 @@ func (a *Aggregator) processEndpoints(ep k8s.K8sResourceMessage) {
 			ports = append(ports, datastore.AddressPort{
 				Port:     port.Port,
 				Protocol: string(port.Protocol),
+				Name:     port.Name,
 			})
 		}
 

datastore/dto.go

@@ -19,6 +19,7 @@ type Service struct {
 	ClusterIP  string
 	ClusterIPs []string
 	Ports      []struct {
+		Name     string `json:"name"`
 		Src      int32  `json:"src"`
 		Dest     int32  `json:"dest"`
 		Protocol string `json:"protocol"`
@@ -72,6 +73,7 @@ type AddressIP struct {
 type AddressPort struct {
 	Port     int32  `json:"port"`     // Port number
 	Protocol string `json:"protocol"` // TCP or UDP
+	Name     string `json:"name"`
 }
 
 // Subsets

datastore/payload.go

@@ -46,6 +46,7 @@ type SvcEvent struct {
 	Type       string   `json:"type"`
 	ClusterIPs []string `json:"cluster_ips"`
 	Ports      []struct {
+		Name     string `json:"name"`
 		Src      int32  `json:"src"`
 		Dest     int32  `json:"dest"`
 		Protocol string `json:"protocol"`