kubernetes: k8s.io/kubernetes/pkg/kubelet/pluginmanager/reconciler Index | Files

package reconciler

import "k8s.io/kubernetes/pkg/kubelet/pluginmanager/reconciler"

Package reconciler implements interfaces that attempt to reconcile the desired state of the world with the actual state of the world by triggering relevant actions (register/deregister plugins).


Package Files


type Reconciler Uses

type Reconciler interface {
    // Run starts running the reconciliation loop which executes periodically,
    // checks if plugins are correctly registered or unregistered.
    // If not, it will trigger register/unregister operations to rectify.
    Run(stopCh <-chan struct{})

    // AddHandler adds the given plugin handler for a specific plugin type,
    // which will be added to the actual state of world cache.
    AddHandler(pluginType string, pluginHandler cache.PluginHandler)

Reconciler runs a periodic loop to reconcile the desired state of the world with the actual state of the world by triggering register and unregister operations. Also provides a means to add a handler for a plugin type.

func NewReconciler Uses

func NewReconciler(
    operationExecutor operationexecutor.OperationExecutor,
    loopSleepDuration time.Duration,
    desiredStateOfWorld cache.DesiredStateOfWorld,
    actualStateOfWorld cache.ActualStateOfWorld) Reconciler

NewReconciler returns a new instance of Reconciler.

loopSleepDuration - the amount of time the reconciler loop sleeps between

successive executions
syncDuration - the amount of time the syncStates sleeps between
successive executions

operationExecutor - used to trigger register/unregister operations safely

(prevents more than one operation from being triggered on the same
socket path)

desiredStateOfWorld - cache containing the desired state of the world actualStateOfWorld - cache containing the actual state of the world

Package reconciler imports 8 packages (graph) and is imported by 1 packages. Updated 2021-01-06. Refresh now. Tools for package owners.