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() {}