Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewEndpointsAdapter (0.14 sec)

  1. pkg/controlplane/reconcilers/endpointsadapter_test.go

    			nameParam:         "bar",
    		},
    	}
    
    	for name, testCase := range testCases {
    		t.Run(name, func(t *testing.T) {
    			client := fake.NewSimpleClientset(testCase.initialState...)
    			epAdapter := NewEndpointsAdapter(client.CoreV1(), client.DiscoveryV1())
    
    			endpoints, err := epAdapter.Get(testCase.namespaceParam, testCase.nameParam, metav1.GetOptions{})
    
    			if !apiequality.Semantic.DeepEqual(testCase.expectedError, err) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 12:23:16 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  2. pkg/controlplane/reconcilers/lease_test.go

    			err := fakeLeases.SetKeys(test.endpointKeys)
    			if err != nil {
    				t.Errorf("unexpected error creating keys: %v", err)
    			}
    			clientset := fake.NewSimpleClientset(test.initialState...)
    
    			epAdapter := NewEndpointsAdapter(clientset.CoreV1(), clientset.DiscoveryV1())
    			r := NewLeaseEndpointReconciler(epAdapter, fakeLeases)
    			err = r.ReconcileEndpoints(test.serviceName, netutils.ParseIPSloppy(test.ip), test.endpointPorts, true)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 24 09:23:05 UTC 2023
    - 28.7K bytes
    - Viewed (0)
  3. pkg/controlplane/instance.go

    	endpointSliceClient := discoveryclient.NewForConfigOrDie(c.ControlPlane.Generic.LoopbackClientConfig)
    	endpointsAdapter := reconcilers.NewEndpointsAdapter(endpointClient, endpointSliceClient)
    
    	return reconcilers.NewMasterCountEndpointReconciler(c.Extra.MasterCount, endpointsAdapter)
    }
    
    func (c *Config) createNoneReconciler() reconcilers.EndpointReconciler {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 03 11:50:04 UTC 2024
    - 21.2K bytes
    - Viewed (0)
Back to top