forked from TencentBlueKing/beats
-
Notifications
You must be signed in to change notification settings - Fork 0
/
data.go
102 lines (90 loc) · 2.41 KB
/
data.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
package container
import (
"encoding/json"
"fmt"
"github.com/elastic/beats/libbeat/common"
"github.com/elastic/beats/metricbeat/mb"
"github.com/elastic/beats/metricbeat/module/kubernetes"
)
func eventMapping(content []byte) ([]common.MapStr, error) {
events := []common.MapStr{}
var summary kubernetes.Summary
err := json.Unmarshal(content, &summary)
if err != nil {
return nil, fmt.Errorf("Cannot unmarshal json response: %s", err)
}
node := summary.Node
for _, pod := range summary.Pods {
for _, container := range pod.Containers {
containerEvent := common.MapStr{
mb.ModuleDataKey: common.MapStr{
"namespace": pod.PodRef.Namespace,
"node": common.MapStr{
"name": node.NodeName,
},
"pod": common.MapStr{
"name": pod.PodRef.Name,
},
},
"name": container.Name,
"start_time": container.StartTime,
"cpu": common.MapStr{
"usage": common.MapStr{
"nanocores": container.CPU.UsageNanoCores,
"core": common.MapStr{
"ns": container.CPU.UsageCoreNanoSeconds,
},
},
},
"memory": common.MapStr{
"available": common.MapStr{
"bytes": container.Memory.AvailableBytes,
},
"usage": common.MapStr{
"bytes": container.Memory.UsageBytes,
},
"workingset": common.MapStr{
"bytes": container.Memory.WorkingSetBytes,
},
"rss": common.MapStr{
"bytes": container.Memory.RssBytes,
},
"pagefaults": container.Memory.PageFaults,
"majorpagefaults": container.Memory.MajorPageFaults,
},
"rootfs": common.MapStr{
"available": common.MapStr{
"bytes": container.Rootfs.AvailableBytes,
},
"capacity": common.MapStr{
"bytes": container.Rootfs.CapacityBytes,
},
"used": common.MapStr{
"bytes": container.Rootfs.UsedBytes,
},
"inodes": common.MapStr{
"used": container.Rootfs.InodesUsed,
},
},
"logs": common.MapStr{
"available": common.MapStr{
"bytes": container.Logs.AvailableBytes,
},
"capacity": common.MapStr{
"bytes": container.Logs.CapacityBytes,
},
"used": common.MapStr{
"bytes": container.Logs.UsedBytes,
},
"inodes": common.MapStr{
"used": container.Logs.InodesUsed,
"free": container.Logs.InodesFree,
"count": container.Logs.Inodes,
},
},
}
events = append(events, containerEvent)
}
}
return events, nil
}