Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewPeerEndpointLeaseReconciler (0.33 sec)

  1. pkg/controlplane/apiserver/peer.go

    	config, err := storageFactory.NewConfig(api.Resource("apiServerPeerIPInfo"))
    	if err != nil {
    		return nil, fmt.Errorf("error creating storage factory config: %w", err)
    	}
    	reconciler, err := reconcilers.NewPeerEndpointLeaseReconciler(config, "/peerserverleases/", ttl)
    	return reconciler, err
    }
    
    // utility function to get the apiserver address that is used by peer apiservers to proxy
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 08:15:02 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/reconcilers/peer_endpoint_lease.go

    	StopReconciling()
    }
    
    type peerEndpointLeaseReconciler struct {
    	serverLeases          *peerEndpointLeases
    	stopReconcilingCalled atomic.Bool
    }
    
    // NewPeerEndpointLeaseReconciler creates a new peer endpoint lease reconciler
    func NewPeerEndpointLeaseReconciler(config *storagebackend.ConfigForResource, baseKey string, leaseTime time.Duration) (PeerEndpointLeaseReconciler, error) {
    	// note that newFunc, newListFunc and resourcePrefix
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 24 09:23:05 UTC 2023
    - 12.3K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy_handler_test.go

    	config := *sc.ForResource(schema.GroupResource{Resource: "endpoints"})
    	baseKey := "/" + uuid.New().String() + "/peer-testleases/"
    	leaseTime := 1 * time.Minute
    	reconciler, err := reconcilers.NewPeerEndpointLeaseReconciler(&config, baseKey, leaseTime)
    	if err != nil {
    		t.Fatalf("Error creating storage: %v", err)
    	}
    	return reconciler
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 10.8K bytes
    - Viewed (0)
Back to top