- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for NewLeaseEndpointReconciler (0.29 sec)
-
pkg/controlplane/reconcilers/lease_test.go
} 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) if err != nil { t.Errorf("unexpected error reconciling: %v", err) }
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/reconcilers/lease.go
epAdapter EndpointsAdapter masterLeases Leases stopReconcilingCalled atomic.Bool reconcilingLock sync.Mutex } // NewLeaseEndpointReconciler creates a new LeaseEndpoint reconciler func NewLeaseEndpointReconciler(epAdapter EndpointsAdapter, masterLeases Leases) EndpointReconciler { return &leaseEndpointReconciler{ epAdapter: epAdapter, masterLeases: masterLeases, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 11.3K bytes - Viewed (0) -
pkg/controlplane/instance.go
} masterLeases, err := reconcilers.NewLeases(config, "/masterleases/", ttl) if err != nil { klog.Fatalf("Error creating leases: %v", err) } return reconcilers.NewLeaseEndpointReconciler(endpointsAdapter, masterLeases) } func (c *Config) createEndpointReconciler() reconcilers.EndpointReconciler { klog.Infof("Using reconciler: %v", c.Extra.EndpointReconcilerType)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 03 11:50:04 UTC 2024 - 21.2K bytes - Viewed (0)