50 lines
1.3 KiB
Go
50 lines
1.3 KiB
Go
|
package kube_inventory
|
||
|
|
|
||
|
|
import (
|
||
|
|
"context"
|
||
|
|
|
||
|
|
apps "k8s.io/api/apps/v1"
|
||
|
|
|
||
|
|
"github.com/influxdata/telegraf"
|
||
|
|
)
|
||
|
|
|
||
|
|
func collectDaemonSets(ctx context.Context, acc telegraf.Accumulator, ki *KubernetesInventory) {
|
||
|
|
list, err := ki.client.getDaemonSets(ctx)
|
||
|
|
if err != nil {
|
||
|
|
acc.AddError(err)
|
||
|
|
return
|
||
|
|
}
|
||
|
|
for i := range list.Items {
|
||
|
|
ki.gatherDaemonSet(&list.Items[i], acc)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
func (ki *KubernetesInventory) gatherDaemonSet(d *apps.DaemonSet, acc telegraf.Accumulator) {
|
||
|
|
fields := map[string]interface{}{
|
||
|
|
"generation": d.Generation,
|
||
|
|
"current_number_scheduled": d.Status.CurrentNumberScheduled,
|
||
|
|
"desired_number_scheduled": d.Status.DesiredNumberScheduled,
|
||
|
|
"number_available": d.Status.NumberAvailable,
|
||
|
|
"number_misscheduled": d.Status.NumberMisscheduled,
|
||
|
|
"number_ready": d.Status.NumberReady,
|
||
|
|
"number_unavailable": d.Status.NumberUnavailable,
|
||
|
|
"updated_number_scheduled": d.Status.UpdatedNumberScheduled,
|
||
|
|
}
|
||
|
|
tags := map[string]string{
|
||
|
|
"daemonset_name": d.Name,
|
||
|
|
"namespace": d.Namespace,
|
||
|
|
}
|
||
|
|
for key, val := range d.Spec.Selector.MatchLabels {
|
||
|
|
if ki.selectorFilter.Match(key) {
|
||
|
|
tags["selector_"+key] = val
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
creationTS := d.GetCreationTimestamp()
|
||
|
|
if !creationTS.IsZero() {
|
||
|
|
fields["created"] = d.GetCreationTimestamp().UnixNano()
|
||
|
|
}
|
||
|
|
|
||
|
|
acc.AddFields(daemonSetMeasurement, fields, tags)
|
||
|
|
}
|