reconciler

Documentation

Overview

Package reconciler implements interfaces that attempt to reconcile the desired state of the with the actual state of the world by triggering actions.

Index

• type Reconciler
  • func NewReconciler(loopPeriod time.Duration, maxSafeToDetachDuration time.Duration, ...) Reconciler

Types

type Reconciler

type Reconciler interface {
	// Starts running the reconcilation loop which executes periodically, checks
	// if volumes that should be attached are attached and volumes that should
	// be detached are detached. If not, it will trigger attach/detach
	// operations to rectify.
	Run(stopCh <-chan struct{})
}

Reconciler runs a periodic loop to reconcile the desired state of the with the actual state of the world by triggering attach detach operations.

func NewReconciler

func NewReconciler(
	loopPeriod time.Duration,
	maxSafeToDetachDuration time.Duration,
	desiredStateOfWorld cache.DesiredStateOfWorld,
	actualStateOfWorld cache.ActualStateOfWorld,
	attacherDetacher attacherdetacher.AttacherDetacher) Reconciler

NewReconciler returns a new instance of Reconciler that waits loopPeriod between successive executions. loopPeriod is the ammount of time the reconciler loop waits between successive executions. maxSafeToDetachDuration is the max ammount of time the reconciler will wait for the volume to deatch, after this it will detach the volume anyway assuming the node is unavilable. If during this time the volume becomes used by a new pod, the detach request will be aborted and the timer cleared.