Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for ConstructInitialSnapshot (4.05 sec)

  1. cni/pkg/nodeagent/net.go

    	return s.ztunnelServer.PodAdded(ctx, pod, netns)
    }
    
    // ConstructInitialSnapshot takes a "snapshot" of current ambient pods and
    //
    // 1. Constructs a ztunnel state message to initialize ztunnel
    // 2. Syncs the host ipset
    func (s *NetServer) ConstructInitialSnapshot(ambientPods []*corev1.Pod) error {
    	var consErr []error
    
    	if err := s.syncHostIPSets(ambientPods); err != nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 12.2K bytes
    - Viewed (1)
  2. cni/pkg/nodeagent/net_test.go

    	}
    	pod := &corev1.Pod{ObjectMeta: podMeta}
    
    	fixture.ipsetDeps.On("listEntriesByIP",
    		"foo-v4",
    	).Return([]netip.Addr{}, nil)
    
    	err := netServer.ConstructInitialSnapshot([]*corev1.Pod{pod})
    	assert.NoError(t, err)
    	if fixture.podNsMap.Get("863b91d4-4b68-4efa-917f-4b560e3e86aa") == nil {
    		t.Fatal("expected pod to be in cache")
    	}
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 16.4K bytes
    - Viewed (0)
Back to top