Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 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/instancecount_test.go

    		},
    	}
    	for _, test := range reconcileTests {
    		t.Run(test.testName, func(t *testing.T) {
    			fakeClient := fake.NewSimpleClientset(test.initialState...)
    			epAdapter := NewEndpointsAdapter(fakeClient.CoreV1(), fakeClient.DiscoveryV1())
    			reconciler := NewMasterCountEndpointReconciler(test.additionalMasters+1, epAdapter)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 27 12:46:24 UTC 2022
    - 14K bytes
    - Viewed (0)
  3. pkg/controlplane/reconcilers/endpointsadapter.go

    // of the 1:1 mapping this allows.
    type EndpointsAdapter struct {
    	endpointClient      corev1client.EndpointsGetter
    	endpointSliceClient discoveryclient.EndpointSlicesGetter
    }
    
    // NewEndpointsAdapter returns a new EndpointsAdapter.
    func NewEndpointsAdapter(endpointClient corev1client.EndpointsGetter, endpointSliceClient discoveryclient.EndpointSlicesGetter) EndpointsAdapter {
    	return EndpointsAdapter{
    		endpointClient:      endpointClient,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 27 12:46:23 UTC 2022
    - 7.8K bytes
    - Viewed (0)
  4. 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)
  5. 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