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