- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 4,604 for GetPod (0.38 sec)
-
pkg/api/v1/resource/helpers_test.go
expectedValue int64 }{ { pod: getPod("foo", podResources{cpuRequest: "9"}), resourceName: v1.ResourceCPU, expectedValue: 9000, }, { pod: getPod("foo", podResources{memoryRequest: "90Mi"}), resourceName: v1.ResourceMemory, expectedValue: 94371840, }, { cName: "just-overhead for cpu", pod: getPod("foo", podResources{cpuOverhead: "5", memoryOverhead: "5"}),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 07 22:26:13 UTC 2023 - 38.3K bytes - Viewed (0) -
pkg/scheduler/internal/cache/fake/fake_cache.go
return c.IsAssumedPodFunc(pod), nil } // GetPod is a fake method for testing. func (c *Cache) GetPod(pod *v1.Pod) (*v1.Pod, error) { return c.GetPodFunc(pod), nil } // AddNode is a fake method for testing. func (c *Cache) AddNode(logger klog.Logger, node *v1.Node) *framework.NodeInfo { return nil } // UpdateNode is a fake method for testing.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 29 05:26:32 UTC 2023 - 2.8K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/waiting_pods_map.go
msg := fmt.Sprintf("rejected due to timeout after waiting %v at plugin %v", waitTime, plugin) wp.Reject(plugin, msg) }) } return wp } // GetPod returns a reference to the waiting pod. func (w *waitingPod) GetPod() *v1.Pod { return w.pod } // GetPendingPlugins returns a list of pending permit plugin's name. func (w *waitingPod) GetPendingPlugins() []string { w.mu.RLock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 4.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/endpointslice.go
// correctness and security. // // Note: this is only used by endpointslice controller func getPod(c *Controller, ip string, ep *metav1.ObjectMeta, targetRef *corev1.ObjectReference, host host.Name) (*corev1.Pod, bool) { var expectPod bool pod := c.getPod(ip, ep.Namespace, targetRef) if targetRef != nil && targetRef.Kind == "Pod" { expectPod = true if pod == nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 16.9K bytes - Viewed (0) -
pkg/scheduler/internal/cache/interface.go
// RemovePod removes a pod. The pod's information would be subtracted from assigned node. RemovePod(logger klog.Logger, pod *v1.Pod) error // GetPod returns the pod from the cache with the same namespace and the // same name of the specified pod. GetPod(pod *v1.Pod) (*v1.Pod, error) // IsAssumedPod returns true if the pod is assumed and not expired. IsAssumedPod(pod *v1.Pod) (bool, error)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 29 05:26:32 UTC 2023 - 5.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/util_test.go
key := "pods/" + obj.Namespace + "/" + obj.Name out := &example.Pod{} err := etcdStorage.Create(context.TODO(), key, obj, out, 0) require.NoError(t, err) return out } getPod := func(name, ns string) *example.Pod { key := "pods/" + ns + "/" + name out := &example.Pod{} err := etcdStorage.Get(context.TODO(), key, storage.GetOptions{}, out) require.NoError(t, err) return out }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 11 12:07:39 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/policy_static_test.go
}, Cells: []int{}, }, }, systemReserved: systemReservedMemory{ 0: map[v1.ResourceName]uint64{ v1.ResourceMemory: 512 * mb, }, }, pod: getPod("pod1", "container1", requirementsBurstable), expectedTopologyHints: nil, topologyHint: &topologymanager.TopologyHint{}, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Sep 17 05:49:15 UTC 2023 - 100.4K bytes - Viewed (0) -
pkg/volume/util/recyclerclient/recycler_client.go
} // recyclerClient abstracts access to a Pod by providing a narrower interface. // This makes it easier to mock a client for testing. type recyclerClient interface { CreatePod(pod *v1.Pod) (*v1.Pod, error) GetPod(name, namespace string) (*v1.Pod, error) DeletePod(name, namespace string) error // WatchPod returns a ListWatch for watching a pod. The stopChannel is used
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 8.5K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_pod_control.go
// with a clientset for writes and listers for reads; for tests we provide stubs. type StatefulPodControlObjectManager interface { CreatePod(ctx context.Context, pod *v1.Pod) error GetPod(namespace, podName string) (*v1.Pod, error) UpdatePod(pod *v1.Pod) error DeletePod(pod *v1.Pod) error CreateClaim(claim *v1.PersistentVolumeClaim) error GetClaim(namespace, claimName string) (*v1.PersistentVolumeClaim, error)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 14.9K bytes - Viewed (0) -
pkg/controller/serviceaccount/tokengetter.go
return serviceAccount, nil } return c.client.CoreV1().ServiceAccounts(namespace).Get(context.TODO(), name, metav1.GetOptions{}) } func (c clientGetter) GetPod(namespace, name string) (*v1.Pod, error) { if pod, err := c.podLister.Pods(namespace).Get(name); err == nil { return pod, nil } return c.client.CoreV1().Pods(namespace).Get(context.TODO(), name, metav1.GetOptions{}) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 21:15:10 UTC 2023 - 3K bytes - Viewed (0)