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
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
|
// SPDX-License-Identifier: GPL-3.0-or-later
package k8s_state
import (
"sync"
"time"
corev1 "k8s.io/api/core/v1"
)
func newKubeState() *kubeState {
return &kubeState{
Mutex: &sync.Mutex{},
nodes: make(map[string]*nodeState),
pods: make(map[string]*podState),
}
}
func newNodeState() *nodeState {
return &nodeState{
new: true,
labels: make(map[string]string),
conditions: make(map[string]*nodeStateCondition),
}
}
func newPodState() *podState {
return &podState{
new: true,
labels: make(map[string]string),
initContainers: make(map[string]*containerState),
containers: make(map[string]*containerState),
}
}
func newContainerState() *containerState {
return &containerState{
new: true,
stateWaitingReasons: make(map[string]*containerStateReason),
stateTerminatedReasons: make(map[string]*containerStateReason),
}
}
type kubeState struct {
*sync.Mutex
nodes map[string]*nodeState
pods map[string]*podState
}
type (
nodeState struct {
new bool
deleted bool
name string
unSchedulable bool
labels map[string]string
creationTime time.Time
allocatableCPU int64
allocatableMem int64
allocatablePods int64
conditions map[string]*nodeStateCondition
stats nodeStateStats
}
nodeStateCondition struct {
new bool
// https://kubernetes.io/docs/concepts/architecture/nodes/#condition
//typ corev1.NodeConditionType
status corev1.ConditionStatus
}
nodeStateStats struct {
reqCPU int64
limitCPU int64
reqMem int64
limitMem int64
pods int64
podsCondPodReady int64
podsCondPodScheduled int64
podsCondPodInitialized int64
podsCondContainersReady int64
podsReadinessReady int64
podsReadinessUnready int64
podsPhaseRunning int64
podsPhaseFailed int64
podsPhaseSucceeded int64
podsPhasePending int64
containers int64
initContainers int64
initContStateRunning int64
initContStateWaiting int64
initContStateTerminated int64
contStateRunning int64
contStateWaiting int64
contStateTerminated int64
}
)
func (ns nodeState) id() string { return ns.name }
func (ns *nodeState) resetStats() { ns.stats = nodeStateStats{} }
type (
podState struct {
new bool
deleted bool
unscheduled bool
name string
nodeName string
namespace string
uid string
labels map[string]string
controllerKind string
controllerName string
qosClass string
creationTime time.Time
reqCPU int64
reqMem int64
limitCPU int64
limitMem int64
// https://kubernetes.io/docs/concepts/workloads/pods/pod-lifecycle/#pod-conditions
condPodScheduled corev1.ConditionStatus
condContainersReady corev1.ConditionStatus
condPodInitialized corev1.ConditionStatus
condPodReady corev1.ConditionStatus
// https://kubernetes.io/docs/concepts/workloads/pods/pod-lifecycle/#pod-phase
phase corev1.PodPhase
initContainers map[string]*containerState
containers map[string]*containerState
}
)
func (ps podState) id() string { return ps.namespace + "_" + ps.name }
type (
containerState struct {
new bool
name string
uid string
podName string
nodeName string
namespace string
ready bool
restarts int64
stateRunning bool
stateWaiting bool
stateTerminated bool
stateWaitingReasons map[string]*containerStateReason
stateTerminatedReasons map[string]*containerStateReason
}
containerStateReason struct {
new bool
reason string
active bool
}
)
|
