Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for ConstructInitialSnapshot (0.29 sec)

  1. cni/pkg/nodeagent/server.go

    	}
    
    	s.netServer.Stop()
    }
    
    func (s *meshDataplane) ConstructInitialSnapshot(ambientPods []*corev1.Pod) error {
    	if err := s.syncHostIPSets(ambientPods); err != nil {
    		log.Errorf("failed to sync host IPset: %v", err)
    		return err
    	}
    
    	return s.netServer.ConstructInitialSnapshot(ambientPods)
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Sep 25 20:54:34 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  2. 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
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Oct 21 16:48:55 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/net_test.go

    	podMeta := metav1.ObjectMeta{
    		Name:      "foo",
    		Namespace: "bar",
    		UID:       types.UID("863b91d4-4b68-4efa-917f-4b560e3e86aa"),
    	}
    	pod := &corev1.Pod{ObjectMeta: podMeta}
    
    	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")
    	}
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jul 25 16:13:38 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/server_test.go

    	}
    	args := f.Called(ctx, pod, isDelete)
    	return args.Error(0)
    }
    
    func (f *fakeServer) Start(ctx context.Context) {
    }
    
    func (f *fakeServer) Stop() {
    }
    
    func (f *fakeServer) ConstructInitialSnapshot(ambientPods []*corev1.Pod) error {
    	if f.testWG != nil {
    		defer f.testWG.Done()
    	}
    	args := f.Called(ambientPods)
    	return args.Error(0)
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 18.7K bytes
    - Viewed (0)
Back to top