Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewLeaseEndpointReconciler (0.29 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top