Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for syncHostIPSets (0.11 sec)

  1. cni/pkg/nodeagent/net_test.go

    		ipProto,
    		podUID,
    		false,
    	).Return(nil)
    
    	fixture.ipsetDeps.On("listEntriesByIP",
    		"foo-v4",
    	).Return([]netip.Addr{}, nil)
    
    	netServer := fixture.netServer
    	err := netServer.syncHostIPSets([]*corev1.Pod{pod})
    	assert.NoError(t, err)
    	fakeIPSetDeps.AssertExpectations(t)
    }
    
    func TestSyncHostIPSetsIgnoresPodIPAddErrorAndContinues(t *testing.T) {
    	pod1 := buildConvincingPod(false)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 05:10:23 UTC 2024
    - 17.8K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/net.go

    //
    // 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 {
    		log.Warnf("failed to sync host IPset: %v", err)
    		consErr = append(consErr, err)
    	}
    
    	podsByUID := slices.GroupUnique(ambientPods, (*corev1.Pod).GetUID)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 05:10:23 UTC 2024
    - 13.4K bytes
    - Viewed (0)
Back to top