Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 23 for poduid (0.05 sec)

  1. cni/pkg/nodeagent/server_test.go

    	var podUID string = string(pod.ObjectMeta.UID)
    	ipProto := uint8(unix.IPPROTO_TCP)
    
    	fakeIPSetDeps.On("addIP",
    		"foo-v4",
    		netip.MustParseAddr("99.9.9.9"),
    		ipProto,
    		podUID,
    		false,
    	).Return(nil)
    
    	fakeIPSetDeps.On("addIP",
    		"foo-v4",
    		netip.MustParseAddr("2.2.2.2"),
    		ipProto,
    		podUID,
    		false,
    	).Return(nil)
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/podcgroupns_test.go

    		},
    	} {
    		t.Run(tt.name, func(t *testing.T) {
    			podUID, containerID, err := getPodUIDAndContainerIDFromCGroups(makeCGroups(tt.cgroupPaths))
    
    			if tt.expectMsg != "" {
    				assert.Equal(t, tt.expectMsg, err.Error())
    				return
    			}
    			assert.Equal(t, tt.expectPodUID, podUID)
    			assert.Equal(t, tt.expectContainerID, containerID)
    		})
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 17:36:49 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/server.go

    	// - the CmdAdd comes back thru here with a new IP
    	// - we will never clean up that old IP that we "lost"
    	// To fix this we probably need to impl CmdDel + manage our own podUID/IP mapping.
    	if retErr == nil {
    		// Handle node healthcheck probe rewrites
    		_, err = s.addPodToHostNSIpset(pod, podIPs)
    		if err != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Sep 25 20:54:34 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  4. cni/pkg/util/podutil.go

    		return nil
    	}
    	return err
    }
    
    // Get any IPs currently assigned to the Pod.
    //
    // If 'PodIPs' exists, it is preferred (and should be guaranteed to contain the address in 'PodIP'),
    // otherwise fallback to 'PodIP'.
    //
    // Note that very early in the pod's lifecycle (before all the node CNI plugin invocations finish)
    // K8S may not have received the pod IPs yet, and may not report the pod as having any.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  5. CHANGELOG/CHANGELOG-1.32.md

    - Optimize code, filter podUID is empty string when call this `getPodAndContainerForDevice` method. ([#126997](https://github.com/kubernetes/kubernetes/pull/126997), [@lengrongfu](https://github.com/lengrongfu)) [SIG Node]
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Tue Oct 29 20:17:52 UTC 2024
    - 121.6K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/informers_test.go

    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "test",
    			Namespace: "test",
    		},
    		Spec: corev1.PodSpec{
    			NodeName: NodeName,
    		},
    		Status: corev1.PodStatus{
    			PodIPs: []corev1.PodIP{},
    			PodIP:  "",
    		},
    	}
    	ns := &corev1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: "test"}}
    
    	client := kube.NewFakeClient(ns, pod)
    
    	fs := &fakeServer{}
    
    	server := getFakeDP(fs, client.Kube())
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  7. cni/pkg/util/podutil_test.go

    			Namespace: "test",
    		},
    		Spec: corev1.PodSpec{
    			NodeName: "derp",
    		},
    		Status: corev1.PodStatus{
    			PodIP:  "2.2.2.2",
    			PodIPs: []corev1.PodIP{{IP: "2.2.2.2"}, {IP: "3.3.3.3"}},
    		},
    	}
    
    	podIPs := GetPodIPsIfPresent(pod)
    	assert.Equal(t, len(podIPs), 2)
    }
    
    func TestGetPodIPsIfNoPodIPPresent(t *testing.T) {
    	pod := &corev1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "test",
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  8. cni/pkg/nodeagent/cni-watcher_test.go

    	pod := &corev1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "pod-bingo",
    			Namespace: "funkyns",
    		},
    		Spec: corev1.PodSpec{
    			NodeName: NodeName,
    		},
    		Status: corev1.PodStatus{
    			PodIP: fakePodIP,
    		},
    	}
    	ns := &corev1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: "funkyns"}}
    
    	client := kube.NewFakeClient(ns, pod)
    
    	// We are expecting at most 1 calls to the mock, wait for them
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/collect/EnumHashBiMapTest.java

     * @author Mike Bostock
     */
    @J2ktIncompatible // EnumHashBiMap
    @GwtCompatible(emulated = true)
    public class EnumHashBiMapTest extends TestCase {
      private enum Currency {
        DOLLAR,
        FRANC,
        PESO,
        POUND,
        YEN
      }
    
      private enum Country {
        CANADA,
        CHILE,
        JAPAN,
        SWITZERLAND,
        UK
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  10. docs/es/docs/tutorial/first-steps.md

    # Primeros pasos
    
    Un archivo muy simple de FastAPI podría verse así:
    
    ```Python
    {!../../docs_src/first_steps/tutorial001.py!}
    ```
    
    Copia eso a un archivo `main.py`.
    
    Corre el servidor en vivo:
    
    <div class="termy">
    
    ```console
    $ uvicorn main:app --reload
    
    <span style="color: green;">INFO</span>:     Uvicorn running on http://127.0.0.1:8000 (Press CTRL+C to quit)
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 9.9K bytes
    - Viewed (0)
Back to top