Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for reconciliation (0.19 sec)

  1. pkg/kubelet/volumemanager/reconciler/reconciler.go

    	}
    	if len(rc.volumesNeedUpdateFromNodeStatus) == 0 {
    		// ASW is fully populated only after both devicePaths and uncertain volume attach-ability
    		// were reconstructed from the API server.
    		// This will start reconciliation of node.status.volumesInUse.
    		rc.updateLastSyncTime()
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 10:23:12 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  2. pkg/controlplane/apiserver/peer.go

    		versionedInformer,
    		svm,
    		proxyRoundTripper,
    		apiServerID,
    		reconciler,
    		serializer,
    	), nil
    }
    
    // CreatePeerEndpointLeaseReconciler creates a apiserver endpoint lease reconciliation loop
    // The peer endpoint leases are used to find network locations of apiservers for peer 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)
  3. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller.go

    type controller[T runtime.Object] struct {
    	informer Informer[T]
    	queue    workqueue.TypedRateLimitingInterface[string]
    
    	// Returns an error if there was a transient error during reconciliation
    	// and the object should be tried again later.
    	reconciler func(namespace, name string, newObj T) error
    
    	options ControllerOptions
    
    	// must hold a func() bool or nil
    	notificationsDelivered atomic.Value
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 7.5K bytes
    - Viewed (0)
Back to top