kubernetes/pkg/kubelet/pluginmanager/reconciler/reconciler.go

type Reconciler …

// NewReconciler returns a new instance of Reconciler.
//
// operationExecutor - used to trigger register/unregister operations safely
// (prevents more than one operation from being triggered on the same
// socket path)
//
// loopSleepDuration - the amount of time the reconciler loop sleeps between
// successive executions
//
// desiredStateOfWorld - cache containing the desired state of the world
//
// actualStateOfWorld - cache containing the actual state of the world
func NewReconciler(
	operationExecutor operationexecutor.OperationExecutor,
	loopSleepDuration time.Duration,
	desiredStateOfWorld cache.DesiredStateOfWorld,
	actualStateOfWorld cache.ActualStateOfWorld) Reconciler { … }

type reconciler …

var _ …

func (rc *reconciler) Run(stopCh <-chan struct{ … }

func (rc *reconciler) AddHandler(pluginType string, pluginHandler cache.PluginHandler) { … }

func (rc *reconciler) getHandlers() map[string]cache.PluginHandler { … }

func (rc *reconciler) reconcile() { … }