72 lines
1.4 KiB
Go
72 lines
1.4 KiB
Go
|
package kube_inventory
|
||
|
|
|
||
|
|
import (
|
||
|
|
"context"
|
||
|
|
|
||
|
|
corev1 "k8s.io/api/core/v1"
|
||
|
|
|
||
|
|
"github.com/influxdata/telegraf"
|
||
|
|
)
|
||
|
|
|
||
|
|
func collectServices(ctx context.Context, acc telegraf.Accumulator, ki *KubernetesInventory) {
|
||
|
|
list, err := ki.client.getServices(ctx)
|
||
|
|
if err != nil {
|
||
|
|
acc.AddError(err)
|
||
|
|
return
|
||
|
|
}
|
||
|
|
for i := range list.Items {
|
||
|
|
ki.gatherService(&list.Items[i], acc)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
func (ki *KubernetesInventory) gatherService(s *corev1.Service, acc telegraf.Accumulator) {
|
||
|
|
creationTS := s.GetCreationTimestamp()
|
||
|
|
if creationTS.IsZero() {
|
||
|
|
return
|
||
|
|
}
|
||
|
|
|
||
|
|
fields := map[string]interface{}{
|
||
|
|
"created": s.GetCreationTimestamp().UnixNano(),
|
||
|
|
"generation": s.Generation,
|
||
|
|
}
|
||
|
|
|
||
|
|
tags := map[string]string{
|
||
|
|
"service_name": s.Name,
|
||
|
|
"namespace": s.Namespace,
|
||
|
|
}
|
||
|
|
|
||
|
|
for key, val := range s.Spec.Selector {
|
||
|
|
if ki.selectorFilter.Match(key) {
|
||
|
|
tags["selector_"+key] = val
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
var getPorts = func() {
|
||
|
|
for _, port := range s.Spec.Ports {
|
||
|
|
fields["port"] = port.Port
|
||
|
|
fields["target_port"] = port.TargetPort.IntVal
|
||
|
|
|
||
|
|
tags["port_name"] = port.Name
|
||
|
|
tags["port_protocol"] = string(port.Protocol)
|
||
|
|
|
||
|
|
if s.Spec.Type == "ExternalName" {
|
||
|
|
tags["external_name"] = s.Spec.ExternalName
|
||
|
|
} else {
|
||
|
|
tags["cluster_ip"] = s.Spec.ClusterIP
|
||
|
|
}
|
||
|
|
|
||
|
|
acc.AddFields(serviceMeasurement, fields, tags)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
if externIPs := s.Spec.ExternalIPs; externIPs != nil {
|
||
|
|
for _, ip := range externIPs {
|
||
|
|
tags["ip"] = ip
|
||
|
|
|
||
|
|
getPorts()
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
getPorts()
|
||
|
|
}
|
||
|
|
}
|