kubernetes/pkg/kubelet/cm/devicemanager/endpoint_test.go

type monitorCallback …

func newMockPluginManager() *mockPluginManager { … }

type mockPluginManager …

func (m *mockPluginManager) CleanupPluginDirectory(r string) error { … }

func (m *mockPluginManager) PluginConnected(r string, p plugin.DevicePlugin) error { … }

func (m *mockPluginManager) PluginDisconnected(r string) { … }

func (m *mockPluginManager) PluginListAndWatchReceiver(r string, lr *pluginapi.ListAndWatchResponse) { … }

func esocketName() string { … }

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

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

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

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

func esetup(t *testing.T, devs []*pluginapi.Device, socket, resourceName string, callback monitorCallback) (*plugin.Stub, *endpointImpl) { … }

func ecleanup(t *testing.T, p *plugin.Stub, e *endpointImpl) { … }