- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 108 for podB (0.26 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_interval_test.go
} } func TestCacheIntervalNextFromStore(t *testing.T) { getAttrsFunc := func(obj runtime.Object) (labels.Set, fields.Set, error) { pod, ok := obj.(*v1.Pod) if !ok { return nil, nil, fmt.Errorf("not a pod") } return labels.Set(pod.Labels), fields.Set{"spec.nodeName": pod.Spec.NodeName}, nil } const numEvents = 50 store := cache.NewIndexer(storeElementKey, storeElementIndexers(nil))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 11.6K bytes - Viewed (0) -
pkg/test/framework/components/echo/echotest/filters_test.go
AllClusters: allClusters, }} // simple pod a1 = &fakeInstance{Cluster: cls1, Namespace: echo1NS, Service: "a"} a2 = &fakeInstance{Cluster: cls2, Namespace: echo1NS, Service: "a"} // simple pod with different svc b1 = &fakeInstance{Cluster: cls1, Namespace: echo1NS, Service: "b"} b2 = &fakeInstance{Cluster: cls2, Namespace: echo1NS, Service: "b"} // another simple pod with different svc
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 13.1K bytes - Viewed (0) -
pkg/volume/plugins.go
// 2. pod.GenerateName helps distinguish recycler pods by name. Recommended. // Default is "pv-recycler-". // 3. pod.Spec.ActiveDeadlineSeconds gives the recycler pod a maximum timeout // before failing. Recommended. Default is 60 seconds. // // See HostPath and NFS for working recycler examples func NewPersistentVolumeRecyclerPodTemplate() *v1.Pod { timeout := int64(60) pod := &v1.Pod{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:13:15 UTC 2024 - 38.2K bytes - Viewed (0) -
pkg/bootstrap/config.go
const ( // DefaultDeploymentUniqueLabelKey is the default key of the selector that is added // to existing ReplicaSets (and label key that is added to its pods) to prevent the existing ReplicaSets // to select new pods (and old pods being select by new ReplicaSet). DefaultDeploymentUniqueLabelKey string = "pod-template-hash" ) // GetNodeMetaData function uses an environment variable contract
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:02:38 UTC 2024 - 27.6K bytes - Viewed (0) -
pkg/kubelet/config/config.go
} else { klog.V(4).InfoS("Updating pods from source", "source", source, "pods", klog.KObjSlice(update.Pods)) } updatePodsFunc(update.Pods, pods, pods) case kubetypes.REMOVE: klog.V(4).InfoS("Removing pods from source", "source", source, "pods", klog.KObjSlice(update.Pods)) for _, value := range update.Pods {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 16.7K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_gc.go
// evictPodLogsDirectories evicts all evictable pod logs directories. Pod logs directories // are evictable if there are no corresponding pods. func (cgc *containerGC) evictPodLogsDirectories(ctx context.Context, allSourcesReady bool) error { osInterface := cgc.manager.osInterface podLogsDirectory := cgc.manager.podLogsDirectory if allSourcesReady { // Only remove pod logs directories when all sources are ready.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 15.3K bytes - Viewed (0) -
pkg/kubelet/config/config_test.go
CreatePodUpdate(kubetypes.UPDATE, TestSource, pod)) } func TestNewPodAddedSetReconciled(t *testing.T) { tCtx := ktesting.Init(t) // Create and touch new test pods, return the new pods and touched pod. We should create new pod list // before touching to avoid data race. newTestPods := func(touchStatus, touchSpec bool) ([]*v1.Pod, *v1.Pod) { pods := []*v1.Pod{ CreateValidPod("changeable-pod-0", "new"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 17.1K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_container_linux_test.go
} l1, _ := m.generateLinuxContainerConfig(&pod1.Spec.Containers[0], pod1, new(int64), "", nil, true) l2, _ := m.generateLinuxContainerConfig(&pod2.Spec.Containers[0], pod2, new(int64), "", nil, true) tests := []struct { name string pod *v1.Pod expected *expectedResult }{ { name: "Request128MBLimit256MB", pod: pod1, expected: &expectedResult{ l1, 128 * 1024 * 1024,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 41K bytes - Viewed (0) -
staging/src/k8s.io/api/policy/v1/types.go
// +k8s:prerelease-lifecycle-gen:introduced=1.22 // Eviction evicts a pod from its node subject to certain policies and safety constraints. // This is a subresource of Pod. A request to cause such an eviction is // created by POSTing to .../pods/<pod name>/evictions. type Eviction struct { metav1.TypeMeta `json:",inline"` // ObjectMeta describes the pod that is being evicted. // +optional
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 23 17:42:49 UTC 2024 - 10.8K bytes - Viewed (0) -
pkg/test/kube/dump.go
func DumpPodLogs(_ resource.Context, c cluster.Cluster, workDir, namespace string, pods ...corev1.Pod) { pods = podsOrFetch(c, pods, namespace) for _, pod := range pods { isVM := checkIfVM(pod) containers := append(pod.Spec.Containers, pod.Spec.InitContainers...) for _, container := range containers { l, err := c.PodLogs(context.TODO(), pod.Name, pod.Namespace, container.Name, false /* previousLog */) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 22.2K bytes - Viewed (0)