- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 23 for Sandboxes (0.13 sec)
-
pkg/kubelet/kuberuntime/util/util_test.go
pod *v1.Pod status *kubecontainer.PodStatus expectedChanged bool expectedAttempt uint32 expectedSandboxID string }{ "Pod with no existing sandboxes": { pod: &v1.Pod{}, status: &kubecontainer.PodStatus{}, expectedChanged: true, expectedAttempt: 0, expectedSandboxID: "", },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 13 23:14:48 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_manager_test.go
}) } podSandBoxStatus.Network.AdditionalIps = additionalPodIPs return podSandBoxStatus } // makeFakePodSandboxes creates a group of fake pod sandboxes based on the sandbox templates. // The function guarantees the order of the fake pod sandboxes is the same with the templates. func makeFakePodSandboxes(t *testing.T, m *kubeGenericRuntimeManager, templates []sandboxTemplate) []*apitest.FakePodSandbox {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 96K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_manager.go
func (m *kubeGenericRuntimeManager) GetPods(ctx context.Context, all bool) ([]*kubecontainer.Pod, error) { pods := make(map[kubetypes.UID]*kubecontainer.Pod) sandboxes, err := m.getKubeletSandboxes(ctx, all) if err != nil { return nil, err } for i := range sandboxes { s := sandboxes[i] if s.Metadata == nil { klog.V(4).InfoS("Sandbox does not have metadata", "sandbox", s) continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 22 02:01:31 UTC 2024 - 64.7K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/helpers.go
State: toKubeContainerState(c.State), }, nil } // sandboxToKubeContainer converts runtimeapi.PodSandbox to kubecontainer.Container. // This is only needed because we need to return sandboxes as if they were // kubecontainer.Containers to avoid substantial changes to PLEG. // TODO: Remove this once it becomes obsolete.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 22 02:01:31 UTC 2024 - 12K bytes - Viewed (0) -
pkg/kubelet/pleg/evented.go
if sandboxStatus.State == runtimeapi.PodSandboxState_SANDBOX_READY { return status.IPs } } // For pods with no ready containers or sandboxes (like exited pods) // use the old status' pod IP return oldStatus.IPs } func (e *EventedPLEG) sendPodLifecycleEvent(event *PodLifecycleEvent) { select { case e.eventChannel <- event: default:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 10:46:06 UTC 2024 - 16.4K bytes - Viewed (0) -
pkg/kubelet/metrics/metrics.go
Help: "Cumulative number of pods started", StabilityLevel: metrics.ALPHA, }, ) // StartedPodsErrorsTotal is a counter that tracks the number of errors creating pod sandboxes StartedPodsErrorsTotal = metrics.NewCounter( &metrics.CounterOpts{ Subsystem: KubeletSubsystem, Name: StartedPodsErrorsTotalKey,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 22 15:13:25 UTC 2024 - 45.6K bytes - Viewed (0) -
pkg/kubelet/stats/cri_stats_provider.go
podSandboxMap := make(map[string]*runtimeapi.PodSandbox) podSandboxes, err := p.runtimeService.ListPodSandbox(ctx, &runtimeapi.PodSandboxFilter{}) if err != nil { return nil, nil, fmt.Errorf("failed to list all pod sandboxes: %v", err) } podSandboxes = removeTerminatedPods(podSandboxes) for _, s := range podSandboxes { podSandboxMap[s.Id] = s } containers = removeTerminatedContainers(containers)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 18:46:33 UTC 2023 - 35.1K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
} // killPod instructs the container runtime to kill the pod. This method requires that // the pod status contains the result of the last syncPod, otherwise it may fail to // terminate newly created containers and sandboxes. func (kl *Kubelet) killPod(ctx context.Context, pod *v1.Pod, p kubecontainer.Pod, gracePeriodOverride *int64) error { // Call the container runtime KillPod method which stops all known running containers of the pod
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0) -
tools/istio-iptables/pkg/dependencies/implementation_linux_test.go
original := file.AsStringOrFail(t, "/etc/nsswitch.conf") var sandboxed string originalNetNS, err := netns.Get() assert.NoError(t, err) var sandboxedNetNS netns.NsHandle // Due to unshare-go imports above, this can run assert.NoError(t, runInSandbox("", func() error { // We should have overwritten this file with /dev/null sandboxed = file.AsStringOrFail(t, "/etc/nsswitch.conf") sandboxedNetNS, err = netns.Get()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Feb 26 20:05:40 UTC 2024 - 1.6K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
func (kl *Kubelet) ListMetricDescriptors(ctx context.Context) ([]*runtimeapi.MetricDescriptor, error) { return kl.containerRuntime.ListMetricDescriptors(ctx) } // ListPodSandboxMetrics retrieves the metrics for all pod sandboxes. func (kl *Kubelet) ListPodSandboxMetrics(ctx context.Context) ([]*runtimeapi.PodSandboxMetrics, error) { return kl.containerRuntime.ListPodSandboxMetrics(ctx) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0)