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

const reconcilerLoopSleepDuration …

var socketDir …

var supportedVersions …

func init() { … }

func cleanup(t *testing.T) { … }

func runReconciler(reconciler Reconciler) { … }

func waitForRegistration(
	t *testing.T,
	socketPath string,
	expectedUUID types.UID,
	asw cache.ActualStateOfWorld) { … }

func waitForUnregistration(
	t *testing.T,
	socketPath string,
	asw cache.ActualStateOfWorld) { … }

func retryWithExponentialBackOff(initialDuration time.Duration, fn wait.ConditionFunc) error { … }

type DummyImpl …

func NewDummyImpl() *DummyImpl { … }

// ValidatePlugin is a dummy implementation
func (d *DummyImpl) ValidatePlugin(pluginName string, endpoint string, versions []string) error { … }

// RegisterPlugin is a dummy implementation
func (d *DummyImpl) RegisterPlugin(pluginName string, endpoint string, versions []string, pluginClientTimeout *time.Duration) error { … }

// DeRegisterPlugin is a dummy implementation
func (d *DummyImpl) DeRegisterPlugin(pluginName string) { … }

// Calls Run()
// Verifies that asw and dsw have no plugins
func Test_Run_Positive_DoNothing(t *testing.T) { … }

// Populates desiredStateOfWorld cache with one plugin.
// Calls Run()
// Verifies the actual state of world contains that plugin
func Test_Run_Positive_Register(t *testing.T) { … }

// Populates desiredStateOfWorld cache with one plugin
// Calls Run()
// Verifies there is one plugin now in actual state of world.
// Deletes plugin from desired state of world.
// Verifies that plugin no longer exists in actual state of world.
func Test_Run_Positive_RegisterThenUnregister(t *testing.T) { … }

// Populates desiredStateOfWorld cache with one plugin
// Calls Run()
// Then update the timestamp of the plugin
// Verifies that the plugin is reregistered.
// Verifies the plugin with updated timestamp now in actual state of world.
func Test_Run_Positive_ReRegister(t *testing.T) { … }