github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-28 22:17:14 +00:00
Code Issues Projects Releases Wiki Activity

Adding metric for latency of SyncPods (synching all pods).

Browse Source
This commit is contained in:
Victor Marmol 2015-02-26 09:16:52 -08:00
parent 1444e59fc9
commit a9301b1996
2 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
pkg/kubelet/kubelet.go
View File

@ -1275,6 +1275,9 @@ func (kl *Kubelet) cleanupOrphanedVolumes(pods []api.BoundPod, running []*docker
// SyncPods synchronizes the configured list of pods (desired state) with the host current state. // SyncPods synchronizes the configured list of pods (desired state) with the host current state.
func (kl *Kubelet) SyncPods(pods []api.BoundPod, podSyncTypes map[types.UID]metrics.SyncPodType, start time.Time) error { func (kl *Kubelet) SyncPods(pods []api.BoundPod, podSyncTypes map[types.UID]metrics.SyncPodType, start time.Time) error {
defer func() {
metrics.SyncPodsLatency.Observe(metrics.SinceInMicroseconds(start))
}()
glog.V(4).Infof("Desired: %#v", pods) glog.V(4).Infof("Desired: %#v", pods)
var err error var err error
desiredContainers := make(map[podContainer]empty) desiredContainers := make(map[podContainer]empty)

9
pkg/kubelet/metrics/metrics.go
View File

@ -45,8 +45,14 @@ var (
}, },
[]string{"operation_type"}, []string{"operation_type"},
) )
SyncPodsLatency = prometheus.NewSummary(
prometheus.SummaryOpts{
Subsystem: kubeletSubsystem,
Name: "sync_pods_latency_microseconds",
Help: "Latency in microseconds to sync all pods.",
},
)
// TODO(vmarmol): Containers per pod // TODO(vmarmol): Containers per pod
// TODO(vmarmol): Latency of SyncPods
DockerOperationsLatency = prometheus.NewSummaryVec( DockerOperationsLatency = prometheus.NewSummaryVec(
prometheus.SummaryOpts{ prometheus.SummaryOpts{
Subsystem: kubeletSubsystem, Subsystem: kubeletSubsystem,
@ -66,6 +72,7 @@ func Register(containerCache dockertools.DockerCache) {
prometheus.MustRegister(ImagePullLatency) prometheus.MustRegister(ImagePullLatency)
prometheus.MustRegister(SyncPodLatency) prometheus.MustRegister(SyncPodLatency)
prometheus.MustRegister(DockerOperationsLatency) prometheus.MustRegister(DockerOperationsLatency)
prometheus.MustRegister(SyncPodsLatency)
prometheus.MustRegister(newPodAndContainerCollector(containerCache)) prometheus.MustRegister(newPodAndContainerCollector(containerCache))
}) })
} }