- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for NewEndpointsAdapter (0.14 sec)
-
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) -
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) -
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) -
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) -
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)